feat(chart): add leaderElection.leaseDuration and leaderElection.renewDeadline

fix: #606

Author: runkecheng

charts/mysql-operator/templates/deployment.yaml

@@ -70,6 +70,8 @@ spec:
         - --health-probe-bind-address=:8081
         - --metrics-bind-address=127.0.0.1:8080
         - --leader-elect
+        - {{ printf "--lease-duration=%s" .Values.leaderElection.leaseDuration }} 
+        - {{ printf "--renew-deadline=%s" .Values.leaderElection.renewDeadline }}
       {{- if not .Values.imagePrefix }}
         image: "{{ .Values.manager.image }}:{{ .Values.manager.tag }}"
       {{- else }}

charts/mysql-operator/values.yaml

@@ -51,6 +51,8 @@ rbacProxy:
 
 leaderElection:
   create: true
+  leaseDuration: 15s
+  renewDeadline: 10s
 
 serviceMonitor:
   enabled: true

cmd/manager/main.go

@@ -20,6 +20,7 @@ import (
 	"flag"
 	"os"
 	"sync"
+	"time"
 
 	// Import all Kubernetes client auth plugins (e.g. Azure, GCP, OIDC, etc.)
 	// to ensure that exec-entrypoint and run can make use of them.
@@ -55,11 +56,15 @@ func main() {
 	var metricsAddr string
 	var enableLeaderElection bool
 	var probeAddr string
+	var leaseDuration time.Duration
+	var renewDeadline time.Duration
 	flag.StringVar(&metricsAddr, "metrics-bind-address", ":8080", "The address the metric endpoint binds to.")
 	flag.StringVar(&probeAddr, "health-probe-bind-address", ":8081", "The address the probe endpoint binds to.")
 	flag.BoolVar(&enableLeaderElection, "leader-elect", false,
 		"Enable leader election for controller manager. "+
 			"Enabling this will ensure there is only one active controller manager.")
+	flag.DurationVar(&leaseDuration, "lease-duration", time.Second*15, "The duration that non-leader candidates will wait to force acquire leadership, this is measured against time of last observed ack.")
+	flag.DurationVar(&renewDeadline, "renew-deadline", time.Second*10, "The duration that the acting controlplane will retry refreshing leadership before giving up.")
 	opts := zap.Options{
 		Development: true,
 	}
@@ -75,6 +80,8 @@ func main() {
 		HealthProbeBindAddress: probeAddr,
 		LeaderElection:         enableLeaderElection,
 		LeaderElectionID:       "2175edb9.radondb.com",
+		LeaseDuration: 			&leaseDuration,
+		RenewDeadline: 			&renewDeadline,
 	})
 	if err != nil {
 		setupLog.Error(err, "unable to start manager")