event scheduling algorithm

Author: csviri

operator-framework/src/main/java/com/github/containersolutions/operator/processing/EventScheduler.java

@@ -84,11 +84,18 @@ void scheduleEvent(CustomResourceEvent event) {
                 return;
             }
             if (eventStore.containsNotScheduledEvent(event.resourceUid())) {
+                log.debug("Replacing event for later processing." +
+                        " New event: {}", event);
+                eventStore.addOrReplaceEventAsNotScheduledYet(event);
+                return;
+            }
+            if (eventStore.containsEventUnderProcessing(event.resourceUid())) {
                 log.debug("Scheduling event for later processing since there is an event under processing for same kind." +
                         " New event: {}", event);
                 eventStore.addOrReplaceEventAsNotScheduledYet(event);
                 return;
             }
+
             Optional<Long> nextBackOff = event.nextBackOff();
             if (!nextBackOff.isPresent()) {
                 log.warn("Event max retry limit reached. Will be discarded. {}", event);

operator-framework/src/main/java/com/github/containersolutions/operator/processing/EventStore.java

@@ -25,9 +25,14 @@ public void addOrReplaceEventAsNotScheduledYet(CustomResourceEvent event) {
         eventsNotScheduledYet.put(event.resourceUid(), event);
     }
 
+    public boolean containsEventUnderProcessing(String uuid) {
+        return eventsUnderProcessing.containsKey(uuid);
+    }
+
     public void addEventUnderProcessing(CustomResourceEvent event) {
         eventsUnderProcessing.put(event.resourceUid(), event);
     }
+
     public CustomResourceEvent removeEventUnderProcessing(String uid) {
         return eventsUnderProcessing.remove(uid);
     }