allegro-internal/flex-roadmap#819 reactor metrics

allegro · Oct 21, 2024 · 7d6d329 · 7d6d329
1 parent 77c3c55
commit 7d6d329
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...l-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt b/...l-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt
@@ -100,10 +100,10 @@ class ReactorUtilsTest {
         // then
         assertThat(received.await(2, TimeUnit.SECONDS)).isTrue()
 
-        val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_METRIC)
-            .tags(Tags.of(METRIC_TYPE_TAG, "discarded-items", METRIC_EMITTER_TAG, "latest-before")).counter()?.count()
+        val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_TOTAL_METRIC)
+            .tags(Tags.of(METRIC_EMITTER_TAG, "latest-before")).counter()?.count()
         val discardedItemsAfterBackpressure = meterRegistry.find(REACTOR_METRIC)
-            .tags(Tags.of(METRIC_TYPE_TAG, "discarded-items", METRIC_EMITTER_TAG, "latest")).counter()?.count()
+            .tags(Tags.of(METRIC_EMITTER_TAG, "latest")).counter()?.count()
 
         /**
          * Published by range: (0..10)