From 42ffb32edb714f2a690c7ec0afbf71be1bd63ca8 Mon Sep 17 00:00:00 2001
From: csviri <csviri@gmail.com>
Date: Tue, 8 Mar 2022 14:31:41 +0100
Subject: [PATCH] fix: added logging

---
 .../operator/processing/event/EventProcessor.java     | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java
index 9ea6df7332..7f4cae69a4 100644
--- a/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java
+++ b/operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/EventProcessor.java
@@ -168,8 +168,10 @@ private void submitReconciliationExecution(ResourceID resourceID) {
   private void handleEventMarking(Event event) {
     if (event instanceof ResourceEvent
         && ((ResourceEvent) event).getAction() == ResourceAction.DELETED) {
+      log.debug("Marking delete event received for: {}", event.getRelatedCustomResourceID());
       eventMarker.markDeleteEventReceived(event);
     } else if (!eventMarker.deleteEventPresent(event.getRelatedCustomResourceID())) {
+      log.debug("Marking event received for: {}", event.getRelatedCustomResourceID());
       eventMarker.markEventReceived(event);
     }
   }
@@ -227,7 +229,13 @@ private void reScheduleExecutionIfInstructed(
       PostExecutionControl<R> postExecutionControl, R customResource) {
     postExecutionControl
         .getReScheduleDelay()
-        .ifPresent(delay -> retryEventSource().scheduleOnce(customResource, delay));
+        .ifPresent(delay -> {
+          if (log.isDebugEnabled()) {
+            log.debug("ReScheduling event for resource: {} with delay: {}",
+                ResourceID.fromResource(customResource), delay);
+          }
+          retryEventSource().scheduleOnce(customResource, delay);
+        });
   }
 
   TimerEventSource<R> retryEventSource() {
@@ -284,6 +292,7 @@ private RetryExecution getOrInitRetryExecution(ExecutionScope<R> executionScope)
   }
 
   private void cleanupForDeletedEvent(ResourceID customResourceUid) {
+    log.debug("Cleaning up for delete event for: {}", customResourceUid);
     eventMarker.cleanup(customResourceUid);
     metrics.cleanupDoneFor(customResourceUid);
   }