aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/metric/Scaler.scala
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2017-06-11 13:24:44 +0200
committerIvan Topolnjak <ivantopo@gmail.com>2017-06-11 13:24:44 +0200
commit942562d452bc1aa64ea6787702c47286c597a186 (patch)
tree437168af59d1169b00e9c269cb43db1e487c8faa /kamon-core/src/main/scala/kamon/metric/Scaler.scala
parenta78ce66cbe149ec7f71b7912e9f7df427688aa15 (diff)
downloadKamon-942562d452bc1aa64ea6787702c47286c597a186.tar.gz
Kamon-942562d452bc1aa64ea6787702c47286c597a186.tar.bz2
Kamon-942562d452bc1aa64ea6787702c47286c597a186.zip
add internal snapshot API that allows keeping state intact
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/Scaler.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/metric/Scaler.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/Scaler.scala b/kamon-core/src/main/scala/kamon/metric/Scaler.scala
index 8f068fa2..21270e4c 100644
--- a/kamon-core/src/main/scala/kamon/metric/Scaler.scala
+++ b/kamon-core/src/main/scala/kamon/metric/Scaler.scala
@@ -22,7 +22,7 @@ class Scaler(targetTimeUnit: MeasurementUnit, targetInformationUnit: Measurement
require(targetTimeUnit.dimension == Dimension.Time, "timeUnit must be in the time dimension.")
require(targetInformationUnit.dimension == Dimension.Information, "informationUnit must be in the information dimension.")
- val scaleHistogram = new HdrHistogram("scaler", Map.empty, MeasurementUnit.none, dynamicRange)
+ val scaleHistogram = new AtomicHdrHistogram("scaler", Map.empty, MeasurementUnit.none, dynamicRange)
def scaleDistribution(metric: MetricDistribution): MetricDistribution = {
metric.measurementUnit match {
@@ -54,7 +54,7 @@ class Scaler(targetTimeUnit: MeasurementUnit, targetInformationUnit: Measurement
scaleHistogram.record(Math.ceil(scaledValue).toLong, b.frequency)
})
- scaleHistogram.snapshot().copy(
+ scaleHistogram.snapshot(resetState = true).copy(
name = metric.name,
tags = metric.tags,
measurementUnit = targetUnit,