Add Leader Election Lease Options

CHANGELOG.md

@@ -34,9 +34,11 @@ To learn more about our roadmap, we recommend reading [this document](ROADMAP.md
 
 ## Unreleased
 
+- **General:** Add settings for configuring leader election ([#2836]https://github.com/kedacore/keda/issues/2836))
+
 ### New
 
-- **General:** Add support to customize HPA name ([3057](https://github.com/kedacore/keda/issues/3057))
+- **General:** Add support to customize HPA name ([#3057](https://github.com/kedacore/keda/issues/3057))
 - **General:** Basic setup for migrating e2e tests to Go. ([#2737](https://github.com/kedacore/keda/issues/2737))
 - **General:** Introduce new AWS DynamoDB Streams Scaler ([#3124](https://github.com/kedacore/keda/issues/3124))
 - **General:** Make propagation policy for ScaledJob rollout configurable ([#2910](https://github.com/kedacore/keda/issues/2910))

main.go

@@ -84,13 +84,34 @@ func main() {
 		os.Exit(1)
 	}
 
+	leaseDuration, err := kedautil.ResolveOsEnvDuration("KEDA_LEADER_ELECTION_LEASE_DURATION", time.Duration(15)*time.Second)
+	if err != nil {
+		setupLog.Error(err, "Invalid KEDA_LEADER_ELECTION_LEASE_DURATION")
+		os.Exit(1)
+	}
+
+	renewDeadline, err := kedautil.ResolveOsEnvDuration("KEDA_LEADER_ELECTION_RENEW_DEADLINE", time.Duration(10)*time.Second)
+	if err != nil {
+		setupLog.Error(err, "Invalid KEDA_LEADER_ELECTION_RENEW_DEADLINE")
+		os.Exit(1)
+	}
+
+	retryPeriod, err := kedautil.ResolveOsEnvDuration("KEDA_LEADER_ELECTION_RETRY_PERIOD", time.Duration(2)*time.Second)
+	if err != nil {
+		setupLog.Error(err, "Invalid KEDA_LEADER_ELECTION_RETRY_PERIOD")
+		os.Exit(1)
+	}
+
 	mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
 		Scheme:                 scheme,
 		MetricsBindAddress:     metricsAddr,
 		Port:                   9443,
 		HealthProbeBindAddress: probeAddr,
 		LeaderElection:         enableLeaderElection,
 		LeaderElectionID:       "operator.keda.sh",
+		LeaseDuration:          &leaseDuration,
+		RenewDeadline:          &renewDeadline,
+		RetryPeriod:            &retryPeriod,
 		Namespace:              namespace,
 	})
 	if err != nil {

pkg/util/env_resolver.go

@@ -3,6 +3,7 @@ package util
 import (
 	"os"
 	"strconv"
+	"time"
 )
 
 func ResolveOsEnvInt(envName string, defaultValue int) (int, error) {
@@ -14,3 +15,13 @@ func ResolveOsEnvInt(envName string, defaultValue int) (int, error) {
 
 	return defaultValue, nil
 }
+
+func ResolveOsEnvDuration(envName string, defaultValue time.Duration) (time.Duration, error) {
+	valueStr, found := os.LookupEnv(envName)
+
+	if found && valueStr != "" {
+		return time.ParseDuration(valueStr)
+	}
+
+	return defaultValue, nil
+}