Start informer

Signed-off-by: Pierangelo Di Pilato <[email protected]>

pkg/reconciler/broker/controller.go

@@ -18,6 +18,9 @@ package broker
 
 import (
 	"context"
+	"os"
+
+	"knative.dev/pkg/injection"
 
 	"knative.dev/eventing/pkg/auth"
 
@@ -60,6 +63,12 @@ const (
 
 var Tracer tracing.Tracer
 
+func init() {
+	if isTest := os.Getenv("IS_TEST"); isTest != "true" {
+		injection.Default.RegisterInformer()
+	}
+}
+
 // NewController initializes the controller and is called by the generated code
 // Registers event handlers to enqueue events
 func NewController(
@@ -69,7 +78,12 @@ func NewController(
 	logger := logging.FromContext(ctx)
 	brokerInformer := brokerinformer.Get(ctx)
 	subscriptionInformer := subscriptioninformer.Get(ctx)
-	endpointsInformer := namespacedinformerfactory.Get(ctx).Core().V1().Endpoints()
+	endpointsInformer := namespacedinformerfactory.Get(ctx).Core().V1().Endpoints().Informer()
+
+	if err := controller.StartInformers(ctx.Done(), endpointsInformer); err != nil {
+		logger.Fatalw("Failed to start namespaced endpoints informer", zap.Error(err))
+	}
+
 	configmapInformer := configmapinformer.Get(ctx)
 	secretInformer := secretinformer.Get(ctx)
 	eventPolicyInformer := eventpolicyinformer.Get(ctx)