allegro-internal/flex-roadmap#819 ReactorUtilsTest

allegro · Oct 21, 2024 · c94026b · c94026b
1 parent c596457
commit c94026b
Showing 1 changed file with 4 additions and 4 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
@@ -98,10 +98,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 discardedItemsAfterBackpressure = meterRegistry.find(REACTOR_METRIC)
-            .tags(Tags.of(METRIC_TYPE_TAG, "discarded-items", METRIC_EMITTER_TAG, "latest")).counter()?.count()
+        val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_DISCARDED_METRIC)
+            .tags(Tags.of( METRIC_EMITTER_TAG, "latest-before")).counter()?.count()
+        val discardedItemsAfterBackpressure = meterRegistry.find(REACTOR_DISCARDED_METRIC)
+            .tags(Tags.of( METRIC_EMITTER_TAG, "latest")).counter()?.count()
 
         /**
          * Published by range: (0..10)