feat: make primary cache accessible from Context (#2053)

* feat: make primary cache accessible from Context

Signed-off-by: Chris Laprun <claprun@redhat.com>

* refactor: introduce IndexedResourceCache interface

Signed-off-by: Chris Laprun <claprun@redhat.com>

* refactor: move read-only cache interfaces to api package

Signed-off-by: Chris Laprun <claprun@redhat.com>

---------

Signed-off-by: Chris Laprun <claprun@redhat.com>

Author: metacosm

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/Context.java

@@ -10,6 +10,7 @@
 import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.managed.ManagedDependentResourceContext;
 import io.javaoperatorsdk.operator.processing.event.EventSourceRetriever;
+import io.javaoperatorsdk.operator.processing.event.source.IndexerResourceCache;
 
 public interface Context<P extends HasMetadata> {
 
@@ -43,4 +44,12 @@ <R> Optional<R> getSecondaryResource(Class<R> expectedType,
    * ExecutorService initialized by framework for workflows. Used for workflow standalone mode.
    */
   ExecutorService getWorkflowExecutorService();
+
+  /**
+   * Retrieves the primary resource cache.
+   *
+   * @return the {@link IndexerResourceCache} associated with the associated {@link Reconciler} for
+   *         this context
+   */
+  IndexedResourceCache<P> getPrimaryCache();
 }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/DefaultContext.java

@@ -40,6 +40,11 @@ public <T> Set<T> getSecondaryResources(Class<T> expectedType) {
     return getSecondaryResourcesAsStream(expectedType).collect(Collectors.toSet());
   }
 
+  @Override
+  public IndexedResourceCache<P> getPrimaryCache() {
+    return controller.getEventSourceManager().getControllerResourceEventSource();
+  }
+
   @Override
   public <R> Stream<R> getSecondaryResourcesAsStream(Class<R> expectedType) {
     return controller.getEventSourceManager().getResourceEventSourcesFor(expectedType).stream()

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/IndexedResourceCache.java

@@ -0,0 +1,9 @@
+package io.javaoperatorsdk.operator.api.reconciler;
+
+import java.util.List;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+
+public interface IndexedResourceCache<T extends HasMetadata> extends ResourceCache<T> {
+  List<T> byIndex(String indexName, String indexKey);
+}

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/ResourceCache.java renamed to operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/ResourceCache.java

@@ -1,9 +1,10 @@
-package io.javaoperatorsdk.operator.processing.event.source;
+package io.javaoperatorsdk.operator.api.reconciler;
 
 import java.util.function.Predicate;
 import java.util.stream.Stream;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.processing.event.source.Cache;
 
 @SuppressWarnings("unchecked")
 public interface ResourceCache<T extends HasMetadata> extends Cache<T> {

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

@@ -5,15 +5,13 @@
 import java.util.function.Function;
 
 import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.reconciler.IndexedResourceCache;
 
-public interface IndexerResourceCache<T extends HasMetadata> extends ResourceCache<T> {
+public interface IndexerResourceCache<T extends HasMetadata> extends IndexedResourceCache<T> {
 
   void addIndexers(Map<String, Function<T, List<String>>> indexers);
 
   default void addIndexer(String name, Function<T, List<String>> indexer) {
     addIndexers(Map.of(name, indexer));
   }
-
-  List<T> byIndex(String indexName, String indexKey);
-
 }