aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala
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
commit2b63540e5fffab545d0846cfb3dab5c0e1d0c9e1 (patch)
tree56c4ad1f025c9144376cd4463ad4d4a23e37b571 /kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala
parent5127c3bb83cd6fe90e071720d995cfb53d913e6a (diff)
downloadKamon-2b63540e5fffab545d0846cfb3dab5c0e1d0c9e1.tar.gz
Kamon-2b63540e5fffab545d0846cfb3dab5c0e1d0c9e1.tar.bz2
Kamon-2b63540e5fffab545d0846cfb3dab5c0e1d0c9e1.zip
basic separation of concerns between sub-projects
Diffstat (limited to 'kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala52
1 files changed, 0 insertions, 52 deletions
diff --git a/kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala b/kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala
deleted file mode 100644
index 106f27e2..00000000
--- a/kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala
+++ /dev/null
@@ -1,52 +0,0 @@
-package kamon.newrelic
-
-import akka.actor.Actor
-import kamon.trace.UowTrace
-import com.newrelic.api.agent.{Response, Request, Trace, NewRelic}
-import kamon.trace.UowTracing.{WebExternal, WebExternalFinish, WebExternalStart}
-import java.util
-import java.util.Date
-
-
-class NewRelicReporting extends Actor {
- def receive = {
- case trace: UowTrace => recordTransaction(trace)
- }
-
- def recordTransaction(uowTrace: UowTrace): Unit = {
- val time = ((uowTrace.segments.last.timestamp - uowTrace.segments.head.timestamp)/1E9)
-
- NewRelic.recordMetric("WebTransaction/Custom" + uowTrace.name, time.toFloat )
- NewRelic.recordMetric("WebTransaction", time.toFloat)
- NewRelic.recordMetric("HttpDispatcher", time.toFloat)
-
- uowTrace.segments.collect { case we: WebExternal => we }.foreach { webExternalTrace =>
- val external = ((webExternalTrace.finish - webExternalTrace.start)/1E9).toFloat
-
- println("Web External: " + webExternalTrace)
- NewRelic.recordMetric(s"External/${webExternalTrace.host}/http", external)
- NewRelic.recordMetric(s"External/${webExternalTrace.host}/all", external)
- NewRelic.recordMetric(s"External/${webExternalTrace.host}/http/WebTransaction/Custom" + uowTrace.name, external)
- }
-
-
- val allExternals = uowTrace.segments.collect { case we: WebExternal => we } sortBy(_.timestamp)
-
-
- def measureExternal(accum: Long, lastEnd: Long, segments: Seq[WebExternal]): Long = segments match {
- case Nil => accum
- case head :: tail =>
- if(head.start > lastEnd)
- measureExternal(accum + (head.finish-head.start), head.finish, tail)
- else
- measureExternal(accum + (head.finish-lastEnd), head.finish, tail)
- }
-
- val external = measureExternal(0, 0, allExternals) / 1E9
-
-
- NewRelic.recordMetric(s"External/all", external.toFloat)
- NewRelic.recordMetric(s"External/allWeb", external.toFloat)
-
- }
-}