From 4f24529aef0b32ed7e3a721b805fa5de20b82d3d Mon Sep 17 00:00:00 2001 From: kjaniak Date: Thu, 7 Nov 2019 12:29:12 +0100 Subject: Fix for 30s bucket problem in metrics Change-Id: I9a6b362f59a47454cb36d9a54861d1bcc1b934be Issue-ID: DCAEGEN2-1890 Signed-off-by: kjaniak --- .../org/onap/dcae/collectors/veshv/main/metrics/MicrometerMetrics.kt | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/metrics/MicrometerMetrics.kt b/sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/metrics/MicrometerMetrics.kt index 9d417a28..2f3470a4 100644 --- a/sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/metrics/MicrometerMetrics.kt +++ b/sources/hv-collector-main/src/main/kotlin/org/onap/dcae/collectors/veshv/main/metrics/MicrometerMetrics.kt @@ -59,6 +59,7 @@ class MicrometerMetrics internal constructor( .publishPercentileHistogram(true) .register(registry) private val processingTimeWithoutRouting = Timer.builder(name(MESSAGES, PROCESSING, TIME, WITHOUT, ROUTING)) + .maximumExpectedValue(MAX_BUCKET_DURATION) .publishPercentileHistogram(true) .register(registry) private val totalLatency = Timer.builder(name(MESSAGES, LATENCY)) @@ -135,7 +136,7 @@ class MicrometerMetrics internal constructor( } companion object { - val INSTANCE = MicrometerMetrics() + val INSTANCE by lazy { MicrometerMetrics() } internal const val PREFIX = "hvves" internal const val MESSAGES = "messages" internal const val RECEIVED = "received" @@ -154,9 +155,9 @@ class MicrometerMetrics internal constructor( internal const val TIME = "time" internal const val LATENCY = "latency" internal const val PAYLOAD = "payload" - internal val MAX_BUCKET_DURATION = Duration.ofSeconds(300L) internal const val WITHOUT = "without" internal const val ROUTING = "routing" + internal val MAX_BUCKET_DURATION = Duration.ofSeconds(300L) internal fun name(vararg name: String) = "$PREFIX.${name.joinToString(".")}" } } -- cgit 1.2.3-korg