record only last event

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

Author: csviri

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

@@ -15,19 +15,14 @@
  */
 package io.javaoperatorsdk.operator.processing.event.source.informer;
 
-import java.util.ArrayList;
-import java.util.List;
 import java.util.Optional;
 
 import io.javaoperatorsdk.operator.processing.event.source.controller.ResourceEvent;
 
 class EventFilterDetails {
 
-  // initially should be created during event filtering update
-
   private int activeUpdates = 0;
-  // todo might be just one
-  private final List<ResourceEvent> events = new ArrayList<>();
+  private ResourceEvent lastEvent;
   private int lastUpdatedResourceVersion = -1;
 
   public int getActiveUpdates() {
@@ -42,8 +37,8 @@ public void decreaseActiveUpdates() {
     activeUpdates = activeUpdates - 1;
   }
 
-  public void recordEvent(ResourceEvent event) {
-    events.add(event);
+  public void setLastEvent(ResourceEvent event) {
+    lastEvent = event;
   }
 
   public void setLastUpdatedResourceVersion(String version) {
@@ -54,11 +49,10 @@ public void setLastUpdatedResourceVersion(String version) {
   }
 
   public Optional<ResourceEvent> getLatestEventAfterLastUpdateEvent() {
-    if (events.isEmpty()) return Optional.empty();
-    var latest = events.get(events.size() - 1);
-    if (Integer.parseInt(latest.getResource().orElseThrow().getMetadata().getResourceVersion())
+    if (lastEvent == null) return Optional.empty();
+    if (Integer.parseInt(lastEvent.getResource().orElseThrow().getMetadata().getResourceVersion())
         > lastUpdatedResourceVersion) {
-      return Optional.of(latest);
+      return Optional.of(lastEvent);
     } else {
       return Optional.empty();
     }

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

@@ -144,7 +144,7 @@ private synchronized boolean onEvent(T resource, boolean unknownState, boolean d
     }
     var ed = activeUpdates.get(resourceId);
     if (ed != null) {
-      ed.recordEvent(
+      ed.setLastEvent(
           delete
               ? new ResourceDeleteEvent(ResourceAction.DELETED, resourceId, resource, unknownState)
               : new ResourceEvent(