feat: expectations

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

Author: csviri

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

@@ -0,0 +1,44 @@
+package io.javaoperatorsdk.operator.api.reconciler;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
+import io.javaoperatorsdk.operator.processing.event.EventSourceRetriever;
+import io.javaoperatorsdk.operator.processing.event.source.IndexerResourceCache;
+
+import java.util.Optional;
+import java.util.Set;
+import java.util.stream.Stream;
+
+public interface CacheAware<P extends HasMetadata> {
+    default <R> Optional<R> getSecondaryResource(Class<R> expectedType) {
+        return getSecondaryResource(expectedType, null);
+    }
+
+    <R> Set<R> getSecondaryResources(Class<R> expectedType);
+
+    default <R> Stream<R> getSecondaryResourcesAsStream(Class<R> expectedType) {
+        return getSecondaryResources(expectedType).stream();
+    }
+
+    <R> Optional<R> getSecondaryResource(Class<R> expectedType, String eventSourceName);
+
+    ControllerConfiguration<P> getControllerConfiguration();
+
+    /**
+     * Retrieves the primary resource.
+     *
+     * @return the primary resource associated with the current reconciliation
+     */
+    P getPrimaryResource();
+
+    /**
+     * Retrieves the primary resource cache.
+     *
+     * @return the {@link IndexerResourceCache} associated with the associated {@link Reconciler} for
+     *     this context
+     */
+    @SuppressWarnings("unused")
+    IndexedResourceCache<P> getPrimaryCache();
+
+    EventSourceRetriever<P> eventSourceRetriever();
+}

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

@@ -12,24 +12,10 @@
 import io.javaoperatorsdk.operator.processing.event.EventSourceRetriever;
 import io.javaoperatorsdk.operator.processing.event.source.IndexerResourceCache;
 
-public interface Context<P extends HasMetadata> {
+public interface Context<P extends HasMetadata> extends CacheAware<P> {
 
   Optional<RetryInfo> getRetryInfo();
 
-  default <R> Optional<R> getSecondaryResource(Class<R> expectedType) {
-    return getSecondaryResource(expectedType, null);
-  }
-
-  <R> Set<R> getSecondaryResources(Class<R> expectedType);
-
-  default <R> Stream<R> getSecondaryResourcesAsStream(Class<R> expectedType) {
-    return getSecondaryResources(expectedType).stream();
-  }
-
-  <R> Optional<R> getSecondaryResource(Class<R> expectedType, String eventSourceName);
-
-  ControllerConfiguration<P> getControllerConfiguration();
-
   /**
    * Retrieve the {@link ManagedWorkflowAndDependentResourceContext} used to interact with {@link
    * io.javaoperatorsdk.operator.api.reconciler.dependent.DependentResource}s and associated {@link
@@ -39,8 +25,6 @@ default <R> Stream<R> getSecondaryResourcesAsStream(Class<R> expectedType) {
    */
   ManagedWorkflowAndDependentResourceContext managedWorkflowAndDependentResourceContext();
 
-  EventSourceRetriever<P> eventSourceRetriever();
-
   KubernetesClient getClient();
 
   /** ExecutorService initialized by framework for workflows. Used for workflow standalone mode. */

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

@@ -0,0 +1,12 @@
+package io.javaoperatorsdk.operator.api.reconciler.expectation;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+
+import java.time.Duration;
+
+public interface Expectation<P extends HasMetadata> {
+
+  boolean isMet(P primary, ExpectationContext<P> context);
+
+  Duration timeout();
+}

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

@@ -0,0 +1,8 @@
+package io.javaoperatorsdk.operator.api.reconciler.expectation;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.api.reconciler.CacheAware;
+
+public interface ExpectationContext<P extends HasMetadata> extends CacheAware<P> {
+
+}