wip

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

Author: csviri

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

@@ -0,0 +1,15 @@
+package io.javaoperatorsdk.operator.processing.event.source.informer;
+
+import java.util.Set;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.processing.event.ResourceID;
+
+public interface ComplementaryPrimaryToSecondaryIndex<R extends HasMetadata> {
+
+  void explicitAddOrUpdate(R resource);
+
+  void onCreateOrUpdateEvent(R resourceID);
+
+  Set<ResourceID> getComplementarySecondaryResources(ResourceID primary);
+}

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

@@ -0,0 +1,24 @@
+package io.javaoperatorsdk.operator.processing.event.source.informer;
+
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.processing.event.ResourceID;
+
+public class DefaultComplementaryPrimaryToSecondaryIndex<R extends HasMetadata>
+    implements ComplementaryPrimaryToSecondaryIndex<R> {
+
+  private final ConcurrentHashMap<ResourceID, Set<ResourceID>> index = new ConcurrentHashMap<>();
+
+  @Override
+  public void explicitAddOrUpdate(R resource) {}
+
+  @Override
+  public void onCreateOrUpdateEvent(R resourceID) {}
+
+  @Override
+  public Set<ResourceID> getComplementarySecondaryResources(ResourceID primary) {
+    return Set.of();
+  }
+}