leader election IT

Author: csviri

operator-framework/src/test/java/io/javaoperatorsdk/operator/LeaderElectionIT.java

@@ -0,0 +1,12 @@
+package io.javaoperatorsdk.operator;
+
+import org.junit.jupiter.api.Test;
+
+class LeaderElectionIT {
+
+    @Test
+    void leaderElection() {
+
+    }
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/leaderelection/LeaderElectionTestCustomResource.java

@@ -0,0 +1,16 @@
+package io.javaoperatorsdk.operator.sample.leaderelection;
+
+import io.fabric8.kubernetes.api.model.Namespaced;
+import io.fabric8.kubernetes.client.CustomResource;
+import io.fabric8.kubernetes.model.annotation.Group;
+import io.fabric8.kubernetes.model.annotation.Kind;
+import io.fabric8.kubernetes.model.annotation.ShortNames;
+import io.fabric8.kubernetes.model.annotation.Version;
+
+@Group("sample.javaoperatorsdk")
+@Version("v1")
+@ShortNames("le")
+public class LeaderElectionTestCustomResource
+    extends CustomResource<Void, LeaderElectionTestCustomResourceStatus>
+    implements Namespaced {
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/leaderelection/LeaderElectionTestCustomResourceStatus.java

@@ -0,0 +1,21 @@
+package io.javaoperatorsdk.operator.sample.leaderelection;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class LeaderElectionTestCustomResourceStatus {
+
+    private List<String> reconciledBy;
+
+    public List<String> getReconciledBy() {
+        if (reconciledBy == null) {
+            reconciledBy = new ArrayList<>();
+        }
+        return reconciledBy;
+    }
+
+    public LeaderElectionTestCustomResourceStatus setReconciledBy(List<String> reconciledBy) {
+        this.reconciledBy = reconciledBy;
+        return this;
+    }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/leaderelection/LeaderElectionTestReconciler.java

@@ -0,0 +1,29 @@
+package io.javaoperatorsdk.operator.sample.leaderelection;
+
+import io.javaoperatorsdk.operator.api.reconciler.*;
+
+import java.time.Duration;
+
+@ControllerConfiguration()
+public class LeaderElectionTestReconciler
+    implements Reconciler<LeaderElectionTestCustomResource> {
+
+  private String reconcilerName;
+
+  public LeaderElectionTestReconciler(String reconcilerName) {
+    this.reconcilerName = reconcilerName;
+  }
+
+  @Override
+  public UpdateControl<LeaderElectionTestCustomResource> reconcile(
+          LeaderElectionTestCustomResource resource, Context<LeaderElectionTestCustomResource> context) {
+
+    if (resource.getStatus() == null) {
+      resource.setStatus(new LeaderElectionTestCustomResourceStatus());
+    }
+
+    resource.getStatus().getReconciledBy().add(reconcilerName);
+    return UpdateControl.patchStatus(resource).rescheduleAfter(Duration.ofSeconds(200));
+  }
+
+}