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 c1e0ca903..e8e981f0a 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 @@ -6,6 +6,7 @@ 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_TOTAL_METRIC = "reactor.stats.total" 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/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtils.kt b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtils.kt index ab4806a09..02f417e86 100644 --- a/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtils.kt +++ b/envoy-control-core/src/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/utils/ReactorUtils.kt @@ -52,7 +52,7 @@ fun Flux.measureBuffer( fun Flux.measureDiscardedItems(name: String, meterRegistry: MeterRegistry): Flux = this .doOnDiscard(Any::class.java) { meterRegistry.counter( - REACTOR_METRIC, + REACTOR_TOTAL_METRIC, METRIC_TYPE_TAG, "discarded-items", METRIC_EMITTER_TAG, name ).increment()