pass watchErrorHandler through Options struct

Signed-off-by: Troy Connor <troy0820@users.noreply.github.com>

pkg/cache/cache.go

@@ -188,6 +188,11 @@ type Options struct {
 	// unless there is already one set in ByObject or DefaultNamespaces.
 	DefaultTransform toolscache.TransformFunc
 
+	// DefaultWatchErrorHandler wil be used to the WatchErrorHandler which is called
+	// whenever ListAndWatch drops the connection with an error. After calling this handler,
+	// the informer will backoff and retry.
+	DefaultWatchErrorHandler toolscache.WatchErrorHandler
+
 	// DefaultUnsafeDisableDeepCopy is the default for UnsafeDisableDeepCopy
 	// for everything that doesn't specify this.
 	//
@@ -353,6 +358,7 @@ func newCache(restConfig *rest.Config, opts Options) newCacheFunc {
 					Field: config.FieldSelector,
 				},
 				Transform:             config.Transform,
+				WatchErrorHandler:     opts.DefaultWatchErrorHandler,
 				UnsafeDisableDeepCopy: pointer.BoolDeref(config.UnsafeDisableDeepCopy, false),
 				NewInformer:           opts.newInformer,
 			}),
@@ -381,6 +387,9 @@ func defaultOpts(config *rest.Config, opts Options) (Options, error) {
 		opts.Scheme = scheme.Scheme
 	}
 
+	if opts.DefaultWatchErrorHandler == nil {
+		opts.DefaultWatchErrorHandler = toolscache.DefaultWatchErrorHandler
+	}
 	// Construct a new Mapper if unset
 	if opts.Mapper == nil {
 		var err error

pkg/cache/internal/informers.go

@@ -55,13 +55,9 @@ type InformersOpts struct {
 // NewInformers creates a new InformersMap that can create informers under the hood.
 func NewInformers(config *rest.Config, options *InformersOpts) *Informers {
 	newInformer := cache.NewSharedIndexInformer
-	watchErrorHandler := cache.DefaultWatchErrorHandler
 	if options.NewInformer != nil {
 		newInformer = *options.NewInformer
 	}
-	if options.WatchErrorHandler != nil {
-		watchErrorHandler = options.WatchErrorHandler
-	}
 	return &Informers{
 		config:     config,
 		httpClient: options.HTTPClient,
@@ -81,7 +77,7 @@ func NewInformers(config *rest.Config, options *InformersOpts) *Informers {
 		transform:             options.Transform,
 		unsafeDisableDeepCopy: options.UnsafeDisableDeepCopy,
 		newInformer:           newInformer,
-		watchErrorHandler:     watchErrorHandler,
+		watchErrorHandler:     options.WatchErrorHandler,
 	}
 }