@@ -54,7 +54,7 @@ func RunOperator(ctx context.Context, cc *controllercmd.ControllerContext) error
54
54
if err != nil {
55
55
return err
56
56
}
57
-
57
+ clusterInformers := v1helpers . NewKubeInformersForNamespaces ( kubeClient , "" )
58
58
configInformers := configinformers .NewSharedInformerFactory (configClient , 10 * time .Minute )
59
59
kubeInformersForNamespaces := v1helpers .NewKubeInformersForNamespaces (kubeClient ,
60
60
"" ,
@@ -199,7 +199,7 @@ func RunOperator(ctx context.Context, cc *controllercmd.ControllerContext) error
199
199
}
200
200
versionRecorder .SetVersion ("raw-internal" , status .VersionForOperatorFromEnv ())
201
201
202
- staticPodControllers , err := staticpod .NewBuilder (operatorClient , kubeClient , kubeInformersForNamespaces , configInformers , cc .Clock ).
202
+ staticPodControllers , err := staticpod .NewBuilder (operatorClient , kubeClient , kubeInformersForNamespaces , clusterInformers . InformersFor ( "" ), configInformers , cc .Clock ).
203
203
WithEvents (cc .EventRecorder ).
204
204
WithInstaller ([]string {"cluster-kube-controller-manager-operator" , "installer" }).
205
205
WithPruning ([]string {"cluster-kube-controller-manager-operator" , "prune" }, "kube-controller-manager-pod" ).
@@ -287,6 +287,7 @@ func RunOperator(ctx context.Context, cc *controllercmd.ControllerContext) error
287
287
})
288
288
289
289
configInformers .Start (ctx .Done ())
290
+ clusterInformers .Start (ctx .Done ())
290
291
kubeInformersForNamespaces .Start (ctx .Done ())
291
292
dynamicInformers .Start (ctx .Done ())
292
293
0 commit comments