diff --git a/apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/config/Metrics.kt b/apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/config/Metrics.kt index c3d1bdc6..e41e157e 100644 --- a/apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/config/Metrics.kt +++ b/apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/config/Metrics.kt @@ -9,18 +9,18 @@ import java.util.concurrent.atomic.AtomicLong fun MeterRegistry.tellMottatteOpplysninger() { counter( - "paw_antall_mottatte_events_total", + "paw_antall_mottatte_meldinger_total", Tags.of( - Tag.of("event", "opplysninger-om-arbeidssoeker") + Tag.of("meldingstype", "opplysninger-om-arbeidssoeker") ) ).increment() } fun MeterRegistry.antallLagredeOpplysningerTotal(antallReference: AtomicLong) { gauge( - "paw_antall_lagrede_events", + "paw_antall_lagrede_meldinger", Tags.of( - Tag.of("event", "opplysninger-om-arbeidssoeker") + Tag.of("meldingstype", "opplysninger-om-arbeidssoeker") ), antallReference ) { @@ -31,10 +31,10 @@ fun MeterRegistry.antallLagredeOpplysningerTotal(antallReference: AtomicLong) { fun MeterRegistry.antallLagredeOpplysningerSumPerPeriode(timestamp: Instant, antallReference: AtomicLong) { val zonedDateTime = timestamp.atZone(ZoneId.systemDefault()) gauge( - "paw_antall_lagrede_events_sum_per_tidsperiode", + "paw_antall_lagrede_meldinger_sum_per_tidsperiode", Tags.of( - Tag.of("event", "opplysninger-om-arbeidssoeker"), - Tag.of("minute", "${zonedDateTime.minute}") + Tag.of("meldingstype", "opplysninger-om-arbeidssoeker"), + Tag.of("minutt", "${zonedDateTime.minute}") ), antallReference ) { diff --git a/apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerTopology.kt b/apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerTopology.kt index f11f2749..eba15413 100644 --- a/apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerTopology.kt +++ b/apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerTopology.kt @@ -126,8 +126,8 @@ private fun buildPunctuation(meterRegistry: MeterRegistry): Punctuation meterRegistry.antallLagredeOpplysningerSumPerPeriode(timestamp, antall) } meterRegistry.antallLagredeOpplysningerTotal(antallTotalt) + histogram.forEach { (_, antall) -> meterRegistry.antallLagredeOpplysningerSumPerPeriode(timestamp, antall) } } } } diff --git a/apps/opplysninger-aggregering/src/test/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerKStreamTest.kt b/apps/opplysninger-aggregering/src/test/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerKStreamTest.kt index 7d15dd94..0f2d0d2c 100644 --- a/apps/opplysninger-aggregering/src/test/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerKStreamTest.kt +++ b/apps/opplysninger-aggregering/src/test/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerKStreamTest.kt @@ -53,8 +53,14 @@ class OpplysningerKStreamTest : FreeSpec({ valueAndTimestamp.value().sendtInnAv.utfoertAv.id shouldBe opplysninger.sendtInnAv.utfoertAv.id } - "Skal slette opplysninger etter 60 minutter" { - testDriver.advanceWallClockTime(Duration.ofMinutes(65)) // 60 min++ + "Skal ikke slette opplysninger etter 50 minutter" { + testDriver.advanceWallClockTime(Duration.ofMinutes(50)) + + stateStore.size() shouldBe 1 + } + + "Skal slette opplysninger etter 61 minutter" { + testDriver.advanceWallClockTime(Duration.ofMinutes(11)) stateStore.size() shouldBe 0 }