wip

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

Author: csviri

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

@@ -15,6 +15,10 @@ public PrimaryResourceCache(BiPredicate<Pair<P>, P> evictionPredicate) {
     this.evictionPredicate = evictionPredicate;
   }
 
+  public PrimaryResourceCache() {
+    this(new ResourceVersionParsingEvictionPredicate<>());
+  }
+
   public void cacheResource(P afterUpdate) {
     var resourceId = ResourceID.fromResource(afterUpdate);
     cache.put(resourceId, new Pair<>(null, afterUpdate));
@@ -49,6 +53,7 @@ public void cleanup(P resource) {
 
   public record Pair<T extends HasMetadata>(T beforeUpdate, T afterUpdate) {}
 
+  /** This works in general, but it does not strictly follow the contract with k8s API */
   public static class ResourceVersionParsingEvictionPredicate<T extends HasMetadata>
       implements BiPredicate<Pair<T>, T> {
     @Override

operator-framework/src/test/java/io/javaoperatorsdk/operator/baseapi/statuscache/PeriodicTriggerEventSource.java

@@ -43,10 +43,7 @@ public void start() throws OperatorException {
           public void run() {
             primaryCache
                 .list()
-                .forEach(
-                    r -> {
-                      getEventHandler().handleEvent(new Event(ResourceID.fromResource(r)));
-                    });
+                .forEach(r -> getEventHandler().handleEvent(new Event(ResourceID.fromResource(r))));
           }
         },
         0,