ContextWithOptionalTimeout wraps context.WithTimeout and handles infinite timeouts expressed as 0 duration.

ListWatchUntil first lists objects, converts them into synthetic ADDED events and checks conditions for those synthetic events.

NewIndexerInformerWatcher will create an IndexerInformer and wrap it into watch.Interface so you can use it anywhere where you'd have used a regular Watcher returned from Watch method.

NewRetryWatcher creates a new RetryWatcher.

Until wraps the watcherClient's watch function with RetryWatcher making sure that watcher gets restarted in case of errors.

UntilWithoutRetry reads items from the watch until each provided condition succeeds, and then returns the last watch encountered.

UntilWithSync creates an informer from lw, optionally checks precondition when the store is synced, and watches the output until each provided condition succeeds, in a way that is identical to function UntilWithoutRetry.

ErrWatchClosed is returned when the watch channel is closed before timeout in UntilWithoutRetry.

RetryWatcher will make sure that in case the underlying watcher is closed (e.g.

ConditionFunc returns true if the condition has been reached, false if it has not been reached yet, or an error if the condition cannot be checked and should terminate.

PreconditionFunc returns true if the condition has been reached, false if it has not been reached yet, or an error if the condition failed or detected an error state.