Merge pull request #3214 from yuswift/feature/support_configurable_cluster_resync_perioud

Configurable cluster resync perioud

pkg/controller/cluster/cluster_controller.go

@@ -158,6 +158,8 @@ type clusterController struct {
 	mu sync.RWMutex
 
 	clusterMap map[string]*clusterData
+
+	resyncPeriod time.Duration
 }
 
 func NewClusterController(
@@ -166,6 +168,7 @@ func NewClusterController(
 	clusterInformer clusterinformer.ClusterInformer,
 	clusterClient clusterclient.ClusterInterface,
 	openpitrixClient openpitrix.Client,
+	resyncPeriod time.Duration,
 ) *clusterController {
 
 	broadcaster := record.NewBroadcaster()
@@ -185,23 +188,18 @@ func NewClusterController(
 		queue:            workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "cluster"),
 		workerLoopPeriod: time.Second,
 		clusterMap:       make(map[string]*clusterData),
+		resyncPeriod:     resyncPeriod,
 	}
-
 	c.clusterLister = clusterInformer.Lister()
 	c.clusterHasSynced = clusterInformer.Informer().HasSynced
 
-	clusterInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
+	clusterInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{
 		AddFunc: c.addCluster,
 		UpdateFunc: func(oldObj, newObj interface{}) {
-			newCluster := newObj.(*clusterv1alpha1.Cluster)
-			oldCluster := oldObj.(*clusterv1alpha1.Cluster)
-			if newCluster.ResourceVersion == oldCluster.ResourceVersion {
-				return
-			}
 			c.addCluster(newObj)
 		},
 		DeleteFunc: c.addCluster,
-	})
+	}, resyncPeriod)
 
 	return c
 }
@@ -227,15 +225,11 @@ func (c *clusterController) Run(workers int, stopCh <-chan struct{}) error {
 
 	// refresh cluster configz every 2 minutes
 	go wait.Until(func() {
-		if err := c.syncStatus(); err != nil {
-			klog.Errorf("Error periodically sync cluster status, %v", err)
-		}
-
 		if err := c.reconcileHostCluster(); err != nil {
 			klog.Errorf("Error create host cluster, error %v", err)
 		}
 
-	}, 2*time.Minute, stopCh)
+	}, c.resyncPeriod, stopCh)
 
 	<-stopCh
 	return nil
@@ -355,6 +349,7 @@ func (c *clusterController) reconcileHostCluster() error {
 }
 
 func (c *clusterController) syncCluster(key string) error {
+	klog.V(5).Infof("starting to sync cluster %s", key)
 	startTime := time.Now()
 
 	_, name, err := cache.SplitMetaNamespaceKey(key)