From 3f862e604473b098689eb68b568e0e678aa5dcc3 Mon Sep 17 00:00:00 2001 From: Ivan Topolnak Date: Wed, 29 Jan 2014 13:20:11 -0300 Subject: max, min and merge operations for MetricSnapshot --- .../scala/kamon/metrics/MetricsExtension.scala | 50 ---------------------- 1 file changed, 50 deletions(-) (limited to 'kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala') diff --git a/kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala b/kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala index 11e3ebfc..4d7ff354 100644 --- a/kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala +++ b/kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala @@ -22,61 +22,11 @@ import com.typesafe.config.Config import kamon.util.GlobPathFilter import kamon.Kamon import akka.actor -import kamon.metrics.Metrics.MetricGroupFilter import kamon.metrics.MetricGroupIdentity.Category import kamon.metrics.Metrics.MetricGroupFilter import scala.Some import kamon.metrics.Subscriptions.Subscribe -case class MetricGroupIdentity(name: String, category: MetricGroupIdentity.Category) - -trait MetricIdentity { - def name: String -} - -trait MetricGroupRecorder { - def record(identity: MetricIdentity, value: Long) - def collect: MetricGroupSnapshot -} - -trait MetricGroupSnapshot { - def metrics: Map[MetricIdentity, MetricSnapshot] -} - -trait MetricRecorder { - def record(value: Long) - def collect(): MetricSnapshot -} - -trait MetricSnapshot { - def numberOfMeasurements: Long - def measurementLevels: Vector[MetricSnapshot.Measurement] -} - -object MetricSnapshot { - case class Measurement(value: Long, count: Long) -} - -case class DefaultMetricSnapshot(numberOfMeasurements: Long, measurementLevels: Vector[MetricSnapshot.Measurement]) extends MetricSnapshot - -object MetricGroupIdentity { - trait Category { - def name: String - } - - val AnyCategory = new Category { - def name: String = "match-all" - override def equals(that: Any): Boolean = that.isInstanceOf[Category] - } -} - -trait MetricGroupFactory { - type Group <: MetricGroupRecorder - def create(config: Config): Group -} - - - class MetricsExtension(val system: ExtendedActorSystem) extends Kamon.Extension { val config = system.settings.config val storage = TrieMap[MetricGroupIdentity, MetricGroupRecorder]() -- cgit v1.2.3