wip

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

Author: csviri

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/controller/ControllerEventSource.java

@@ -149,7 +149,9 @@ public void onUpdate(T oldCustomResource, T newCustomResource) {
 
   @Override
   public void onDelete(T resource, boolean deletedFinalStateUnknown) {
-    super.onDelete(resource, deletedFinalStateUnknown);
+    temporaryResourceCache.onDeleteEvent(resource, deletedFinalStateUnknown);
+    // delete event is quite special here, that requires special care, since we clean up caches on
+    // delete event.
     eventReceived(ResourceAction.DELETED, resource, null, deletedFinalStateUnknown, false);
   }
 

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

@@ -130,7 +130,7 @@ public synchronized void onDelete(R resource, boolean b) {
           resourceType().getSimpleName());
     }
     primaryToSecondaryIndex.onDelete(resource);
-    super.onDelete(resource, b);
+    temporaryResourceCache.onDeleteEvent(resource, b);
     if (acceptedByDeleteFilters(resource, b)) {
       propagateEvent(resource);
     }

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

@@ -72,11 +72,6 @@ protected ManagedInformerEventSource(
     this.configuration = configuration;
   }
 
-  @Override
-  public void onDelete(R obj, boolean deletedFinalStateUnknown) {
-    temporaryResourceCache.onDeleteEvent(obj, deletedFinalStateUnknown);
-  }
-
   protected InformerManager<R, C> manager() {
     return cache;
   }