type resourceVersionGetter …
type RetryWatcher …
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 { … }
func (rw *RetryWatcher) doReceive() (bool, time.Duration) { … }
func (rw *RetryWatcher) receive() { … }
func (rw *RetryWatcher) ResultChan() <-chan watch.Event { … }
func (rw *RetryWatcher) Stop() { … }
func (rw *RetryWatcher) Done() <-chan struct{ … }