diff options
author | Ivan Topolnak <ivantopo@gmail.com> | 2013-11-05 18:38:39 -0300 |
---|---|---|
committer | Ivan Topolnak <ivantopo@gmail.com> | 2013-11-05 18:38:39 -0300 |
commit | 26003feac484c971abf7639dc3adb628c5f118c3 (patch) | |
tree | c22effcf90aea23af6ce23beff4735c7de59131a /kamon-core/src/main/scala/kamon/metric | |
parent | 84711adba09c64b75369f8b801819a90198238c6 (diff) | |
download | Kamon-26003feac484c971abf7639dc3adb628c5f118c3.tar.gz Kamon-26003feac484c971abf7639dc3adb628c5f118c3.tar.bz2 Kamon-26003feac484c971abf7639dc3adb628c5f118c3.zip |
basic separation of concerns between sub-projects
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric')
-rw-r--r-- | kamon-core/src/main/scala/kamon/metric/NewRelicReporter.scala | 51 |
1 files changed, 0 insertions, 51 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/NewRelicReporter.scala b/kamon-core/src/main/scala/kamon/metric/NewRelicReporter.scala deleted file mode 100644 index 70f3e54a..00000000 --- a/kamon-core/src/main/scala/kamon/metric/NewRelicReporter.scala +++ /dev/null @@ -1,51 +0,0 @@ -package kamon.metric - -import com.codahale.metrics -import metrics._ -import java.util.concurrent.TimeUnit -import java.util -import com.newrelic.api.agent.NewRelic -import scala.collection.JavaConverters._ - - -class NewRelicReporter(registry: MetricRegistry, name: String,filter: MetricFilter, rateUnit: TimeUnit, durationUnit: TimeUnit) extends ScheduledReporter(registry, name, filter, rateUnit, durationUnit) { - - - - private[NewRelicReporter] def processMeter(name: String, meter: Meter) { - NewRelic.recordMetric("Custom/Actor/MessagesPerSecond", meter.getMeanRate().toFloat) - } - - private[NewRelicReporter] def processCounter(name:String, counter:Counter) { - println(s"Logging to NewRelic: ${counter.getCount}") - - } - - -/* def processGauge(name: String, gauge: Gauge[_]) = { - println(s"the value is: "+gauge.getValue) - NewRelic.recordMetric("Custom/ActorSystem/activeCount", gauge.getValue.asInstanceOf[Float]) - }*/ - - - def report(gauges: util.SortedMap[String, Gauge[_]], counters: util.SortedMap[String, Counter], histograms: util.SortedMap[String, metrics.Histogram], meters: util.SortedMap[String, Meter], timers: util.SortedMap[String, Timer]) { - //Process Meters - meters.asScala.map{case(name, meter) => processMeter(name, meter)} - - //Process Meters - counters.asScala.map{case(name, counter) => processCounter(name, counter)} - - // Gauges - gauges.asScala.foreach{ case (name, gauge) => { - val measure: Float = gauge.getValue.asInstanceOf[Number].floatValue() - val fullMetricName = "Custom" + name - NewRelic.recordMetric(fullMetricName, measure) - }} - } - - -} - -object NewRelicReporter { - def apply(registry: MetricRegistry) = new NewRelicReporter(registry, "NewRelic-reporter", metrics.MetricFilter.ALL, TimeUnit.SECONDS, TimeUnit.MILLISECONDS) -}
\ No newline at end of file |