bootstrapper-maven-plugin/pom.xml

@@ -5,7 +5,7 @@
   <parent>
     <artifactId>java-operator-sdk</artifactId>
     <groupId>io.javaoperatorsdk</groupId>
-    <version>4.6.1-SNAPSHOT</version>
+    <version>4.7.0-SNAPSHOT</version>
   </parent>
 
   <artifactId>bootstrapper</artifactId>

caffeine-bounded-cache-support/pom.xml

@@ -5,7 +5,7 @@
   <parent>
     <artifactId>java-operator-sdk</artifactId>
     <groupId>io.javaoperatorsdk</groupId>
-    <version>4.6.1-SNAPSHOT</version>
+    <version>4.7.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

micrometer-support/pom.xml

@@ -5,7 +5,7 @@
   <parent>
     <artifactId>java-operator-sdk</artifactId>
     <groupId>io.javaoperatorsdk</groupId>
-    <version>4.6.1-SNAPSHOT</version>
+    <version>4.7.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

operator-framework-bom/pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>operator-framework-bom</artifactId>
-    <version>4.6.1-SNAPSHOT</version>
+    <version>4.7.0-SNAPSHOT</version>
     <name>Operator SDK - Bill of Materials</name>
     <packaging>pom</packaging>
     <description>Java SDK for implementing Kubernetes operators</description>

operator-framework-core/pom.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>4.6.1-SNAPSHOT</version>
+    <version>4.7.0-SNAPSHOT</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 

operator-framework-junit5/pom.xml

@@ -5,7 +5,7 @@
   <parent>
     <artifactId>java-operator-sdk</artifactId>
     <groupId>io.javaoperatorsdk</groupId>
-    <version>4.6.1-SNAPSHOT</version>
+    <version>4.7.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

operator-framework/pom.xml

@@ -5,7 +5,7 @@
   <parent>
     <artifactId>java-operator-sdk</artifactId>
     <groupId>io.javaoperatorsdk</groupId>
-    <version>4.6.1-SNAPSHOT</version>
+    <version>4.7.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

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;
+  }
+}

pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>io.javaoperatorsdk</groupId>
     <artifactId>java-operator-sdk</artifactId>
-    <version>4.6.1-SNAPSHOT</version>
+    <version>4.7.0-SNAPSHOT</version>
     <name>Operator SDK for Java</name>
     <description>Java SDK for implementing Kubernetes operators</description>
     <packaging>pom</packaging>

sample-operators/leader-election/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.javaoperatorsdk</groupId>
         <artifactId>sample-operators</artifactId>
-        <version>4.6.1-SNAPSHOT</version>
+        <version>4.7.0-SNAPSHOT</version>
     </parent>
 
     <artifactId>sample-leader-election</artifactId>

sample-operators/mysql-schema/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.javaoperatorsdk</groupId>
         <artifactId>sample-operators</artifactId>
-        <version>4.6.1-SNAPSHOT</version>
+        <version>4.7.0-SNAPSHOT</version>
     </parent>
 
     <artifactId>sample-mysql-schema-operator</artifactId>

sample-operators/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.javaoperatorsdk</groupId>
         <artifactId>java-operator-sdk</artifactId>
-        <version>4.6.1-SNAPSHOT</version>
+        <version>4.7.0-SNAPSHOT</version>
     </parent>
 
     <artifactId>sample-operators</artifactId>

sample-operators/tomcat-operator/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.javaoperatorsdk</groupId>
         <artifactId>sample-operators</artifactId>
-        <version>4.6.1-SNAPSHOT</version>
+        <version>4.7.0-SNAPSHOT</version>
     </parent>
 
     <artifactId>sample-tomcat-operator</artifactId>

sample-operators/webpage/pom.xml

@@ -7,7 +7,7 @@
     <parent>
         <groupId>io.javaoperatorsdk</groupId>
         <artifactId>sample-operators</artifactId>
-        <version>4.6.1-SNAPSHOT</version>
+        <version>4.7.0-SNAPSHOT</version>
     </parent>
 
     <artifactId>sample-webpage-operator</artifactId>