allegro-internal/flex-roadmap#819 ReactorUtilsTest

allegro · Oct 21, 2024 · fcf3470 · fcf3470
1 parent c94026b
commit fcf3470
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 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
@@ -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/...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
@@ -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)