[YUNIKORN-2621] Start the CSINode informer (#838)

Closes: #838 Signed-off-by: Peter Bacsko <[email protected]>
apache · May 13, 2024 · e95ba07 · e95ba07
1 parent abd7011
commit e95ba07
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/pkg/client/apifactory.go b/pkg/client/apifactory.go
@@ -125,6 +125,7 @@ func NewAPIFactory(scheduler api.SchedulerAPI, informerFactory informers.SharedI
 			PVCInformer:           pvcInformer,
 			NamespaceInformer:     namespaceInformer,
 			StorageInformer:       storageInformer,
+			CSINodeInformer:       csiNodeInformer,
 			PriorityClassInformer: priorityClassInformer,
 			VolumeBinder:          volumeBinder,
 		},

diff --git a/pkg/client/clients.go b/pkg/client/clients.go
@@ -55,6 +55,7 @@ type Clients struct {
 	PVInformer            coreInformerV1.PersistentVolumeInformer
 	PVCInformer           coreInformerV1.PersistentVolumeClaimInformer
 	StorageInformer       storageInformerV1.StorageClassInformer
+	CSINodeInformer       storageInformerV1.CSINodeInformer
 	NamespaceInformer     coreInformerV1.NamespaceInformer
 	PriorityClassInformer schedulingInformerV1.PriorityClassInformer
 
@@ -75,6 +76,7 @@ func (c *Clients) WaitForSync() {
 			c.PVCInformer.Informer().HasSynced() &&
 			c.PVInformer.Informer().HasSynced() &&
 			c.StorageInformer.Informer().HasSynced() &&
+			c.CSINodeInformer.Informer().HasSynced() &&
 			c.ConfigMapInformer.Informer().HasSynced() &&
 			c.NamespaceInformer.Informer().HasSynced() &&
 			c.PriorityClassInformer.Informer().HasSynced() {
@@ -95,6 +97,7 @@ func (c *Clients) Run(stopCh <-chan struct{}) {
 	go c.PVInformer.Informer().Run(stopCh)
 	go c.PVCInformer.Informer().Run(stopCh)
 	go c.StorageInformer.Informer().Run(stopCh)
+	go c.CSINodeInformer.Informer().Run(stopCh)
 	go c.ConfigMapInformer.Informer().Run(stopCh)
 	go c.NamespaceInformer.Informer().Run(stopCh)
 	go c.PriorityClassInformer.Informer().Run(stopCh)