From fcf347051d70614a316b915ef2525f0ba4d08fd5 Mon Sep 17 00:00:00 2001 From: "nastassia.dailidava" Date: Mon, 21 Oct 2024 12:24:31 +0200 Subject: [PATCH] allegro-internal/flex-roadmap#819 ReactorUtilsTest --- .../pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt | 4 ++-- .../tech/servicemesh/envoycontrol/utils/ReactorUtilsTest.kt | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt index b7e3bb692..a38fd30e2 100644 --- a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt +++ b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/Metrics.kt @@ -5,8 +5,8 @@ import io.micrometer.core.instrument.Tags import io.micrometer.core.instrument.noop.NoopTimer val noopTimer = NoopTimer(Meter.Id("", Tags.empty(), null, null, Meter.Type.TIMER)) -const val REACTOR_METRIC = "reactor.stats" -const val REACTOR_DISCARDED_METRIC = "reactor.discarded" +const val REACTOR_METRIC = "reactor.stream.stats" +const val REACTOR_DISCARDED_METRIC = "reactor.stream.discarded" const val SERVICES_STATE_METRIC = "services.state" const val SERVICES_STATE_ERRORS_METRIC = "services.state.errors.total" const val SNAPSHOT_METRIC = "snapshot" 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 7e554b087..d58fd836a 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 @@ -99,9 +99,9 @@ class ReactorUtilsTest { assertThat(received.await(2, TimeUnit.SECONDS)).isTrue() val discardedItemsBeforeBackpressure = meterRegistry.find(REACTOR_DISCARDED_METRIC) - .tags(Tags.of( METRIC_EMITTER_TAG, "latest-before")).counter()?.count() + .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() + .tags(Tags.of(METRIC_EMITTER_TAG, "latest")).counter()?.count() /** * Published by range: (0..10)