Skip to content

Commit 36639d7

Browse files
avoldsundkristoiverlingjd
committed
Fiks for dårleg oppløysing i InfluxDb sin timestamp i ms
Oppløysinga i ms er så låg at det er eit problem. Legg til eit "fake" nanosekund for å fikse problemet Co-authored-by: kristoiv <[email protected]> Co-authored-by: erlingjd <[email protected]>
1 parent 59f6ebb commit 36639d7

File tree

1 file changed

+7
-2
lines changed

1 file changed

+7
-2
lines changed

src/main/kotlin/no/nav/hjelpemidler/metrics/SensuMetrics.kt

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,13 +63,13 @@ class SensuMetrics {
6363

6464
private fun registerPoint(measurement: String, fields: Map<String, Any>, tags: Map<String, String>) {
6565
log.info("Posting point to Influx: measurment {} fields {} tags {} ", measurement, fields, tags)
66+
counter = ((counter + 1) % 1000000)
6667
val point = Point.measurement(measurement)
67-
.time(TimeUnit.MILLISECONDS.toNanos(System.currentTimeMillis()), TimeUnit.NANOSECONDS)
68+
.time(TimeUnit.MILLISECONDS.toNanos(System.currentTimeMillis()) + counter, TimeUnit.NANOSECONDS)
6869
.tag(tags)
6970
.tag(DEFAULT_TAGS)
7071
.fields(fields)
7172
.build()
72-
7373
try {
7474
sendEvent(SensuEvent(sensuName, point.lineProtocol()))
7575
} catch (e: Exception) {
@@ -122,5 +122,10 @@ class SensuMetrics {
122122
const val OEBS_MELDING_SF_TYPE_ULIK_VEDTAK_INFOTRYGD = "$SOKNADER.oebs.sfTypeUlikVedtakInfotrygd"
123123
const val OEBS_MELDING_RETT_HJELPEMIDDELTYPE = "$SOKNADER.oebs.rettHjelpemiddeltype"
124124
const val OEBS_MELDING_IRRELEVANT_HJELPEMIDDELTYPE = "$SOKNADER.oebs.irrelevantHjelpemiddeltype"
125+
126+
// For å unngå problem med at to eventar blir logga på samme millisekund til InfluxDb, legg vi til ein aukande
127+
// counter som "fakar" auka oppløysing i nanosekund. Det blir lagt til eit tal modulo 1000000 for at det skal
128+
// bli eit tal mellom 0 og 999999
129+
var counter: Long = 0
125130
}
126131
}

0 commit comments

Comments
 (0)