Updated Listen logic of informer manager to start snapshot sync

Author: kolluria

pkg/kubernetes/informers.go

@@ -18,6 +18,7 @@ package kubernetes
 
 import (
 	"context"
+	"fmt"
 	"sync"
 	"time"
 
@@ -316,5 +317,16 @@ func (im *InformerManager) Listen() (stopCh <-chan struct{}) {
 		}
 
 	}
+
+	go im.snapshotInformerFactory.Start(im.stopCh)
+	cacheSync := im.snapshotInformerFactory.WaitForCacheSync(im.stopCh)
+	// TODO: remove
+	fmt.Print(cacheSync)
+	for _, isSynced := range cacheSync {
+		if !isSynced {
+			return
+		}
+	}
+
 	return im.stopCh
 }

pkg/kubernetes/types.go

@@ -56,7 +56,7 @@ type InformerManager struct {
 	snapshotInformerFactory externalversions.SharedInformerFactory
 
 	// main signal
-	stopCh (<-chan struct{})
+	stopCh <-chan struct{}
 
 	// node informer
 	nodeInformer cache.SharedInformer