Add promote filter function to Broker and Trigger reconciler (#1616) (#…

…1621) When a reconciler gets promoted to be the leader, every object gets re-queued even if it shouldn't be. Signed-off-by: Pierangelo Di Pilato <[email protected]>
knative-extensions · Dec 16, 2021 · c79ae37 · c79ae37
1 parent 987feee
commit c79ae37
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/control-plane/pkg/reconciler/broker/controller.go b/control-plane/pkg/reconciler/broker/controller.go
@@ -94,7 +94,9 @@ func NewController(ctx context.Context, watcher configmap.Watcher, configs *Conf
 		reconciler.SetBootstrapServers(configs.BootstrapServers)
 	}
 
-	impl := brokerreconciler.NewImpl(ctx, reconciler, kafka.BrokerClass)
+	impl := brokerreconciler.NewImpl(ctx, reconciler, kafka.BrokerClass, func(impl *controller.Impl) controller.Options {
+		return controller.Options{PromoteFilterFunc: kafka.BrokerClassFilter()}
+	})
 
 	reconciler.Resolver = resolver.NewURIResolverFromTracker(ctx, impl.Tracker)
 

diff --git a/control-plane/pkg/reconciler/trigger/controller.go b/control-plane/pkg/reconciler/trigger/controller.go
@@ -81,6 +81,7 @@ func NewController(ctx context.Context, _ configmap.Watcher, configs *config.Env
 			FinalizerName:     FinalizerName,
 			AgentName:         ControllerAgentName,
 			SkipStatusUpdates: false,
+			PromoteFilterFunc: filterTriggers(reconciler.BrokerLister),
 		}
 	})