Add timer for adding a connection log entry

Signed-off-by: Yannic Klem <yannic.klem@bosch.io>
eclipse-ditto · Jul 6, 2021 · 5d9bad8 · 5d9bad8
1 parent 89d3e3a
commit 5d9bad8
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...clipse/ditto/connectivity/service/messaging/monitoring/logs/EvictingConnectionLogger.java b/...clipse/ditto/connectivity/service/messaging/monitoring/logs/EvictingConnectionLogger.java
@@ -31,6 +31,8 @@
 import org.eclipse.ditto.connectivity.service.messaging.monitoring.ConnectionMonitor;
 import org.eclipse.ditto.internal.utils.akka.logging.DittoLogger;
 import org.eclipse.ditto.internal.utils.akka.logging.DittoLoggerFactory;
+import org.eclipse.ditto.internal.utils.metrics.DittoMetrics;
+import org.eclipse.ditto.internal.utils.metrics.instruments.timer.StartedTimer;
 
 /**
  * Implementation of {@link ConnectionLogger} that
@@ -112,10 +114,13 @@ public void success(final ConnectionMonitor.InfoProvider infoProvider) {
     @Override
     public void success(final ConnectionMonitor.InfoProvider infoProvider, final String message,
             final Object... messageArguments) {
-
+        final StartedTimer logTimer = DittoMetrics.timer("connection_log").start();
         final String formattedMessage = formatMessage(infoProvider, message, messageArguments);
+        logTimer.startNewSegment("message_prepared");
         logTraceWithCorrelationId(infoProvider.getCorrelationId(), "success", infoProvider, formattedMessage);
+        logTimer.startNewSegment("message_internally_logged");
         successLogs.add(getLogEntry(infoProvider, formattedMessage, LogLevel.SUCCESS));
+        logTimer.stop();
     }
 
     @Override