log sanitization

Author: csviri

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

@@ -5,9 +5,11 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+@SuppressWarnings("rawtypes")
 class EventConsumer implements Runnable {
 
     private final static Logger log = LoggerFactory.getLogger(EventConsumer.class);
+
     private final CustomResourceEvent event;
     private final EventDispatcher eventDispatcher;
     private final EventScheduler eventScheduler;
@@ -20,27 +22,26 @@ class EventConsumer implements Runnable {
 
     @Override
     public void run() {
+        log.debug("Processing event started: {}", event);
         if (processEvent()) {
             eventScheduler.eventProcessingFinishedSuccessfully(event);
+            log.debug("Event processed successfully: {}", event);
         } else {
             this.eventScheduler.eventProcessingFailed(event);
+            log.debug("Event processed failed: {}", event);
         }
     }
 
     @SuppressWarnings("unchecked")
     private boolean processEvent() {
-
         Watcher.Action action = event.getAction();
         CustomResource resource = event.getResource();
-        log.info("Processing event {}", event);
         try {
             eventDispatcher.handleEvent(action, resource);
         } catch (RuntimeException e) {
             log.error("Processing event {} failed.", event, e);
-            log.debug("Failed object: {}", resource);
             return false;
         }
-
         return true;
     }
 }

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

@@ -74,8 +74,8 @@ public void eventReceived(Watcher.Action action, R resource) {
     }
 
     void scheduleEvent(CustomResourceEvent event) {
-        log.debug("Current queue size {}", executor.getQueue().size());
-        log.info("Scheduling event: {}", event);
+        log.trace("Current queue size {}", executor.getQueue().size());
+        log.debug("Scheduling event: {}", event);
         try {
             lock.lock();
             if (event.getAction() == Action.DELETED) {
@@ -109,7 +109,7 @@ void scheduleEvent(CustomResourceEvent event) {
                     nextBackOff.get(), TimeUnit.MILLISECONDS);
             eventStore.addEventUnderProcessing(event);
         } finally {
-            log.info("Scheduling event finished: {}", event);
+            log.debug("Scheduling event finished: {}", event);
             lock.unlock();
         }
     }