options

Author: MatousJobanek

main.go

@@ -93,6 +93,15 @@ func main() {
 
 	var mgr ctrl.Manager
 	var err error
+	options := ctrl.Options{
+		Scheme:                 scheme,
+		MetricsBindAddress:     metricsAddr,
+		Port:                   9443,
+		HealthProbeBindAddress: probeAddr,
+		LeaderElection:         enableLeaderElection,
+		LeaderElectionID:       "68a0532d.my.domain",
+		LeaderElectionConfig:   restConfig,
+	}
 	if apisKcpGroupPresent(restConfig) {
 		setupLog.Info("Looking up virtual workspace URL")
 		cfg, err := restConfigForAPIExport(ctx, restConfig, apiExportName)
@@ -102,29 +111,15 @@ func main() {
 
 		setupLog.Info("Using virtual workspace URL", "url", cfg.Host)
 
-		mgr, err = kcp.NewClusterAwareManager(cfg, ctrl.Options{
-			Scheme:                 scheme,
-			MetricsBindAddress:     metricsAddr,
-			Port:                   9443,
-			HealthProbeBindAddress: probeAddr,
-			LeaderElection:         enableLeaderElection,
-			LeaderElectionID:       "68a0532d.my.domain",
-			LeaderElectionConfig:   restConfig,
-		})
+		options.LeaderElectionConfig = restConfig
+		mgr, err = kcp.NewClusterAwareManager(cfg, options)
 		if err != nil {
 			setupLog.Error(err, "unable to start cluster aware manager")
 			os.Exit(1)
 		}
 	} else {
 		setupLog.Info("The apis.kcp.dev group is not present - creating standard manager")
-		mgr, err = ctrl.NewManager(restConfig, ctrl.Options{
-			Scheme:                 scheme,
-			MetricsBindAddress:     metricsAddr,
-			Port:                   9443,
-			HealthProbeBindAddress: probeAddr,
-			LeaderElection:         enableLeaderElection,
-			LeaderElectionID:       "68a0532d.my.domain",
-		})
+		mgr, err = ctrl.NewManager(restConfig, options)
 		if err != nil {
 			setupLog.Error(err, "unable to start manager")
 			os.Exit(1)