finish federatedinformermanager tests

kubewharf · Jul 12, 2023 · 666afef · 666afef
1 parent cf4a9a7
commit 666afef
Show file tree

Hide file tree

Showing 3 changed files with 1,140 additions and 194 deletions.
diff --git a/pkg/util/informermanager/federatedinformermanager.go b/pkg/util/informermanager/federatedinformermanager.go
@@ -31,7 +31,7 @@ type federatedInformerManager struct {
 	clusterInformer fedcorev1a1informers.FederatedClusterInformer
 
 	eventHandlerGenerators []*EventHandlerGenerator
-	clusterEventHandler    []*ClusterEventHandler
+	clusterEventHandlers    []*ClusterEventHandler
 
 	clients                     map[string]dynamic.Interface
 	connectionMap               map[string][]byte
@@ -53,7 +53,7 @@ func NewFederatedInformerManager(
 		ftcInformer:                 ftcInformer,
 		clusterInformer:             clusterInformer,
 		eventHandlerGenerators:      []*EventHandlerGenerator{},
-		clusterEventHandler:         []*ClusterEventHandler{},
+		clusterEventHandlers:         []*ClusterEventHandler{},
 		clients:                     map[string]dynamic.Interface{},
 		connectionMap:               map[string][]byte{},
 		informerManagers:            map[string]InformerManager{},
@@ -73,6 +73,8 @@ func NewFederatedInformerManager(
 		},
 	})
 
+	ftcInformer.Informer()
+
 	return manager
 }
 
@@ -210,7 +212,7 @@ func (m *federatedInformerManager) AddClusterEventHandler(handler *ClusterEventH
 		return fmt.Errorf("FederatedInformerManager is already started.")
 	}
 
-	m.clusterEventHandler = append(m.clusterEventHandler, handler)
+	m.clusterEventHandlers = append(m.clusterEventHandlers, handler)
 	return nil
 
 }
@@ -280,7 +282,7 @@ func (m *federatedInformerManager) Start(ctx context.Context) {
 		return
 	}
 
-	for _, handler := range m.clusterEventHandler {
+	for _, handler := range m.clusterEventHandlers {
 		predicate := handler.Predicate
 		callback := handler.Callback