wip

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

Author: csviri

Diff for: operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/PrimaryUpdateAndCacheUtils.java

@@ -0,0 +1,25 @@
+package io.javaoperatorsdk.operator.api.reconciler;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+import io.javaoperatorsdk.operator.processing.event.ResourceID;
+
+public class PrimaryUpdateAndCacheUtils {
+
+  public static <P extends HasMetadata> P updateAndCacheStatus(P primary, Context<P> context) {
+    if (primary.getMetadata().getResourceVersion() == null) {
+      throw new IllegalStateException(
+          "Primary resource version is null, it is expected to set resource version for updates"
+              + " with for cache");
+    }
+    var updatedResource = context.getClient().resource(primary).updateStatus();
+    context
+        .eventSourceRetriever()
+        .getControllerEventSource()
+        .handleRecentResourceUpdate(ResourceID.fromResource(primary), updatedResource, primary);
+    return updatedResource;
+  }
+
+  public static <P extends HasMetadata> P patchAndCacheStatus(P primary) {
+    return null;
+  }
+}

Diff for: operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/support/ResourceCache.java renamed to operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/reconciler/support/ResourceCache.java

@@ -1,4 +1,4 @@
-package io.javaoperatorsdk.operator.processing.support;
+package io.javaoperatorsdk.operator.api.reconciler.support;
 
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.BiPredicate;

Diff for: operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceManager.java

@@ -208,6 +208,7 @@ public Stream<? extends EventSource<?, P>> getEventSourcesStream() {
     return eventSources.flatMappedSources();
   }
 
+  @Override
   public ControllerEventSource<P> getControllerEventSource() {
     return eventSources.controllerEventSource();
   }

Diff for: operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventSourceRetriever.java

@@ -6,6 +6,7 @@
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.javaoperatorsdk.operator.api.reconciler.EventSourceContext;
 import io.javaoperatorsdk.operator.processing.event.source.EventSource;
+import io.javaoperatorsdk.operator.processing.event.source.controller.ControllerEventSource;
 
 public interface EventSourceRetriever<P extends HasMetadata> {
 
@@ -17,6 +18,8 @@ default <R> EventSource<R, P> getEventSourceFor(Class<R> dependentType) {
 
   <R> List<EventSource<R, P>> getEventSourcesFor(Class<R> dependentType);
 
+  ControllerEventSource<P> getControllerEventSource();
+
   /**
    * Registers (and starts) the specified {@link EventSource} dynamically during the reconciliation.
    * If an EventSource is already registered with the specified name, the registration will be