wip

Signed-off-by: Attila Mészáros <a_meszaros@apple.com>

sample-operators/controller-namespace-deletion/src/main/java/io/javaoperatorsdk/operator/sample/ControllerNamespaceDeletionCustomResource.java

@@ -1,7 +1,12 @@
 package io.javaoperatorsdk.operator.sample;
 
 import io.fabric8.kubernetes.client.CustomResource;
+import io.fabric8.kubernetes.model.annotation.Group;
+import io.fabric8.kubernetes.model.annotation.Version;
 
-public class ControllerNamespaceDeletionCustomResource extends CustomResource<ControllerNamespaceDeletionSpec, ControllerNamespaceDeletionStatus> {
+@Group("namespacedeletion.io")
+@Version("v1")
+public class ControllerNamespaceDeletionCustomResource
+    extends CustomResource<ControllerNamespaceDeletionSpec, ControllerNamespaceDeletionStatus> {
 
 }

sample-operators/controller-namespace-deletion/src/main/java/io/javaoperatorsdk/operator/sample/ControllerNamespaceDeletionOperator.java

@@ -4,11 +4,11 @@
 import org.slf4j.LoggerFactory;
 
 import io.javaoperatorsdk.operator.Operator;
-import io.javaoperatorsdk.operator.api.config.LeaderElectionConfiguration;
 
 public class ControllerNamespaceDeletionOperator {
 
-  private static final Logger log = LoggerFactory.getLogger(ControllerNamespaceDeletionOperator.class);
+  private static final Logger log =
+      LoggerFactory.getLogger(ControllerNamespaceDeletionOperator.class);
 
   public static void main(String[] args) {
     Operator operator = new Operator();

sample-operators/controller-namespace-deletion/src/main/java/io/javaoperatorsdk/operator/sample/ControllerNamespaceDeletionReconciler.java

@@ -1,33 +1,58 @@
 package io.javaoperatorsdk.operator.sample;
 
+import java.time.Duration;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
 import io.javaoperatorsdk.operator.api.reconciler.Cleaner;
 import io.javaoperatorsdk.operator.api.reconciler.Context;
 import io.javaoperatorsdk.operator.api.reconciler.DeleteControl;
 import io.javaoperatorsdk.operator.api.reconciler.Reconciler;
 import io.javaoperatorsdk.operator.api.reconciler.UpdateControl;
 
-import java.time.Duration;
-
-public class ControllerNamespaceDeletionReconciler implements Reconciler<ControllerNamespaceDeletionCustomResource>,
-        Cleaner<ControllerNamespaceDeletionCustomResource> {
-
-    @Override
-    public UpdateControl<ControllerNamespaceDeletionCustomResource> reconcile(ControllerNamespaceDeletionCustomResource resource,
-                                                                              Context<ControllerNamespaceDeletionCustomResource> context) {
-
-
-        return null;
-    }
-
-
-    @Override
-    public DeleteControl cleanup(ControllerNamespaceDeletionCustomResource resource,
-                                 Context<ControllerNamespaceDeletionCustomResource> context) {
-        try {
-            Thread.sleep(Duration.ofSeconds(10).toMillis());
-            return DeleteControl.defaultDelete();
-        } catch (InterruptedException e) {
-            throw new RuntimeException(e);
-        }
+public class ControllerNamespaceDeletionReconciler
+    implements Reconciler<ControllerNamespaceDeletionCustomResource>,
+    Cleaner<ControllerNamespaceDeletionCustomResource> {
+
+  private static final Logger log =
+      LoggerFactory.getLogger(ControllerNamespaceDeletionReconciler.class);
+
+  public static final Duration CLEANUP_DELAY = Duration.ofSeconds(10);
+
+  @Override
+  public UpdateControl<ControllerNamespaceDeletionCustomResource> reconcile(
+      ControllerNamespaceDeletionCustomResource resource,
+      Context<ControllerNamespaceDeletionCustomResource> context) {
+    log.info("Reconciling: {} in namespace: {}", resource.getMetadata().getName(),
+        resource.getMetadata().getNamespace());
+
+    var response = createResponseResource(resource);
+    response.getStatus().setValue(resource.getSpec().getValue());
+
+    return UpdateControl.patchStatus(response);
+  }
+
+  private ControllerNamespaceDeletionCustomResource createResponseResource(
+      ControllerNamespaceDeletionCustomResource resource) {
+    var res = new ControllerNamespaceDeletionCustomResource();
+    res.setMetadata(new ObjectMetaBuilder()
+        .withName(resource.getMetadata().getName())
+        .withNamespace(resource.getMetadata().getNamespace())
+        .build());
+    res.setStatus(new ControllerNamespaceDeletionStatus());
+    return res;
+  }
+
+  @Override
+  public DeleteControl cleanup(ControllerNamespaceDeletionCustomResource resource,
+      Context<ControllerNamespaceDeletionCustomResource> context) {
+    try {
+      Thread.sleep(CLEANUP_DELAY.toMillis());
+      return DeleteControl.defaultDelete();
+    } catch (InterruptedException e) {
+      throw new RuntimeException(e);
     }
+  }
 }

sample-operators/controller-namespace-deletion/src/main/java/io/javaoperatorsdk/operator/sample/ControllerNamespaceDeletionSpec.java

@@ -1,6 +1,15 @@
 package io.javaoperatorsdk.operator.sample;
 
-import io.fabric8.kubernetes.client.CustomResource;
 
 public class ControllerNamespaceDeletionSpec {
+
+  private String value;
+
+  public String getValue() {
+    return value;
+  }
+
+  public void setValue(String value) {
+    this.value = value;
+  }
 }

sample-operators/controller-namespace-deletion/src/main/java/io/javaoperatorsdk/operator/sample/ControllerNamespaceDeletionStatus.java

@@ -1,6 +1,15 @@
 package io.javaoperatorsdk.operator.sample;
 
-import io.fabric8.kubernetes.client.CustomResource;
 
 public class ControllerNamespaceDeletionStatus {
+
+  private String value;
+
+  public String getValue() {
+    return value;
+  }
+
+  public void setValue(String value) {
+    this.value = value;
+  }
 }