GT-474 Switch to Lease API

CHANGELOG.md

@@ -6,6 +6,7 @@
 - (Feature) Optional Assertions
 - (Feature) Deprecate Actions
 - (Bugfix) Debug mode
+- (Improvement) Switch to Lease API
 
 ## [1.2.32](https://github.com/arangodb/kube-arangodb/tree/1.2.32) (2023-08-07)
 - (Feature) Backup lifetime - remove Backup once its lifetime has been reached

chart/kube-arangodb/templates/deployment-operator/role.yaml

@@ -35,6 +35,9 @@ rules:
     - apiGroups: ["policy"]
       resources: ["poddisruptionbudgets"]
       verbs: ["*"]
+    - apiGroups: ["coordination.k8s.io"]
+      resources: ["leases"]
+      verbs: ["*"]
     - apiGroups: ["backup.arangodb.com"]
       resources: ["arangobackuppolicies", "arangobackups"]
       verbs: ["get", "list", "watch"]

pkg/operator/operator_leader.go

@@ -57,22 +57,22 @@ func (o *Operator) runLeaderElection(lockName, label string, onStart func(stop <
 			o.Dependencies.EventRecorder.Event(eventTarget, core.EventTypeNormal, reason, message)
 		}
 	}
-	rl, err := resourcelock.New("endpoints",
-		namespace,
-		lockName,
-		kubecli.CoreV1(),
-		kubecli.CoordinationV1(),
-		resourcelock.ResourceLockConfig{
+
+	lock := &resourcelock.LeaseLock{
+		LeaseMeta: meta.ObjectMeta{
+			Name:      lockName,
+			Namespace: namespace,
+		},
+		Client: kubecli.CoordinationV1(),
+		LockConfig: resourcelock.ResourceLockConfig{
 			Identity:      o.Config.ID,
 			EventRecorder: o.Dependencies.EventRecorder,
-		})
-	if err != nil {
-		log.Err(err).Fatal("Failed to create resource lock")
+		},
 	}
 
 	ctx := context.Background()
 	leaderelection.RunOrDie(ctx, leaderelection.LeaderElectionConfig{
-		Lock:          rl,
+		Lock:          lock,
 		LeaseDuration: 15 * time.Second,
 		RenewDeadline: 10 * time.Second,
 		RetryPeriod:   2 * time.Second,