wip

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

Author: csviri

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

@@ -26,6 +26,10 @@ class EventSources<P extends HasMetadata> {
       new TimerEventSource<>("RetryAndRescheduleTimerEventSource");
   private ControllerEventSource<P> controllerEventSource;
 
+  public EventSources(boolean triggerReconcilerOnAllEvent) {
+    this.controllerEventSource = controllerEventSource;
+  }
+
   public void add(EventSource eventSource) {
     final var name = eventSource.name();
     var existing = sourceByName.get(name);

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/timer/TimerEventSource.java

@@ -21,13 +21,15 @@ public class TimerEventSource<R extends HasMetadata> extends AbstractEventSource
 
   private Timer timer;
   private final Map<ResourceID, EventProducerTimeTask> onceTasks = new ConcurrentHashMap<>();
+  private boolean triggerReconcilerOnAllEvent;
 
   public TimerEventSource() {
     super(Void.class);
   }
 
-  public TimerEventSource(String name) {
+  public TimerEventSource(String name, boolean triggerReconcilerOnAllEvent) {
     super(Void.class, name);
+    this.triggerReconcilerOnAllEvent = triggerReconcilerOnAllEvent;
   }
 
   @SuppressWarnings("unused")
@@ -50,7 +52,11 @@ public void scheduleOnce(ResourceID resourceID, long delay) {
 
   @Override
   public void onResourceDeleted(R resource) {
-    cancelOnceSchedule(ResourceID.fromResource(resource));
+    // for triggerReconcilerOnAllEvent the cancelOnceSchedule will be called on
+    // successful delete event processing
+    if (!triggerReconcilerOnAllEvent) {
+      cancelOnceSchedule(ResourceID.fromResource(resource));
+    }
   }
 
   public void cancelOnceSchedule(ResourceID customResourceUid) {