koord-scheduler: fix PodGroupController panic when init (#659)

Signed-off-by: Joseph <[email protected]>
koordinator-sh · Sep 23, 2022 · 5aca824 · 5aca824
1 parent 92b281a
commit 5aca824
Showing 1 changed file with 8 additions and 9 deletions.
diff --git a/pkg/scheduler/plugins/coscheduling/controller/podgroup.go b/pkg/scheduler/plugins/coscheduling/controller/podgroup.go
@@ -69,9 +69,14 @@ func NewPodGroupController(client kubernetes.Interface,
 	pgClient schedclientset.Interface, podGroupManager *core.PodGroupManager, recorder events.EventRecorder) *PodGroupController {
 
 	ctrl := &PodGroupController{
-		eventRecorder: recorder,
-		pgQueue:       workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "PodGroup"),
-		pgManager:     podGroupManager,
+		eventRecorder:   recorder,
+		pgManager:       podGroupManager,
+		pgClient:        pgClient,
+		pgLister:        pgInformer.Lister(),
+		podLister:       podInformer.Lister(),
+		pgListerSynced:  pgInformer.Informer().HasSynced,
+		podListerSynced: podInformer.Informer().HasSynced,
+		pgQueue:         workqueue.NewNamedRateLimitingQueue(workqueue.DefaultControllerRateLimiter(), "PodGroup"),
 	}
 
 	pgInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
@@ -83,12 +88,6 @@ func NewPodGroupController(client kubernetes.Interface,
 		AddFunc:    ctrl.podAdded,
 		UpdateFunc: ctrl.podUpdated,
 	})
-
-	ctrl.pgLister = pgInformer.Lister()
-	ctrl.podLister = podInformer.Lister()
-	ctrl.pgListerSynced = pgInformer.Informer().HasSynced
-	ctrl.podListerSynced = podInformer.Informer().HasSynced
-	ctrl.pgClient = pgClient
 	return ctrl
 }