This is an automated email from the ASF dual-hosted git repository.
pbacsko pushed a commit to branch branch-1.5
in repository https://gitbox.apache.org/repos/asf/yunikorn-k8shim.git
The following commit(s) were added to refs/heads/branch-1.5 by this push:
new 66afd62d [YUNIKORN-2621] Start the CSINode informer (#838)
66afd62d is described below
commit 66afd62d98f72ff4da193c8fea093ef08f683b7b
Author: Jacob Salway <[email protected]>
AuthorDate: Mon May 13 12:11:59 2024 +0200
[YUNIKORN-2621] Start the CSINode informer (#838)
Closes: #838
Signed-off-by: Peter Bacsko <[email protected]>
(cherry picked from commit e95ba07d1e568701de2cec30a95f8cc0d8644e1c)
---
pkg/client/apifactory.go | 1 +
pkg/client/clients.go | 3 +++
2 files changed, 4 insertions(+)
diff --git a/pkg/client/apifactory.go b/pkg/client/apifactory.go
index 4efdefa3..62bdcb20 100644
--- 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
index f53e65e7..479b6e2b 100644
--- 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)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
