diff --git a/pkg/controller/job/job_controller.go b/pkg/controller/job/job_controller.go index dfcd1d56b..1a00d0037 100644 --- a/pkg/controller/job/job_controller.go +++ b/pkg/controller/job/job_controller.go @@ -72,9 +72,7 @@ func NewJobController(jobInformer batchv1informers.JobInformer, client clientset v.jobSynced = jobInformer.Informer().HasSynced jobInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ - AddFunc: func(obj interface{}) { - v.enqueueJob(obj) - }, + AddFunc: v.enqueueJob, UpdateFunc: func(old, cur interface{}) { v.enqueueJob(cur) }, diff --git a/pkg/controller/network/nsnetworkpolicy/nsnetworkpolicy_controller.go b/pkg/controller/network/nsnetworkpolicy/nsnetworkpolicy_controller.go index 5d66294b6..e4f8434ed 100644 --- a/pkg/controller/network/nsnetworkpolicy/nsnetworkpolicy_controller.go +++ b/pkg/controller/network/nsnetworkpolicy/nsnetworkpolicy_controller.go @@ -678,15 +678,11 @@ func NewNSNetworkPolicyController( }) nsnpInformer.Informer().AddEventHandlerWithResyncPeriod(cache.ResourceEventHandlerFuncs{ - AddFunc: func(obj interface{}) { - controller.nsnpEnqueue(obj) - }, + AddFunc: controller.nsnpEnqueue, UpdateFunc: func(oldObj interface{}, newObj interface{}) { controller.nsnpEnqueue(newObj) }, - DeleteFunc: func(obj interface{}) { - controller.nsnpEnqueue(obj) - }, + DeleteFunc: controller.nsnpEnqueue, }, defaultSleepDuration) return controller diff --git a/pkg/utils/clusterclient/clusterclient.go b/pkg/utils/clusterclient/clusterclient.go index b36a492ac..7aa860343 100644 --- a/pkg/utils/clusterclient/clusterclient.go +++ b/pkg/utils/clusterclient/clusterclient.go @@ -77,9 +77,7 @@ func NewClusterClient(clusterInformer clusterinformer.ClusterInformer) ClusterCl c.addCluster(newObj) } }, - DeleteFunc: func(obj interface{}) { - c.removeCluster(obj) - }, + DeleteFunc: c.removeCluster, }) return c }