feat: all-event mode

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

Author: csviri

notes.txt

@@ -0,0 +1 @@
+- check that Cleaner interface is not present

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ControllerConfiguration.java

@@ -92,4 +92,8 @@ default String fieldManager() {
   }
 
   <C> C getConfigurationFor(DependentResourceSpec<?, P, C> spec);
+
+  default ControllerMode getMode() {
+    return ControllerMode.DEFAULT;
+  }
 }

operator-framework-core/src/main/java/io/javaoperatorsdk/operator/api/config/ControllerMode.java

@@ -0,0 +1,6 @@
+package io.javaoperatorsdk.operator.api.config;
+
+public enum ControllerMode {
+  DEFAULT,
+  ALL_EVENT_MODE
+}

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

@@ -6,6 +6,7 @@
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
 
+import io.javaoperatorsdk.operator.api.config.ControllerMode;
 import io.javaoperatorsdk.operator.api.config.informer.Informer;
 import io.javaoperatorsdk.operator.processing.event.rate.LinearRateLimiter;
 import io.javaoperatorsdk.operator.processing.event.rate.RateLimiter;
@@ -77,4 +78,6 @@ MaxReconciliationInterval maxReconciliationInterval() default
    * @return the name used as field manager for SSA operations
    */
   String fieldManager() default CONTROLLER_NAME_AS_FIELD_MANAGER;
+
+  ControllerMode allEventMode() default ControllerMode.DEFAULT;
 }

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

@@ -15,6 +15,7 @@
 import io.javaoperatorsdk.operator.OperatorException;
 import io.javaoperatorsdk.operator.api.config.ConfigurationService;
 import io.javaoperatorsdk.operator.api.config.ControllerConfiguration;
+import io.javaoperatorsdk.operator.api.config.ControllerMode;
 import io.javaoperatorsdk.operator.api.monitoring.Metrics;
 import io.javaoperatorsdk.operator.api.reconciler.Constants;
 import io.javaoperatorsdk.operator.processing.LifecycleAware;
@@ -122,7 +123,7 @@ public synchronized void handleEvent(Event event) {
   }
 
   private void handleMarkedEventForResource(ResourceState state) {
-    if (state.deleteEventPresent()) {
+    if (state.deleteEventPresent() && !isAllEventMode()) {
       cleanupForDeletedEvent(state.getId());
     } else if (!state.processedMarkForDeletionPresent()) {
       submitReconciliationExecution(state);
@@ -179,7 +180,7 @@ private void handleEventMarking(Event event, ResourceState state) {
     if (event instanceof ResourceEvent resourceEvent) {
       if (resourceEvent.getAction() == ResourceAction.DELETED) {
         log.debug("Marking delete event received for: {}", relatedCustomResourceID);
-        state.markDeleteEventReceived();
+        state.markDeleteEventReceived(resourceEvent.getResource().orElseThrow());
       } else {
         if (state.processedMarkForDeletionPresent() && isResourceMarkedForDeletion(resourceEvent)) {
           log.debug(
@@ -501,4 +502,8 @@ public synchronized boolean isUnderProcessing(ResourceID resourceID) {
   public synchronized boolean isRunning() {
     return running;
   }
+
+  private boolean isAllEventMode() {
+    return controllerConfiguration.getMode() == ControllerMode.ALL_EVENT_MODE;
+  }
 }

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

@@ -1,5 +1,6 @@
 package io.javaoperatorsdk.operator.processing.event;
 
+import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.javaoperatorsdk.operator.processing.event.rate.RateLimiter.RateLimitState;
 import io.javaoperatorsdk.operator.processing.retry.RetryExecution;
 
@@ -29,6 +30,7 @@ private enum EventingState {
   private RetryExecution retry;
   private EventingState eventing;
   private RateLimitState rateLimit;
+  private HasMetadata lastKnownResource;
 
   public ResourceState(ResourceID id) {
     this.id = id;
@@ -63,8 +65,9 @@ public void setUnderProcessing(boolean underProcessing) {
     this.underProcessing = underProcessing;
   }
 
-  public void markDeleteEventReceived() {
+  public void markDeleteEventReceived(HasMetadata lastKnownResource) {
     eventing = EventingState.DELETE_EVENT_PRESENT;
+    this.lastKnownResource = lastKnownResource;
   }
 
   public boolean deleteEventPresent() {
@@ -94,6 +97,10 @@ public boolean noEventPresent() {
     return eventing == EventingState.NO_EVENT_PRESENT;
   }
 
+  public HasMetadata getLastKnownResource() {
+    return lastKnownResource;
+  }
+
   public void unMarkEventReceived() {
     switch (eventing) {
       case EVENT_PRESENT: