aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/metric
diff options
context:
space:
mode:
authorIvan Topolnak <ivantopo@gmail.com>2013-11-05 18:38:39 -0300
committerIvan Topolnak <ivantopo@gmail.com>2013-11-05 18:38:39 -0300
commit26003feac484c971abf7639dc3adb628c5f118c3 (patch)
treec22effcf90aea23af6ce23beff4735c7de59131a /kamon-core/src/main/scala/kamon/metric
parent84711adba09c64b75369f8b801819a90198238c6 (diff)
downloadKamon-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.scala51
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