From 942562d452bc1aa64ea6787702c47286c597a186 Mon Sep 17 00:00:00 2001 From: Ivan Topolnjak Date: Sun, 11 Jun 2017 13:24:44 +0200 Subject: add internal snapshot API that allows keeping state intact --- kamon-core/src/main/scala/kamon/metric/Scaler.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kamon-core/src/main/scala/kamon/metric/Scaler.scala') 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, -- cgit v1.2.3