Merge pull request #369 from rabbitmq/sync-period

Support setting manager sync period using operator envVar

Author: ChunyiLyu

controllers/common.go

@@ -39,6 +39,7 @@ const (
 	KubernetesInternalDomainEnvVar = "MESSAGING_DOMAIN_NAME"
 	OperatorNamespaceEnvVar        = "OPERATOR_NAMESPACE"
 	EnableWebhooksEnvVar           = "ENABLE_WEBHOOKS"
+	ControllerSyncPeriodEnvVar     = "SYNC_PERIOD"
 )
 
 type TopologyController interface {

main.go

@@ -16,6 +16,7 @@ import (
 	"os"
 	"regexp"
 	"strings"
+	"time"
 
 	"k8s.io/apimachinery/pkg/runtime"
 	clientgoscheme "k8s.io/client-go/kubernetes/scheme"
@@ -87,13 +88,25 @@ func main() {
 
 	clusterDomain := sanitizeClusterDomainInput(os.Getenv(controllers.KubernetesInternalDomainEnvVar))
 
-	mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
+	managerOpts := ctrl.Options{
 		Scheme:                  scheme,
 		MetricsBindAddress:      metricsAddr,
 		LeaderElection:          true,
 		LeaderElectionNamespace: operatorNamespace,
 		LeaderElectionID:        "messaging-topology-operator-leader-election",
-	})
+	}
+
+	if syncPeriod := os.Getenv(controllers.ControllerSyncPeriodEnvVar); syncPeriod != "" {
+		syncPeriodDuration, err := time.ParseDuration(syncPeriod)
+		if err != nil {
+			log.Error(err, "unable to parse provided sync period", "sync period", syncPeriod)
+			os.Exit(1)
+		}
+		managerOpts.SyncPeriod = &syncPeriodDuration
+		log.Info(fmt.Sprintf("sync period set; all resources will be reconciled every: %s", syncPeriodDuration))
+	}
+
+	mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), managerOpts)
 	if err != nil {
 		log.Error(err, "unable to start manager")
 		os.Exit(1)