From c94026b70e95ff1cf3e2b3d22f22cd3be5f5b6c3 Mon Sep 17 00:00:00 2001 From: "nastassia.dailidava" Date: Mon, 21 Oct 2024 12:15:49 +0200 Subject: [PATCH] allegro-internal/flex-roadmap#819 ReactorUtilsTest --- .../servicemesh/envoycontrol/utils/ReactorUtilsTest.kt | 8 ++++---- 1 file changed, 4 insertions(+), 4 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..7e554b087 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,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)