aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/metric/Metric.scala
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2017-12-05 02:11:34 +0100
committerIvan Topolnjak <ivantopo@gmail.com>2017-12-05 02:11:34 +0100
commit6b196b2626f618e452a25e9437c944ff4138636c (patch)
tree8f9dc1691055512e959afd4d238d01c94a63da56 /kamon-core/src/main/scala/kamon/metric/Metric.scala
parentb330bc51e1969b1e2284b120a47283d3dd0d8977 (diff)
downloadKamon-6b196b2626f618e452a25e9437c944ff4138636c.tar.gz
Kamon-6b196b2626f618e452a25e9437c944ff4138636c.tar.bz2
Kamon-6b196b2626f618e452a25e9437c944ff4138636c.zip
rename MinMaxCounter to RangeSampler
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/Metric.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/metric/Metric.scala28
1 files changed, 14 insertions, 14 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/Metric.scala b/kamon-core/src/main/scala/kamon/metric/Metric.scala
index db5ff9c0..f63e3d07 100644
--- a/kamon-core/src/main/scala/kamon/metric/Metric.scala
+++ b/kamon-core/src/main/scala/kamon/metric/Metric.scala
@@ -46,7 +46,7 @@ trait Metric[T] {
trait HistogramMetric extends Metric[Histogram] with Histogram
trait TimerMetric extends Metric[Timer] with Timer
-trait MinMaxCounterMetric extends Metric[MinMaxCounter] with MinMaxCounter
+trait RangeSamplerMetric extends Metric[RangeSampler] with RangeSampler
trait GaugeMetric extends Metric[Gauge] with Gauge
trait CounterMetric extends Metric[Counter] with Counter
@@ -110,11 +110,11 @@ private[kamon] final class HistogramMetricImpl(val name: String, val unit: Measu
instrument.asInstanceOf[AtomicHdrHistogram].snapshot(resetState = true)
}
-private[kamon] final class MinMaxCounterMetricImpl(val name: String, val unit: MeasurementUnit, customDynamicRange: Option[DynamicRange],
+private[kamon] final class RangeSamplerMetricImpl(val name: String, val unit: MeasurementUnit, customDynamicRange: Option[DynamicRange],
customSampleInterval: Option[Duration], factory: AtomicReference[InstrumentFactory], scheduler: ScheduledExecutorService)
- extends BaseMetric[MinMaxCounter, MetricDistribution](MinMaxCounter) with MinMaxCounterMetric {
+ extends BaseMetric[RangeSampler, MetricDistribution](RangeSampler) with RangeSamplerMetric {
- private val logger = LoggerFactory.getLogger(classOf[MinMaxCounterMetric])
+ private val logger = LoggerFactory.getLogger(classOf[RangeSamplerMetric])
private val scheduledSamplers = TrieMap.empty[Tags, ScheduledFuture[_]]
def dynamicRange: DynamicRange =
@@ -138,13 +138,13 @@ private[kamon] final class MinMaxCounterMetricImpl(val name: String, val unit: M
override def sample(): Unit =
baseInstrument.sample()
- override protected def createInstrument(tags: Tags): MinMaxCounter = {
- val mmCounter = factory.get().buildMinMaxCounter(customDynamicRange, customSampleInterval)(name, tags, unit)
- val sampleInterval = mmCounter.sampleInterval.toMillis
- val scheduledFuture = scheduler.scheduleAtFixedRate(scheduledSampler(mmCounter), sampleInterval, sampleInterval, TimeUnit.MILLISECONDS)
+ override protected def createInstrument(tags: Tags): RangeSampler = {
+ val rangeSampler = factory.get().buildRangeSampler(customDynamicRange, customSampleInterval)(name, tags, unit)
+ val sampleInterval = rangeSampler.sampleInterval.toMillis
+ val scheduledFuture = scheduler.scheduleAtFixedRate(scheduledSampler(rangeSampler), sampleInterval, sampleInterval, TimeUnit.MILLISECONDS)
scheduledSamplers.put(tags, scheduledFuture)
- mmCounter
+ rangeSampler
}
override def remove(tags: JTags): Boolean =
@@ -163,17 +163,17 @@ private[kamon] final class MinMaxCounterMetricImpl(val name: String, val unit: M
val removed = super.remove(tags)
if(removed)
scheduledSamplers.get(tags).foreach(sf => {
- Try(sf.cancel(false)).failed.foreach(_ => logger.error("Failed to cancel scheduled sampling for MinMaxCounter []", tags.prettyPrint()))
+ Try(sf.cancel(false)).failed.foreach(_ => logger.error("Failed to cancel scheduled sampling for RangeSampler []", tags.prettyPrint()))
})
removed
}
- override protected def createSnapshot(instrument: MinMaxCounter): MetricDistribution =
- instrument.asInstanceOf[SimpleMinMaxCounter].snapshot(resetState = true)
+ override protected def createSnapshot(instrument: RangeSampler): MetricDistribution =
+ instrument.asInstanceOf[SimpleRangeSampler].snapshot(resetState = true)
- private def scheduledSampler(mmCounter: MinMaxCounter): Runnable = new Runnable {
- override def run(): Unit = mmCounter.sample()
+ private def scheduledSampler(rangeSampler: RangeSampler): Runnable = new Runnable {
+ override def run(): Unit = rangeSampler.sample()
}
}