allegro-internal/flex-roadmap#819 Migrated metrics to prometheus (lint)

allegro · Oct 1, 2024 · c435189 · c435189
1 parent e5efd7b
commit c435189
Showing 1 changed file with 15 additions and 3 deletions.
diff --git a/...allegro/tech/servicemesh/envoycontrol/server/callbacks/MetricsDiscoveryServerCallbacks.kt b/...allegro/tech/servicemesh/envoycontrol/server/callbacks/MetricsDiscoveryServerCallbacks.kt
@@ -37,7 +37,11 @@ class MetricsDiscoveryServerCallbacks(private val meterRegistry: MeterRegistry)
             .toMap()
 
         connectionsByType.forEach { (type, typeConnections) ->
-            meterRegistry.gauge("connections", Tags.of("connection-type", "grpc", "stream-type", type.name.lowercase()), typeConnections)
+            meterRegistry.gauge(
+                "connections",
+                Tags.of("connection-type", "grpc", "stream-type", type.name.lowercase()),
+                typeConnections
+            )
         }
     }
 
@@ -54,7 +58,11 @@ class MetricsDiscoveryServerCallbacks(private val meterRegistry: MeterRegistry)
     override fun onV3StreamRequest(streamId: Long, request: V3DiscoveryRequest) {
         meterRegistry.counter(
             "requests.total",
-            Tags.of("connection-type", "grpc", "stream-type", StreamType.fromTypeUrl(request.typeUrl).name.lowercase(), "discovery-request-type", "total")
+            Tags.of(
+                "connection-type", "grpc",
+                "stream-type", StreamType.fromTypeUrl(request.typeUrl).name.lowercase(),
+                "discovery-request-type", "total"
+            )
         )
             .increment()
     }
@@ -65,7 +73,11 @@ class MetricsDiscoveryServerCallbacks(private val meterRegistry: MeterRegistry)
     ) {
         meterRegistry.counter(
             "requests.total",
-            Tags.of("connection-type", "grpc", "stream-type", StreamType.fromTypeUrl(request.typeUrl).name.lowercase(), "discovery-request-type", "delta")
+            Tags.of(
+                "connection-type",
+                "grpc", "stream-type",
+                StreamType.fromTypeUrl(request.typeUrl).name.lowercase(), "discovery-request-type", "delta"
+            )
         )
             .increment()
     }