kubernetes/staging/src/k8s.io/client-go/tools/watch/retrywatcher.go

type resourceVersionGetter …

type RetryWatcher …

// NewRetryWatcher creates a new RetryWatcher.
// It will make sure that watches gets restarted in case of recoverable errors.
// The initialResourceVersion will be given to watch method when first called.
func NewRetryWatcher(initialResourceVersion string, watcherClient cache.Watcher) (*RetryWatcher, error) { … }

func newRetryWatcher(initialResourceVersion string, watcherClient cache.Watcher, minRestartDelay time.Duration) (*RetryWatcher, error) { … }

func (rw *RetryWatcher) send(event watch.Event) bool { … }

// doReceive returns true when it is done, false otherwise.
// If it is not done the second return value holds the time to wait before calling it again.
func (rw *RetryWatcher) doReceive() (bool, time.Duration) { … }

// receive reads the result from a watcher, restarting it if necessary.
func (rw *RetryWatcher) receive() { … }

// ResultChan implements Interface.
func (rw *RetryWatcher) ResultChan() <-chan watch.Event { … }

// Stop implements Interface.
func (rw *RetryWatcher) Stop() { … }

// Done allows the caller to be notified when Retry watcher stops.
func (rw *RetryWatcher) Done() <-chan struct{ … }