@@ -22,6 +22,7 @@ import (
2222 "net/http"
2323 "time"
2424
25+ "github.com/kcp-dev/apimachinery/v2/third_party/informers"
2526 "golang.org/x/exp/maps"
2627 corev1 "k8s.io/api/core/v1"
2728 "k8s.io/apimachinery/pkg/api/meta"
@@ -170,6 +171,14 @@ type Options struct {
170171 // instead of `reconcile.Result{}`.
171172 SyncPeriod * time.Duration
172173
174+ // NewInformerFunc is a function that is used to create SharedIndexInformers.
175+ // Defaults to cache.NewSharedIndexInformer from client-go
176+ NewInformerFunc client.NewInformerFunc
177+
178+ // Indexers is the indexers that the informers will be configured to use.
179+ // Will always have the standard NamespaceIndex.
180+ Indexers toolscache.Indexers
181+
173182 // ReaderFailOnMissingInformer configures the cache to return a ErrResourceNotCached error when a user
174183 // requests, using Get() and List(), a resource the cache does not already have an informer for.
175184 //
@@ -223,9 +232,6 @@ type Options struct {
223232 // ByObject restricts the cache's ListWatch to the desired fields per GVK at the specified object.
224233 // object, this will fall through to Default* settings.
225234 ByObject map [client.Object ]ByObject
226-
227- // newInformer allows overriding of NewSharedIndexInformer for testing.
228- newInformer * func (toolscache.ListerWatcher , runtime.Object , time.Duration , toolscache.Indexers ) toolscache.SharedIndexInformer
229235}
230236
231237// ByObject offers more fine-grained control over the cache's ListWatch by object.
@@ -382,7 +388,7 @@ func newCache(restConfig *rest.Config, opts Options) newCacheFunc {
382388 Transform : config .Transform ,
383389 WatchErrorHandler : opts .DefaultWatchErrorHandler ,
384390 UnsafeDisableDeepCopy : ptr .Deref (config .UnsafeDisableDeepCopy , false ),
385- NewInformer : opts .newInformer ,
391+ NewInformer : opts .NewInformerFunc ,
386392 }),
387393 readerFailOnMissingInformer : opts .ReaderFailOnMissingInformer ,
388394 }
@@ -478,6 +484,10 @@ func defaultOpts(config *rest.Config, opts Options) (Options, error) {
478484 if opts .SyncPeriod == nil {
479485 opts .SyncPeriod = & defaultSyncPeriod
480486 }
487+
488+ if opts .NewInformerFunc == nil {
489+ opts .NewInformerFunc = informers .NewSharedIndexInformer
490+ }
481491 return opts , nil
482492}
483493
0 commit comments