diff options
author | Ivan Topolnak <itopolnak@despegar.com> | 2014-03-07 18:08:01 -0300 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2014-03-11 21:14:53 -0300 |
commit | b6af84ab6b60b4ca6c0389c8c3622db3d3c27915 (patch) | |
tree | 1f89896820e36d59daadef7699b434de1051be42 /kamon-newrelic/src/main/scala/kamon/newrelic/package.scala | |
parent | ccbcc55282251b5e6d4f41384730232a8f0e7d05 (diff) | |
download | Kamon-b6af84ab6b60b4ca6c0389c8c3622db3d3c27915.tar.gz Kamon-b6af84ab6b60b4ca6c0389c8c3622db3d3c27915.tar.bz2 Kamon-b6af84ab6b60b4ca6c0389c8c3622db3d3c27915.zip |
multiple fixes to the custom metrics collection facilities
Diffstat (limited to 'kamon-newrelic/src/main/scala/kamon/newrelic/package.scala')
-rw-r--r-- | kamon-newrelic/src/main/scala/kamon/newrelic/package.scala | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/kamon-newrelic/src/main/scala/kamon/newrelic/package.scala b/kamon-newrelic/src/main/scala/kamon/newrelic/package.scala index 76b40748..06059c49 100644 --- a/kamon-newrelic/src/main/scala/kamon/newrelic/package.scala +++ b/kamon-newrelic/src/main/scala/kamon/newrelic/package.scala @@ -16,27 +16,27 @@ package kamon -import kamon.metrics.MetricSnapshot +import kamon.metrics.{ Scale, MetricSnapshotLike } package object newrelic { - def toNewRelicMetric(name: String, scope: Option[String], snapshot: MetricSnapshot): NewRelic.Metric = { + def toNewRelicMetric(scale: Scale)(name: String, scope: Option[String], snapshot: MetricSnapshotLike): NewRelic.Metric = { var total: Double = 0D var sumOfSquares: Double = 0D - val measurementLevels = snapshot.measurementLevels.iterator + val measurementLevels = snapshot.measurements.iterator while (measurementLevels.hasNext) { val level = measurementLevels.next() // NewRelic metrics need to be scaled to seconds. - val scaledValue = level.value / 1E9D + val scaledValue = Scale.convert(snapshot.scale, scale, level.value) total += scaledValue sumOfSquares += scaledValue * scaledValue } - val scaledMin = snapshot.min / 1E9D - val scaledMax = snapshot.max / 1E9D + val scaledMin = Scale.convert(snapshot.scale, scale, snapshot.min) + val scaledMax = Scale.convert(snapshot.scale, scale, snapshot.max) NewRelic.Metric(name, scope, snapshot.numberOfMeasurements, total, total, scaledMin, scaledMax, sumOfSquares) } |