From 3232c52d57b331d7120eeaac9386b848197475df Mon Sep 17 00:00:00 2001 From: wangxiaofei67 Date: Thu, 11 Apr 2024 15:22:08 +0800 Subject: [PATCH] add: Use opts.ResyncPeriod as controlPlaneInformerManager and sharedFactory Signed-off-by: wangxiaofei67 --- cmd/controller-manager/app/controllermanager.go | 4 ++-- pkg/resourceinterpreter/interpreter.go | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/cmd/controller-manager/app/controllermanager.go b/cmd/controller-manager/app/controllermanager.go index 12498841d4f6..d270804c6afe 100644 --- a/cmd/controller-manager/app/controllermanager.go +++ b/cmd/controller-manager/app/controllermanager.go @@ -735,10 +735,10 @@ func setupControllers(mgr controllerruntime.Manager, opts *options.Options, stop return } - controlPlaneInformerManager := genericmanager.NewSingleClusterInformerManager(dynamicClientSet, 0, stopChan) + controlPlaneInformerManager := genericmanager.NewSingleClusterInformerManager(dynamicClientSet, opts.ResyncPeriod.Duration, stopChan) // We need a service lister to build a resource interpreter with `ClusterIPServiceResolver` // witch allows connection to the customized interpreter webhook without a cluster DNS service. - sharedFactory := informers.NewSharedInformerFactory(kubeClientSet, 0) + sharedFactory := informers.NewSharedInformerFactory(kubeClientSet, opts.ResyncPeriod.Duration) serviceLister := sharedFactory.Core().V1().Services().Lister() sharedFactory.Start(stopChan) sharedFactory.WaitForCacheSync(stopChan) diff --git a/pkg/resourceinterpreter/interpreter.go b/pkg/resourceinterpreter/interpreter.go index 68513560290e..db498f7dc0ad 100644 --- a/pkg/resourceinterpreter/interpreter.go +++ b/pkg/resourceinterpreter/interpreter.go @@ -99,6 +99,7 @@ func (i *customResourceInterpreterImpl) Start(ctx context.Context) (err error) { i.defaultInterpreter = native.NewDefaultInterpreter() i.informer.Start() + i.informer.WaitForCacheSync() <-ctx.Done() klog.Infof("Stopped as stopCh closed.") return nil