feat: GenericKubernetesResource based DependentResource

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

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/dependent/kubernetes/GenericKubernetesDependentResource.java

@@ -0,0 +1,21 @@
+package io.javaoperatorsdk.operator.processing.dependent.kubernetes;
+
+import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
+import io.fabric8.kubernetes.api.model.HasMetadata;
+
+public class GenericKubernetesDependentResource<P extends HasMetadata>
+    extends KubernetesDependentResource<GenericKubernetesResource, P> {
+
+  private final String apiVersion;
+  private final String kind;
+
+
+  public GenericKubernetesDependentResource(String apiVersion, String kind) {
+    super(GenericKubernetesResource.class);
+    this.apiVersion = apiVersion;
+    this.kind = kind;
+  }
+
+
+
+}

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

@@ -0,0 +1,40 @@
+package io.javaoperatorsdk.operator;
+
+import org.junit.jupiter.api.Test;
+
+import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
+import io.fabric8.kubernetes.client.KubernetesClientBuilder;
+import io.fabric8.kubernetes.client.informers.ResourceEventHandler;
+
+public class GenericKubernetesDependentStandaloneIT {
+
+
+  @Test
+  void testInformer() {
+    GenericKubernetesResource res = new GenericKubernetesResource();
+    res.setApiVersion("v1");
+    res.setKind("ConfigMap");
+
+    try (var client = new KubernetesClientBuilder().build()) {
+      client.resource(res).inform().addEventHandler(new ResourceEventHandler<>() {
+        @Override
+        public void onAdd(GenericKubernetesResource genericKubernetesResource) {
+          System.out.println(genericKubernetesResource);
+        }
+
+        @Override
+        public void onUpdate(GenericKubernetesResource genericKubernetesResource,
+            GenericKubernetesResource t1) {
+          System.out.println(genericKubernetesResource);
+        }
+
+        @Override
+        public void onDelete(GenericKubernetesResource genericKubernetesResource, boolean b) {
+          System.out.println(genericKubernetesResource);
+        }
+      });
+    }
+  }
+
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/generickubernetesdependentstandalone/ConfigMapGenericKubernetesDependent.java

@@ -0,0 +1,31 @@
+package io.javaoperatorsdk.operator.sample.generickubernetesdependentstandalone;
+
+import io.fabric8.kubernetes.api.model.GenericKubernetesResource;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.Deleter;
+import io.javaoperatorsdk.operator.processing.dependent.Creator;
+import io.javaoperatorsdk.operator.processing.dependent.Updater;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.GenericKubernetesDependentResource;
+
+public class ConfigMapGenericKubernetesDependent extends
+    GenericKubernetesDependentResource<GenericKubernetesDependentStandaloneCustomResource>
+    implements
+    Creator<GenericKubernetesResource, GenericKubernetesDependentStandaloneCustomResource>,
+    Updater<GenericKubernetesResource, GenericKubernetesDependentStandaloneCustomResource>,
+    Deleter<GenericKubernetesDependentStandaloneCustomResource> {
+
+
+  public ConfigMapGenericKubernetesDependent() {
+    super("v1", "ConfigMap");
+  }
+
+  @Override
+  protected GenericKubernetesResource desired(
+      GenericKubernetesDependentStandaloneCustomResource primary,
+      Context<GenericKubernetesDependentStandaloneCustomResource> context) {
+
+    return null;
+  }
+
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/generickubernetesdependentstandalone/GenericKubernetesDependentStandaloneCustomResource.java

@@ -0,0 +1,15 @@
+package io.javaoperatorsdk.operator.sample.generickubernetesdependentstandalone;
+
+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.ShortNames;
+import io.fabric8.kubernetes.model.annotation.Version;
+
+@Group("sample.javaoperatorsdk")
+@Version("v1")
+@ShortNames("gkd")
+public class GenericKubernetesDependentStandaloneCustomResource
+    extends CustomResource<Void, Void>
+    implements Namespaced {
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/generickubernetesdependentstandalone/GenericKubernetesDependentStandaloneReconciler.java

@@ -0,0 +1,28 @@
+package io.javaoperatorsdk.operator.sample.generickubernetesdependentstandalone;
+
+import io.javaoperatorsdk.operator.api.reconciler.*;
+import io.javaoperatorsdk.operator.sample.bulkdependent.CRUDConfigMapBulkDependentResource;
+import io.javaoperatorsdk.operator.sample.bulkdependent.ConfigMapDeleterBulkDependentResource;
+
+@ControllerConfiguration
+public class GenericKubernetesDependentStandaloneReconciler
+    implements Reconciler<GenericKubernetesDependentStandaloneCustomResource> {
+
+
+  private final ConfigMapDeleterBulkDependentResource dependent;
+
+  public GenericKubernetesDependentStandaloneReconciler() {
+    dependent = new CRUDConfigMapBulkDependentResource();
+  }
+
+  @Override
+  public UpdateControl<GenericKubernetesDependentStandaloneCustomResource> reconcile(
+      GenericKubernetesDependentStandaloneCustomResource resource,
+      Context<GenericKubernetesDependentStandaloneCustomResource> context) {
+
+
+
+    return UpdateControl.noUpdate();
+  }
+
+}