Skriv til en bestemt retention policy.

navikt · May 12, 2021 · ed94b0d · ed94b0d
1 parent 08fd3b6
commit ed94b0d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...luxdb/src/main/kotlin/no/nav/personbruker/dittnav/common/metrics/influx/DataPointRelay.kt b/...luxdb/src/main/kotlin/no/nav/personbruker/dittnav/common/metrics/influx/DataPointRelay.kt
@@ -21,6 +21,7 @@ internal class DataPointRelay(private val influxDB: InfluxDB) {
 }
 
 internal object DataPointRelayFactory {
+
     internal fun createDataPointRelay(influxConfig: InfluxConfig): DataPointRelay {
         val influxDb = InfluxDBFactory.connect(
             "https://${influxConfig.hostName}:${influxConfig.hostPort}",
@@ -30,6 +31,8 @@ internal object DataPointRelayFactory {
 
         influxDb.setDatabase(influxConfig.databaseName)
 
+        influxDb.setRetentionPolicy(influxConfig.retentionPolicyName)
+
         if (influxConfig.enableEventBatching) {
             influxDb.enableBatch()
         } else {

diff --git a/...nfluxdb/src/main/kotlin/no/nav/personbruker/dittnav/common/metrics/influx/InfluxConfig.kt b/...nfluxdb/src/main/kotlin/no/nav/personbruker/dittnav/common/metrics/influx/InfluxConfig.kt
@@ -6,6 +6,7 @@ data class InfluxConfig (
     val password: String,
     val hostPort: Int,
     val databaseName: String,
+    val retentionPolicyName: String,
     val applicationName: String,
     val clusterName: String,
     val namespace: String,