Use resync period in event handlers

practo · Feb 4, 2022 · fef9160 · fef9160
1 parent 158d426
commit fef9160
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/cmd/workerpodautoscaler/run.go b/cmd/workerpodautoscaler/run.go
@@ -192,6 +192,7 @@ func (v *runCmd) run(cmd *cobra.Command, args []string) {
 		kubeInformerFactory.Apps().V1().ReplicaSets(),
 		customInformerFactory.K8s().V1().WorkerPodAutoScalers(),
 		wpaDefaultMaxDisruption,
+                resyncPeriod,
 		queues,
 	)
 

diff --git a/pkg/controller/controller.go b/pkg/controller/controller.go
@@ -199,6 +199,7 @@ func NewController(
 	replicaSetInformer appsinformers.ReplicaSetInformer,
 	workerPodAutoScalerInformer informers.WorkerPodAutoScalerInformer,
 	defaultMaxDisruption string,
+        resyncPeriod time.Duration,
 	queues *queue.Queues) *Controller {
 
 	// Create event broadcaster
@@ -230,13 +231,13 @@ func NewController(
 	klog.V(4).Info("Setting up event handlers")
 
 	// Set up an event handler for when WorkerPodAutoScaler resources change
-	workerPodAutoScalerInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
+	workerPodAutoScalerInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{
 		AddFunc: controller.enqueueAddWorkerPodAutoScaler,
 		UpdateFunc: func(old, new interface{}) {
 			controller.enqueueUpdateWorkerPodAutoScaler(new)
 		},
 		DeleteFunc: controller.enqueueDeleteWorkerPodAutoScaler,
-	})
+	}, resyncPeriod)
 	return controller
 }