cache option

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

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ConfigurationService.java

@@ -457,14 +457,17 @@ default boolean previousAnnotationForDependentResourcesEventFiltering() {
    * logic, and you want to further minimize the amount of work done / updates issued by the
    * operator.
    *
-   * @return if resource version should be parsed (as integer)
    * @since 4.5.0
-   * @return if resource version should be parsed (as integer)
+   * @return if resourceVersion should be parsed (as integer)
    */
   default boolean parseResourceVersionsForEventFilteringAndCaching() {
     return false;
   }
 
+  default boolean cacheUpdatedResourcesViaUpdateControl() {
+    return false;
+  }
+
   /**
    * {@link io.javaoperatorsdk.operator.api.reconciler.UpdateControl} patch resource or status can
    * either use simple patches or SSA. Setting this to {@code true}, controllers will use SSA for

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ConfigurationServiceOverrider.java

@@ -40,6 +40,7 @@ public class ConfigurationServiceOverrider {
   private Boolean parseResourceVersions;
   private Boolean useSSAToPatchPrimaryResource;
   private Boolean cloneSecondaryResourcesWhenGettingFromCache;
+  private Boolean cacheUpdatedResourcesViaUpdateControl;
 
   @SuppressWarnings("rawtypes")
   private DependentResourceFactory dependentResourceFactory;
@@ -188,6 +189,11 @@ public ConfigurationServiceOverrider withCloneSecondaryResourcesWhenGettingFromC
     return this;
   }
 
+  public ConfigurationServiceOverrider withCacheUpdatedResourcesViaUpdateControl(boolean value) {
+    this.cacheUpdatedResourcesViaUpdateControl = value;
+    return this;
+  }
+
   public ConfigurationService build() {
     return new BaseConfigurationService(original.getVersion(), cloner, client) {
       @Override
@@ -328,6 +334,13 @@ public boolean cloneSecondaryResourcesWhenGettingFromCache() {
             cloneSecondaryResourcesWhenGettingFromCache,
             ConfigurationService::cloneSecondaryResourcesWhenGettingFromCache);
       }
+
+      @Override
+      public boolean cacheUpdatedResourcesViaUpdateControl() {
+        return overriddenValueOrDefault(
+            cacheUpdatedResourcesViaUpdateControl,
+            ConfigurationService::cacheUpdatedResourcesViaUpdateControl);
+      }
     };
   }
 }

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

@@ -416,7 +416,8 @@ static class CustomResourceFacade<R extends HasMetadata> {
     private final boolean useSSA;
     private final String fieldManager;
     private final Cloner cloner;
-    private final boolean previousAnnotationForDependentResourcesEventFiltering;
+    private final boolean cacheUpdatedResources;
+
     private final ControllerEventSource<R> controllerEventSource;
 
     public CustomResourceFacade(
@@ -427,16 +428,17 @@ public CustomResourceFacade(
       this.resourceOperation = resourceOperation;
       this.useSSA = configuration.getConfigurationService().useSSAToPatchPrimaryResource();
       this.fieldManager = configuration.fieldManager();
-      this.previousAnnotationForDependentResourcesEventFiltering =
+      this.cacheUpdatedResources =
           configuration
-              .getConfigurationService()
-              .previousAnnotationForDependentResourcesEventFiltering();
+                  .getConfigurationService()
+                  .previousAnnotationForDependentResourcesEventFiltering()
+              && configuration.getConfigurationService().cacheUpdatedResourcesViaUpdateControl();
       this.cloner = cloner;
       this.controllerEventSource = controllerEventSource;
     }
 
     private void cachePrimaryResource(R updatedResource, R previousVersionOfResource) {
-      if (previousAnnotationForDependentResourcesEventFiltering) {
+      if (cacheUpdatedResources) {
         controllerEventSource.handleRecentResourceUpdate(
             ResourceID.fromResource(updatedResource), updatedResource, previousVersionOfResource);
       }