Endret metrics navn og consumer group

Author: naviktthomas

apps/opplysninger-aggregering/README.md

@@ -1,2 +1,4 @@
 # PAW Arbeidssoeker Opplysninger Aggregering
 
+## Testbruker
+28908398892 FORNØYD BLEKK Tyskland

apps/opplysninger-aggregering/nais/nais-dev.yaml

@@ -10,7 +10,7 @@ spec:
   port: 8080
   env:
     - name: KAFKA_OPPLYSNINGER_OM_ARBEIDSSOEKER_STREAM_ID_SUFFIX
-      value: "opplysninger-stream-v1"
+      value: "opplysninger-stream-v2"
     - name: KAFKA_PAW_OPPLYSNINGER_OM_ARBEIDSSOEKER_TOPIC
       value: "paw.opplysninger-om-arbeidssoeker-v1"
     - name: OPPLYSNINGER_PUNCTUATOR_SCHEDULE

apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/config/Metrics.kt

@@ -7,18 +7,21 @@ import java.time.Instant
 import java.time.ZoneId
 import java.util.concurrent.atomic.AtomicLong
 
-private const val METRIC_PREFIX = "paw_arbeidssoeker_opplysninger_aggregering"
-
 fun MeterRegistry.tellMottatteOpplysninger() {
     counter(
-        "${METRIC_PREFIX}_antall_mottatte_opplysninger_total",
+        "paw_antall_mottatte_events_total",
+        Tags.of(
+            Tag.of("event", "opplysninger-om-arbeidssoeker")
+        )
     ).increment()
 }
 
 fun MeterRegistry.antallLagredeOpplysningerTotal(antallReference: AtomicLong) {
     gauge(
-        "${METRIC_PREFIX}_antall_lagrede_opplysninger_total",
-        Tags.empty(),
+        "paw_antall_lagrede_events",
+        Tags.of(
+            Tag.of("event", "opplysninger-om-arbeidssoeker")
+        ),
         antallReference
     ) {
         antallReference.get().toDouble()
@@ -28,8 +31,9 @@ fun MeterRegistry.antallLagredeOpplysningerTotal(antallReference: AtomicLong) {
 fun MeterRegistry.antallLagredeOpplysningerSumPerPeriode(timestamp: Instant, antallReference: AtomicLong) {
     val zonedDateTime = timestamp.atZone(ZoneId.systemDefault())
     gauge(
-        "${METRIC_PREFIX}_antall_lagrede_opplysninger_sum_per_periode",
+        "paw_antall_lagrede_events_sum_per_tidsperiode",
         Tags.of(
+            Tag.of("event", "opplysninger-om-arbeidssoeker"),
             Tag.of("minute", "${zonedDateTime.minute}")
         ),
         antallReference

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

@@ -30,7 +30,7 @@ fun buildOpplysningerTopology(
 
 context(ApplicationContext)
 private fun StreamsBuilder.addOpplysningerStateStore() {
-    logger.info("Oppretter state store for opplysninger om arbeidssøker")
+    logger.info("Oppretter State Store for opplysninger om arbeidssøker")
     val kafkaProperties = properties.kafka
     val kafkaStreamsProperties = properties.kafkaStreams
 
@@ -123,17 +123,21 @@ private fun buildPunctuation(meterRegistry: MeterRegistry): Punctuation<Long, Op
                     )
                 }
 
-                val antall = histogram[opplysninger.periodeId]
-                if (antall != null) {
-                    antall.incrementAndGet()
-                    histogram[opplysninger.periodeId] = antall
-                } else {
-                    histogram[opplysninger.periodeId] = AtomicLong(1)
-                }
+                histogram.tellAntall(opplysninger.periodeId)
             }
 
             histogram.forEach { (_, antall) -> meterRegistry.antallLagredeOpplysningerSumPerPeriode(timestamp, antall) }
             meterRegistry.antallLagredeOpplysningerTotal(antallTotalt)
         }
     }
 }
+
+private fun MutableMap<UUID, AtomicLong>.tellAntall(key: UUID) {
+    val antall = get(key)
+    if (antall != null) {
+        antall.incrementAndGet()
+        put(key, antall)
+    } else {
+        put(key, AtomicLong(1))
+    }
+}