code: func NewRetryWatcher(initialResourceVersion string, watcherClient cache.Watcher) (*RetryWatcher, error) {
  	return newRetryWatcher(initialResourceVersion, watcherClient, 1*time.Second)
  }
docs: // 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.