make min resync period configurable

Signed-off-by: sunhaizhou <sunhaizhou@kingsoft.com>
kubeedge · Feb 11, 2022 · c9fa528 · c9fa528
1 parent b30b98e
commit c9fa528
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/pkg/globalmanager/config/config.go b/pkg/globalmanager/config/config.go
@@ -34,6 +34,7 @@ const (
 	defaultWebsocketPort    = 9000
 	defaultLCServer         = "http://localhost:9100"
 	defaultKBServer         = "http://localhost:9020"
+	defaultPeriod           = 30
 )
 
 // ControllerConfig indicates the config of controller
@@ -58,6 +59,10 @@ type ControllerConfig struct {
 
 	// kb config to info the worker
 	KB KBConfig `json:"knowledgeBaseServer,omitempty"`
+
+	// period config min resync period
+	// default 30s
+	MinResyncPeriodSeconds int64 `json:"minResyncPeriodSeconds,omitempty"`
 }
 
 // WebSocket describes GM of websocket config
@@ -120,6 +125,7 @@ func NewDefaultControllerConfig() *ControllerConfig {
 		KB: KBConfig{
 			Server: defaultKBServer,
 		},
+		MinResyncPeriodSeconds: defaultPeriod,
 	}
 }
 

diff --git a/pkg/globalmanager/controllers/manager.go b/pkg/globalmanager/controllers/manager.go
@@ -76,8 +76,7 @@ func (m *Manager) Start() error {
 		namespace = metav1.NamespaceAll
 	}
 
-	// TODO(llhuii): make this period configurable
-	minResyncPeriod := time.Second * 30
+	minResyncPeriod := time.Second * time.Duration(m.Config.MinResyncPeriodSeconds)
 
 	kubeInformerFactory := kubeinformers.NewSharedInformerFactoryWithOptions(kubeClient, genResyncPeriod(minResyncPeriod), kubeinformers.WithNamespace(namespace))