diff options
| author | Ivan Topolnjak <ivantopo@gmail.com> | 2017-06-11 13:24:44 +0200 |
|---|---|---|
| committer | Ivan Topolnjak <ivantopo@gmail.com> | 2017-06-11 13:24:44 +0200 |
| commit | 942562d452bc1aa64ea6787702c47286c597a186 (patch) | |
| tree | 437168af59d1169b00e9c269cb43db1e487c8faa /kamon-core/src/main/scala/kamon/metric/Accumulator.scala | |
| parent | a78ce66cbe149ec7f71b7912e9f7df427688aa15 (diff) | |
| download | Kamon-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/Accumulator.scala')
| -rw-r--r-- | kamon-core/src/main/scala/kamon/metric/Accumulator.scala | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/Accumulator.scala b/kamon-core/src/main/scala/kamon/metric/Accumulator.scala index d960565f..9017c14e 100644 --- a/kamon-core/src/main/scala/kamon/metric/Accumulator.scala +++ b/kamon-core/src/main/scala/kamon/metric/Accumulator.scala @@ -22,11 +22,9 @@ class DistributionAccumulator(dynamicRange: DynamicRange) { private val accumulatorHistogram = new HdrHistogram("metric-distribution-accumulator", tags = Map.empty, unit = MeasurementUnit.none, dynamicRange) - - def add(distribution: Distribution): Unit = { + def add(distribution: Distribution): Unit = distribution.bucketsIterator.foreach(b => accumulatorHistogram.record(b.value, b.frequency)) - } - def result(): Distribution = - accumulatorHistogram.snapshot().distribution + def result(resetState: Boolean): Distribution = + accumulatorHistogram.snapshot(resetState).distribution } |