wip

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

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/support/ResourceCache.java

@@ -15,6 +15,11 @@ public ResourceCache(BiPredicate<Pair<P>, P> evictionPredicate) {
     this.evictionPredicate = evictionPredicate;
   }
 
+  public void cacheResource(P afterUpdate) {
+    var resourceId = ResourceID.fromResource(afterUpdate);
+    cache.put(resourceId, new Pair<>(null, afterUpdate));
+  }
+
   public void cacheResource(P beforeUpdate, P afterUpdate) {
     var resourceId = ResourceID.fromResource(beforeUpdate);
     cache.put(resourceId, new Pair<>(beforeUpdate, afterUpdate));
@@ -26,6 +31,10 @@ public P getFreshResource(P newVersion) {
     if (pair == null) {
       return newVersion;
     }
+    if (!newVersion.getMetadata().getUid().equals(pair.afterUpdate().getMetadata().getUid())) {
+      cache.remove(resourceId);
+      return newVersion;
+    }
     if (evictionPredicate.test(pair, newVersion)) {
       cache.remove(resourceId);
       return newVersion;