activation condition share event sounrce in DR

Signed-off-by: Attila Mészáros <[email protected]>

Author: csviri

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

@@ -0,0 +1,7 @@
+package io.javaoperatorsdk.operator;
+
+public class MultipleActivationSharingInformerIT {
+
+
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipleactivationsharinginformer/AbstractConfigMapDependentResource.java

@@ -0,0 +1,34 @@
+package io.javaoperatorsdk.operator.sample.multipleactivationsharinginformer;
+
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.CRUDNoGCKubernetesDependentResource;
+
+import java.util.Map;
+
+public abstract class AbstractConfigMapDependentResource
+    extends
+    CRUDNoGCKubernetesDependentResource<ConfigMap, MultipleActivationSharingInformerCustomResource> {
+
+  public static final String DATA_KEY = "data";
+
+  public AbstractConfigMapDependentResource() {
+    super(ConfigMap.class);
+  }
+
+  @Override
+  protected ConfigMap desired(MultipleActivationSharingInformerCustomResource primary,
+                              Context<MultipleActivationSharingInformerCustomResource> context) {
+    ConfigMap configMap = new ConfigMap();
+    configMap.setMetadata(new ObjectMetaBuilder()
+        .withName(primary.getMetadata().getName())
+        .withNamespace(primary.getMetadata().getNamespace())
+        .build());
+    configMap.setData(Map.of(DATA_KEY, value(primary)));
+    return configMap;
+  }
+
+  abstract String value(MultipleActivationSharingInformerCustomResource primary);
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipleactivationsharinginformer/ActivationCondition.java

@@ -0,0 +1,20 @@
+package io.javaoperatorsdk.operator.sample.multipleactivationsharinginformer;
+
+import io.fabric8.openshift.api.model.Route;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource;
+import io.javaoperatorsdk.operator.processing.dependent.workflow.Condition;
+
+public class ActivationCondition
+    implements Condition<Route, MultipleActivationSharingInformerCustomResource> {
+
+  public final static boolean MET = true;
+
+  @Override
+  public boolean isMet(
+      DependentResource<Route, MultipleActivationSharingInformerCustomResource> dependentResource,
+      MultipleActivationSharingInformerCustomResource primary,
+      Context<MultipleActivationSharingInformerCustomResource> context) {
+    return MET;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipleactivationsharinginformer/ConfigMapDependentResource1.java

@@ -0,0 +1,11 @@
+package io.javaoperatorsdk.operator.sample.multipleactivationsharinginformer;
+
+public class ConfigMapDependentResource1 extends AbstractConfigMapDependentResource {
+
+    public static final String VALUE_SUFFIX = "_1";
+
+    @Override
+    String value(MultipleActivationSharingInformerCustomResource primary) {
+        return primary.getSpec().getValue()+ VALUE_SUFFIX;
+    }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipleactivationsharinginformer/ConfigMapDependentResource2.java

@@ -0,0 +1,11 @@
+package io.javaoperatorsdk.operator.sample.multipleactivationsharinginformer;
+
+public class ConfigMapDependentResource2 extends AbstractConfigMapDependentResource {
+
+    public static final String VALUE_SUFFIX = "_2";
+
+    @Override
+    String value(MultipleActivationSharingInformerCustomResource primary) {
+        return primary.getSpec().getValue()+ VALUE_SUFFIX;
+    }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipleactivationsharinginformer/MultipleActivationSharingInformerCustomResource.java

@@ -0,0 +1,17 @@
+package io.javaoperatorsdk.operator.sample.multipleactivationsharinginformer;
+
+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("mwac")
+public class MultipleActivationSharingInformerCustomResource
+    extends CustomResource<MultipleActivationSharingInformerCustomResourceSpec, Void>
+    implements Namespaced {
+
+
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipleactivationsharinginformer/MultipleActivationSharingInformerCustomResourceSpec.java

@@ -0,0 +1,14 @@
+package io.javaoperatorsdk.operator.sample.multipleactivationsharinginformer;
+
+public class MultipleActivationSharingInformerCustomResourceSpec {
+
+  private String value;
+
+  public String getValue() {
+    return value;
+  }
+
+  public void setValue(String value) {
+    this.value = value;
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipleactivationsharinginformer/MultipleActivationSharingInformerReconciler.java

@@ -0,0 +1,45 @@
+package io.javaoperatorsdk.operator.sample.multipleactivationsharinginformer;
+
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.javaoperatorsdk.operator.api.config.informer.InformerConfiguration;
+import io.javaoperatorsdk.operator.api.reconciler.*;
+import io.javaoperatorsdk.operator.api.reconciler.dependent.Dependent;
+import io.javaoperatorsdk.operator.processing.event.source.EventSource;
+import io.javaoperatorsdk.operator.processing.event.source.informer.InformerEventSource;
+
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
+
+@ControllerConfiguration(dependents = {
+    @Dependent(type = ConfigMapDependentResource1.class,
+        activationCondition = ActivationCondition.class),
+    @Dependent(type = ConfigMapDependentResource2.class,
+        activationCondition = ActivationCondition.class),
+    @Dependent(type = SecretDependentResource.class)
+})
+public class MultipleActivationSharingInformerReconciler
+    implements Reconciler<MultipleActivationSharingInformerCustomResource> {
+
+  public static final String CONFIG_MAP_INFORMER_NAME = "ConfigMapInformer";
+  private final AtomicInteger numberOfReconciliationExecution = new AtomicInteger(0);
+
+  InformerEventSource<ConfigMap,MultipleActivationSharingInformerCustomResource> configMapES;
+  
+  
+  public MultipleActivationSharingInformerReconciler() {
+  }
+
+  @Override
+  public UpdateControl<MultipleActivationSharingInformerCustomResource> reconcile(
+      MultipleActivationSharingInformerCustomResource resource,
+      Context<MultipleActivationSharingInformerCustomResource> context) {
+
+    numberOfReconciliationExecution.incrementAndGet();
+
+    return UpdateControl.noUpdate();
+  }
+
+  public int getNumberOfReconciliationExecution() {
+    return numberOfReconciliationExecution.get();
+  }
+}

operator-framework/src/test/java/io/javaoperatorsdk/operator/sample/multipleactivationsharinginformer/SecretDependentResource.java

@@ -0,0 +1,32 @@
+package io.javaoperatorsdk.operator.sample.multipleactivationsharinginformer;
+
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+import io.fabric8.kubernetes.api.model.Secret;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.CRUDKubernetesDependentResource;
+import io.javaoperatorsdk.operator.sample.workflowmultipleactivation.WorkflowMultipleActivationCustomResource;
+
+import java.util.Base64;
+import java.util.Map;
+
+public class SecretDependentResource
+    extends CRUDKubernetesDependentResource<Secret, MultipleActivationSharingInformerCustomResource> {
+
+  public SecretDependentResource() {
+    super(Secret.class);
+  }
+
+  @Override
+  protected Secret desired(MultipleActivationSharingInformerCustomResource primary,
+      Context<MultipleActivationSharingInformerCustomResource> context) {
+    // basically does not matter since this should not be called
+    Secret secret = new Secret();
+    secret.setMetadata(new ObjectMetaBuilder()
+        .withName(primary.getMetadata().getName())
+        .withNamespace(primary.getMetadata().getNamespace())
+        .build());
+    secret.setData(Map.of("data",
+        Base64.getEncoder().encodeToString(primary.getSpec().getValue().getBytes())));
+    return secret;
+  }
+}