From b80920009c36972f9aadf2e91c44a6a98d9aabdd Mon Sep 17 00:00:00 2001 From: AS! <857949825@qq.com> Date: Wed, 26 Apr 2023 11:36:27 +0800 Subject: [PATCH] Uniform code format (#5650) Signed-off-by: sologgfun <857949825@qq.com> --- pkg/controller/job/job_controller.go | 4 +--- .../network/nsnetworkpolicy/nsnetworkpolicy_controller.go | 8 ++------ pkg/utils/clusterclient/clusterclient.go | 4 +--- 3 files changed, 4 insertions(+), 12 deletions(-) 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 }