From 025872c6bed1353ed025ce3620a1fbd2ef8dbd2c Mon Sep 17 00:00:00 2001 From: "nastassia.dailidava" Date: Sun, 20 Oct 2024 00:16:00 +0200 Subject: [PATCH] allegro-internal/flex-roadmap#819 fixed TEST --- .../tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 c2f43c8f0..dd2b0d448 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 @@ -98,9 +98,9 @@ class ReactorUtilsTest { // then assertThat(received.await(2, TimeUnit.SECONDS)).isTrue() - val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_METRIC) + val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_TOTAL_METRIC) .tags(Tags.of(METRIC_TYPE_TAG, "discarded-items", METRIC_EMITTER_TAG, "latest-before")).counter()?.count() - val discardedItemsAfterBackpressure = meterRegistry.find(REACTOR_METRIC) + val discardedItemsAfterBackpressure = meterRegistry.find(REACTOR_TOTAL_METRIC) .tags(Tags.of(METRIC_TYPE_TAG, "discarded-items", METRIC_EMITTER_TAG, "latest")).counter()?.count() /**