wip

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

Author: csviri

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

@@ -6,6 +6,7 @@
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.fabric8.kubernetes.client.KubernetesClient;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.managed.ManagedWorkflowAndDependentResourceContext;
+import io.javaoperatorsdk.operator.api.reconciler.expectation.ExpectationResult;
 import io.javaoperatorsdk.operator.processing.event.source.IndexerResourceCache;
 
 public interface Context<P extends HasMetadata> extends CacheAware<P> {
@@ -52,4 +53,6 @@ public interface Context<P extends HasMetadata> extends CacheAware<P> {
    * @return {@code true} is another reconciliation is already scheduled, {@code false} otherwise
    */
   boolean isNextReconciliationImminent();
+
+  Optional<ExpectationResult> expectationResult();
 }

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

@@ -11,6 +11,7 @@
 import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.managed.DefaultManagedWorkflowAndDependentResourceContext;
 import io.javaoperatorsdk.operator.api.reconciler.dependent.managed.ManagedWorkflowAndDependentResourceContext;
+import io.javaoperatorsdk.operator.api.reconciler.expectation.ExpectationResult;
 import io.javaoperatorsdk.operator.processing.Controller;
 import io.javaoperatorsdk.operator.processing.event.EventSourceRetriever;
 import io.javaoperatorsdk.operator.processing.event.NoEventSourceForClassException;
@@ -119,6 +120,11 @@ public boolean isNextReconciliationImminent() {
         .isNextReconciliationImminent(ResourceID.fromResource(primaryResource));
   }
 
+  @Override
+  public Optional<ExpectationResult> expectationResult() {
+    return Optional.empty();
+  }
+
   public DefaultContext<P> setRetryInfo(RetryInfo retryInfo) {
     this.retryInfo = retryInfo;
     return this;

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

@@ -2,13 +2,13 @@
 
 public class ExpectationResult {
 
-    private ExpectationStatus status;
+  private ExpectationStatus status;
 
-    public ExpectationResult(ExpectationStatus status) {
-        this.status = status;
-    }
+  public ExpectationResult(ExpectationStatus status) {
+    this.status = status;
+  }
 
-    public ExpectationStatus getStatus() {
-        return status;
-    }
+  public ExpectationStatus getStatus() {
+    return status;
+  }
 }

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

@@ -1,6 +1,6 @@
 package io.javaoperatorsdk.operator.api.reconciler.expectation;
 
 public enum ExpectationStatus {
-    TIMEOUT,
-    FULFILLED;
+  TIMEOUT,
+  FULFILLED;
 }