wip

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

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer/InformerManager.java

@@ -149,7 +149,6 @@ private InformerWrapper<R> createEventSource(
       ResourceEventHandler<R> eventHandler,
       String namespaceIdentifier) {
     final var informerConfig = configuration.getInformerConfig();
-
     if (informerConfig.getFieldSelector() != null
         && !informerConfig.getFieldSelector().getFields().isEmpty()) {
       for (var f : informerConfig.getFieldSelector().getFields()) {

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/pool/AbstractEventSourcePool.java

@@ -0,0 +1,3 @@
+package io.javaoperatorsdk.operator.processing.event.source.pool;
+
+public abstract class AbstractEventSourcePool<C, T> implements EventSourcePool<C, T> {}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/pool/EventSourcePool.java

@@ -0,0 +1,8 @@
+package io.javaoperatorsdk.operator.processing.event.source.pool;
+
+public interface EventSourcePool<C, T> {
+
+  T getEventSource(C classifier);
+
+  void removeEventSource(T informerEventSource);
+}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/pool/InformerClassifier.java

@@ -0,0 +1,10 @@
+package io.javaoperatorsdk.operator.processing.event.source.pool;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.config.informer.FieldSelector;
+
+public record InformerClassifier(
+    String labelSelector,
+    String namespaceIdentifier,
+    Class<? extends HasMetadata> resourceClass,
+    FieldSelector fieldSelector) {}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/pool/InformerPool.java

@@ -0,0 +1,38 @@
+package io.javaoperatorsdk.operator.processing.event.source.pool;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import io.fabric8.kubernetes.client.KubernetesClient;
+import io.fabric8.kubernetes.client.informers.SharedIndexInformer;
+
+public class InformerPool
+    extends AbstractEventSourcePool<InformerClassifier, SharedIndexInformer<?>> {
+
+  private final KubernetesClient client;
+
+  private Map<InformerClassifier, SharedIndexInformer<?>> informers = new ConcurrentHashMap<>();
+  private Map<SharedIndexInformer<?>, AtomicInteger> counters = new ConcurrentHashMap<>();
+
+  public InformerPool(KubernetesClient client) {
+    this.client = client;
+  }
+
+  @Override
+  public SharedIndexInformer<?> getEventSource(InformerClassifier classifier) {
+    var actual = informers.get(classifier);
+    if (actual == null) {
+      actual = null; // create Informer
+    }
+    incrementCounter(actual);
+    return null;
+  }
+
+  private synchronized void incrementCounter(SharedIndexInformer<?> actual) {
+    counters.compute(actual, (k, v) -> new AtomicInteger(v == null ? 0 : v.incrementAndGet()));
+  }
+
+  @Override
+  public void removeEventSource(SharedIndexInformer<?> informerEventSource) {}
+}