fjern Influx, som skal utfases i Nav

Author: olesls

.nais/nais-dev.yaml

@@ -11,7 +11,6 @@ spec:
   ingresses:
     - https://hm-soknadsbehandling-db.intern.dev.nav.no
   envFrom:
-    - secret: hm-influxdb-secret
     - secret: hm-slack-hook
   kafka:
     pool: nav-dev

.nais/nais-prod.yaml

@@ -9,7 +9,6 @@ metadata:
 spec:
   image: {{ image }}
   envFrom:
-    - secret: hm-influxdb-secret
     - secret: hm-slack-hook
   kafka:
     pool: nav-prod

app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/metrics/BigQueryClient.kt

@@ -0,0 +1,24 @@
+package no.nav.hjelpemidler.soknad.db.metrics
+
+import io.github.oshai.kotlinlogging.KotlinLogging
+import no.nav.hjelpemidler.behovsmeldingsmodell.BehovsmeldingStatus
+import no.nav.hjelpemidler.soknad.db.metrics.kafka.KafkaClient
+import no.nav.hjelpemidler.soknad.db.metrics.kafka.createKafkaClient
+
+private val logg = KotlinLogging.logger {}
+
+class BigQueryClient {
+    private val kafkaClient: KafkaClient = createKafkaClient()
+
+    private fun writeEvent(measurement: String, fields: Map<String, Any>, tags: Map<String, String>) {
+        kafkaClient.hendelseOpprettet(measurement, fields, tags)
+    }
+
+    fun registerElapsedTime(metricFieldName: String, tid: Long) {
+        writeEvent(metricFieldName, mapOf("elapsed_ms" to tid), emptyMap())
+    }
+
+    fun registerStatusCounts(metricFieldName: String, antallByStatus: Map<BehovsmeldingStatus, Int>) {
+        writeEvent(metricFieldName, antallByStatus.mapKeys { it.key.toString() }, emptyMap())
+    }
+}

app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/metrics/InfluxDB.kt

@@ -21,7 +21,7 @@ private val logg = KotlinLogging.logger {}
 
 class Metrics(
     private val transaction: Transaction,
-    private val influxDB: InfluxDB = InfluxDB(),
+    private val bigQuery: BigQueryClient = BigQueryClient(),
 ) {
     init {
         Timer("metrics", true).schedule(
@@ -116,7 +116,7 @@ class Metrics(
                         metricFieldName.plus("-papir")
                     }
 
-                influxDB.registerElapsedTime(finalMetricFieldName, timeDifference)
+                bigQuery.registerElapsedTime(finalMetricFieldName, timeDifference)
             }
         } catch (e: Exception) {
             logg.error(e) { "Feil ved sending av tid mellom status-metrikker" }
@@ -127,7 +127,7 @@ class Metrics(
         try {
             val antallByStatus = transaction { søknadStore.tellStatuser() }
             if (antallByStatus.isNotEmpty()) {
-                influxDB.registerStatusCounts(COUNT_OF_SOKNAD_BY_STATUS, antallByStatus)
+                bigQuery.registerStatusCounts(COUNT_OF_SOKNAD_BY_STATUS, antallByStatus)
             }
         } catch (e: Exception) {
             logg.error(e) { "Feil ved sending antall per status metrikker." }

app/src/main/kotlin/no/nav/hjelpemidler/soknad/db/metrics/Metrics.kt

@@ -14,9 +14,3 @@ HM_ROLLER_URL = http://hm-roller
 HM_ROLLER_AUDIENCE = hm-soknadsbehandling-db
 
 BIGQUERY_DATASET_ID = hm_soknadsbehandling_v1_dataset_dev_local
-
-INFLUX_HOST = http://localhost
-INFLUX_PORT = 9900
-INFLUX_DATABASE_NAME = test
-INFLUX_USER = test
-INFLUX_PASSWORD = test