feat: allow transform resource before caching in TemporaryResoureCache

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

Author: csviri

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

@@ -19,6 +19,7 @@
 import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.function.UnaryOperator;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -60,6 +61,7 @@ public class TemporaryResourceCache<T extends HasMetadata> {
   private String latestResourceVersion;
 
   private final Map<ResourceID, EventFilterDetails> activeUpdates = new HashMap<>();
+  private final UnaryOperator<T> transformationFunction;
 
   public enum EventHandling {
     DEFER,
@@ -68,7 +70,13 @@ public enum EventHandling {
   }
 
   public TemporaryResourceCache(boolean comparableResourceVersions) {
+    this(comparableResourceVersions, t -> t);
+  }
+
+  public TemporaryResourceCache(
+      boolean comparableResourceVersions, UnaryOperator<T> transformationFunction) {
     this.comparableResourceVersions = comparableResourceVersions;
+    this.transformationFunction = transformationFunction;
   }
 
   public synchronized void startEventFilteringModify(ResourceID resourceID) {
@@ -204,7 +212,7 @@ public synchronized void putResource(T newResource) {
           "Temporarily moving ahead to target version {} for resource id: {}",
           newResource.getMetadata().getResourceVersion(),
           resourceId);
-      cache.put(resourceId, newResource);
+      cache.put(resourceId, transformationFunction.apply(newResource));
     }
   }