From 50e298a4f4b4049455eb06bc982ab1dc8bb6480e Mon Sep 17 00:00:00 2001 From: Chris Eager Date: Wed, 19 Mar 2025 14:32:09 -0500 Subject: [PATCH] Add counter for Redis events --- .../redis/ConnectionEventLogger.java | 28 ++++++++++++------- 1 file changed, 18 insertions(+), 10 deletions(-) diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/redis/ConnectionEventLogger.java b/service/src/main/java/org/whispersystems/textsecuregcm/redis/ConnectionEventLogger.java index aa059b25b..193aafba7 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/redis/ConnectionEventLogger.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/redis/ConnectionEventLogger.java @@ -5,23 +5,31 @@ package org.whispersystems.textsecuregcm.redis; +import static org.whispersystems.textsecuregcm.metrics.MetricsUtil.name; + import io.lettuce.core.cluster.event.ClusterTopologyChangedEvent; import io.lettuce.core.event.connection.ConnectionEvent; import io.lettuce.core.resource.ClientResources; +import io.micrometer.core.instrument.Metrics; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class ConnectionEventLogger { - private static final Logger logger = LoggerFactory.getLogger(ConnectionEventLogger.class); + private static final String EVENT_COUNTER_NAME = name(ConnectionEventLogger.class, "events"); - public static void logConnectionEvents(final ClientResources clientResources) { - clientResources.eventBus().get().subscribe(event -> { - if (event instanceof ConnectionEvent) { - logger.debug("Connection event: {}", event); - } else if (event instanceof ClusterTopologyChangedEvent) { - logger.info("Cluster topology changed: {}", event); - } - }); - } + private static final Logger logger = LoggerFactory.getLogger(ConnectionEventLogger.class); + + public static void logConnectionEvents(final ClientResources clientResources) { + + clientResources.eventBus().get().subscribe(event -> { + if (event instanceof ConnectionEvent) { + logger.debug("Connection event: {}", event); + } else if (event instanceof ClusterTopologyChangedEvent) { + logger.info("Cluster topology changed: {}", event); + } + + Metrics.counter(EVENT_COUNTER_NAME, "type", event.getClass().getSimpleName()).increment(); + }); + } }