diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2017-12-05 02:11:34 +0100 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2017-12-05 02:11:34 +0100 |
commit | 6b196b2626f618e452a25e9437c944ff4138636c (patch) | |
tree | 8f9dc1691055512e959afd4d238d01c94a63da56 /kamon-core/src/main/scala/kamon/metric/MetricRegistry.scala | |
parent | b330bc51e1969b1e2284b120a47283d3dd0d8977 (diff) | |
download | Kamon-6b196b2626f618e452a25e9437c944ff4138636c.tar.gz Kamon-6b196b2626f618e452a25e9437c944ff4138636c.tar.bz2 Kamon-6b196b2626f618e452a25e9437c944ff4138636c.zip |
rename MinMaxCounter to RangeSampler
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/MetricRegistry.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/metric/MetricRegistry.scala | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/MetricRegistry.scala b/kamon-core/src/main/scala/kamon/metric/MetricRegistry.scala index ebc17834..cc111d95 100644 --- a/kamon-core/src/main/scala/kamon/metric/MetricRegistry.scala +++ b/kamon-core/src/main/scala/kamon/metric/MetricRegistry.scala @@ -50,8 +50,8 @@ class MetricRegistry(initialConfig: Config, scheduler: ScheduledExecutorService) def gauge(name: String, unit: MeasurementUnit): GaugeMetric = lookupMetric(name, unit, InstrumentTypes.Gauge)(new GaugeMetricImpl(name, unit, instrumentFactory)) - def minMaxCounter(name: String, unit: MeasurementUnit, dynamicRange: Option[DynamicRange], sampleInterval: Option[Duration]): MinMaxCounterMetric = - lookupMetric(name, unit, InstrumentTypes.MinMaxCounter)(new MinMaxCounterMetricImpl(name, unit, dynamicRange, sampleInterval, instrumentFactory, scheduler)) + def rangeSampler(name: String, unit: MeasurementUnit, dynamicRange: Option[DynamicRange], sampleInterval: Option[Duration]): RangeSamplerMetric = + lookupMetric(name, unit, InstrumentTypes.RangeSampler)(new RangeSamplerMetricImpl(name, unit, dynamicRange, sampleInterval, instrumentFactory, scheduler)) def timer(name: String, dynamicRange: Option[DynamicRange]): TimerMetric = new TimerMetricImpl(histogram(name, time.nanoseconds, dynamicRange)) @@ -59,21 +59,21 @@ class MetricRegistry(initialConfig: Config, scheduler: ScheduledExecutorService) override def snapshot(): MetricsSnapshot = synchronized { var histograms = Seq.empty[MetricDistribution] - var mmCounters = Seq.empty[MetricDistribution] + var rangeSamplers = Seq.empty[MetricDistribution] var counters = Seq.empty[MetricValue] var gauges = Seq.empty[MetricValue] for(metricEntry <- metrics.values) { metricEntry.instrumentType match { case InstrumentTypes.Histogram => histograms = histograms ++ metricEntry.snapshot().asInstanceOf[Seq[MetricDistribution]] - case InstrumentTypes.MinMaxCounter => mmCounters = mmCounters ++ metricEntry.snapshot().asInstanceOf[Seq[MetricDistribution]] + case InstrumentTypes.RangeSampler => rangeSamplers = rangeSamplers ++ metricEntry.snapshot().asInstanceOf[Seq[MetricDistribution]] case InstrumentTypes.Gauge => gauges = gauges ++ metricEntry.snapshot().asInstanceOf[Seq[MetricValue]] case InstrumentTypes.Counter => counters = counters ++ metricEntry.snapshot().asInstanceOf[Seq[MetricValue]] case other => logger.warn("Unexpected instrument type [{}] found in the registry", other ) } } - MetricsSnapshot(histograms, mmCounters, gauges, counters) + MetricsSnapshot(histograms, rangeSamplers, gauges, counters) } private def lookupMetric[T <: BaseMetric[_, _]](name: String, unit: MeasurementUnit, instrumentType: InstrumentType)(metricBuilder: => T): T = { |