feature: modified events logic

Author: laxmikantbpandhare

Diff for: operator-framework-core/src/main/java/io/javaoperatorsdk/operator/Metrics.java

@@ -36,6 +36,7 @@ public <R extends CustomResource> UpdateControl<R> timeControllerCreateOrUpdate(
             .register(registry);
     try {
       final var result = timer.record(() -> controller.createOrUpdateResource(resource, context));
+      System.out.println("I am here in create update");
       String successType = "cr";
       if (result.isUpdateStatusSubResource()) {
         successType = "status";
@@ -47,9 +48,6 @@ public <R extends CustomResource> UpdateControl<R> timeControllerCreateOrUpdate(
           .counter(
               "operator.sdk.controllers.execution.success", "controller", name, "type", successType)
           .increment();
-      registry
-          .counter("operator.sdk.events.received", "events", name, "type", "totalEvents")
-          .increment();
       return result;
     } catch (Exception e) {
       registry
@@ -60,9 +58,6 @@ public <R extends CustomResource> UpdateControl<R> timeControllerCreateOrUpdate(
               "exception",
               e.getClass().getSimpleName())
           .increment();
-      registry
-          .counter("operator.sdk.events.received", "events", name, "exception", "totalEvents")
-          .increment();
       throw e;
     }
   }
@@ -81,6 +76,7 @@ public DeleteControl timeControllerDelete(
             .register(registry);
     try {
       final var result = timer.record(() -> controller.deleteResource(resource, context));
+      System.out.println("I am here in delete");
       String successType = "notDelete";
       if (result == DeleteControl.DEFAULT_DELETE) {
         successType = "delete";
@@ -89,9 +85,6 @@ public DeleteControl timeControllerDelete(
           .counter(
               "operator.sdk.controllers.execution.success", "controller", name, "type", successType)
           .increment();
-      registry
-          .counter("operator.sdk.events.received", "events", name, "type", "totalEvents")
-          .increment();
       return result;
     } catch (Exception e) {
       registry
@@ -102,9 +95,6 @@ public DeleteControl timeControllerDelete(
               "exception",
               e.getClass().getSimpleName())
           .increment();
-      registry
-          .counter("operator.sdk.events.received", "events", name, "exception", "totalEvents")
-          .increment();
       throw e;
     }
   }
@@ -119,6 +109,16 @@ public void timeControllerRetry() {
 
   }
 
+  public void timeControllerEvents() {
+
+    registry
+        .counter(
+            "operator.sdk.total.events.received", "events", "totalEvents", "type",
+            "eventsReceived")
+        .increment();
+
+  }
+
   public static class NoopMeterRegistry extends MeterRegistry {
     public NoopMeterRegistry(Clock clock) {
       super(clock);

Diff for: operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/DefaultEventHandler.java

@@ -116,6 +116,7 @@ public void handleEvent(Event event) {
       final Predicate<CustomResource> selector = event.getCustomResourcesSelector();
       for (String uid : eventSourceManager.getLatestResourceUids(selector)) {
         eventBuffer.addEvent(uid, event);
+        metrics.timeControllerEvents();
         executeBufferedEvents(uid);
       }
     } finally {