Merge pull request #1 from ChristopherDavenport/fixNanosCalc

davenverse · Apr 22, 2020 · 1868078 · 1868078
2 parents 5082032 + c1315a3
commit 1868078
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/core/src/main/scala/io/chrisdavenport/epimetheus/redis4cats/RedisMetricOps.scala b/core/src/main/scala/io/chrisdavenport/epimetheus/redis4cats/RedisMetricOps.scala
@@ -106,8 +106,15 @@ object RedisMetricOps {
 
     def recordTotalTime(terminationType: TerminationType, elapsed: Long, classifier: Option[String]): F[Unit] = {
       metricsCollection.operations.label((terminationType, Classifier.opt(classifier)))
-        .observe(elapsed.toDouble)
+        .observe(nanosToSeconds(elapsed))
     }
   }
 
+
+  // Elapsed is in Nanos, but buckets are in Seconds
+  private def nanosToSeconds(l: Long): Double = 
+    l / nanoseconds_per_second
+  private val nanoseconds_per_second = 1E9
+
+
 }