We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9429896 commit 060934fCopy full SHA for 060934f
pkg/reconciler/broker/controller.go
@@ -69,7 +69,12 @@ func NewController(
69
logger := logging.FromContext(ctx)
70
brokerInformer := brokerinformer.Get(ctx)
71
subscriptionInformer := subscriptioninformer.Get(ctx)
72
+
73
endpointsInformer := namespacedinformerfactory.Get(ctx).Core().V1().Endpoints()
74
+ if err := controller.StartInformers(ctx.Done(), endpointsInformer.Informer()); err != nil {
75
+ logger.Fatalw("Failed to start namespaced endpoints informer", zap.Error(err))
76
+ }
77
78
configmapInformer := configmapinformer.Get(ctx)
79
secretInformer := secretinformer.Get(ctx)
80
eventPolicyInformer := eventpolicyinformer.Get(ctx)
0 commit comments