Rename metrics

Author: naviktthomas

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
     ) {

apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/topology/OpplysningerTopology.kt

@@ -126,8 +126,8 @@ private fun buildPunctuation(meterRegistry: MeterRegistry): Punctuation<Long, Op
                 histogram.tellAntall(opplysninger.periodeId)
             }
 
-            histogram.forEach { (_, antall) -> meterRegistry.antallLagredeOpplysningerSumPerPeriode(timestamp, antall) }
             meterRegistry.antallLagredeOpplysningerTotal(antallTotalt)
+            histogram.forEach { (_, antall) -> meterRegistry.antallLagredeOpplysningerSumPerPeriode(timestamp, antall) }
         }
     }
 }

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
             }