diff --git a/envoy-control-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt b/envoy-control-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt index 111a1ee7b..5f2c804bd 100644 --- a/envoy-control-core/src/test/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt +++ b/envoy-control-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)