aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala19
1 files changed, 17 insertions, 2 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala b/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala
index dc9a4bbf..77cb503b 100644
--- a/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala
+++ b/kamon-core/src/main/scala/kamon/metric/instrument/Histogram.scala
@@ -20,6 +20,7 @@ import java.nio.LongBuffer
import kamon.metric.instrument.Histogram.{ DynamicRange, Snapshot }
import org.HdrHistogram.ModifiedAtomicHistogram
+import org.slf4j.LoggerFactory
trait Histogram extends Instrument {
type SnapshotType = Histogram.Snapshot
@@ -135,6 +136,10 @@ object Histogram {
}
}
+object HdrHistogram {
+ private val log = LoggerFactory.getLogger(classOf[HdrHistogram])
+}
+
/**
* This implementation is meant to be used for real time data collection where data snapshots are taken often over time.
* The collect(..) operation extracts all the recorded values from the histogram and resets the counts, but still
@@ -142,10 +147,20 @@ object Histogram {
*/
class HdrHistogram(dynamicRange: DynamicRange) extends ModifiedAtomicHistogram(dynamicRange.lowestDiscernibleValue,
dynamicRange.highestTrackableValue, dynamicRange.precision) with Histogram {
+ import HdrHistogram.log
+
+ def record(value: Long): Unit = tryRecord(value, 1L)
- def record(value: Long): Unit = recordValue(value)
+ def record(value: Long, count: Long): Unit = tryRecord(value, count)
- def record(value: Long, count: Long): Unit = recordValueWithCount(value, count)
+ private def tryRecord(value: Long, count: Long): Unit = {
+ try {
+ recordValueWithCount(value, count)
+ } catch {
+ case anyException: Throwable ⇒
+ log.warn("Failed to store value {} in HdrHistogram, please review your range configuration.")
+ }
+ }
def collect(context: CollectionContext): Histogram.Snapshot = {
import context.buffer