🐛 Use leader config for election events

Fixes: #1798 Signed-off-by: Justin Kulikauskas <jkulikau@redhat.com>
kubernetes-sigs · Feb 14, 2022 · 84bd552 · 84bd552
1 parent 273e608
commit 84bd552
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/pkg/manager/manager.go b/pkg/manager/manager.go
@@ -339,7 +339,13 @@ func New(config *rest.Config, options Options) (Manager, error) {
 	if leaderConfig == nil {
 		leaderConfig = rest.CopyConfig(config)
 	}
-	resourceLock, err := options.newResourceLock(leaderConfig, recorderProvider, leaderelection.Options{
+
+	leaderRecorderProvider, err := options.newRecorderProvider(leaderConfig, cluster.GetScheme(), options.Logger.WithName("events"), options.makeBroadcaster)
+	if err != nil {
+		return nil, err
+	}
+
+	resourceLock, err := options.newResourceLock(leaderConfig, leaderRecorderProvider, leaderelection.Options{
 		LeaderElection:             options.LeaderElection,
 		LeaderElectionResourceLock: options.LeaderElectionResourceLock,
 		LeaderElectionID:           options.LeaderElectionID,