diff options
author | Ivan Topolnak <ivantopo@gmail.com> | 2013-10-10 18:52:09 -0300 |
---|---|---|
committer | Ivan Topolnak <ivantopo@gmail.com> | 2013-10-10 18:52:09 -0300 |
commit | e148933747e8fde17b6ac324df0dee70b8cb9ebc (patch) | |
tree | 6cd084809e8184c74052bcb4201adb3f8e5e4004 /kamon-core/src/main/scala/kamon/newrelic | |
parent | dbac9011999384a57c0ecc2c9ab5c49870cdce45 (diff) | |
download | Kamon-e148933747e8fde17b6ac324df0dee70b8cb9ebc.tar.gz Kamon-e148933747e8fde17b6ac324df0dee70b8cb9ebc.tar.bz2 Kamon-e148933747e8fde17b6ac324df0dee70b8cb9ebc.zip |
complete spray client instrumentation with experimental branch
Diffstat (limited to 'kamon-core/src/main/scala/kamon/newrelic')
-rw-r--r-- | kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala | 23 |
1 files changed, 16 insertions, 7 deletions
diff --git a/kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala b/kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala index 31e50cfe..6629e164 100644 --- a/kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala +++ b/kamon-core/src/main/scala/kamon/newrelic/NewRelicReporting.scala @@ -2,8 +2,9 @@ package kamon.newrelic import akka.actor.Actor import kamon.trace.UowTrace -import com.newrelic.api.agent.{Trace, NewRelic} -import kamon.trace.UowTracing.WebExternal +import com.newrelic.api.agent.{Response, Request, Trace, NewRelic} +import kamon.trace.UowTracing.{WebExternal, WebExternalFinish, WebExternalStart} +import java.util class NewRelicReporting extends Actor { @@ -11,7 +12,6 @@ class NewRelicReporting extends Actor { case trace: UowTrace => recordTransaction(trace) } - //@Trace def recordTransaction(uowTrace: UowTrace): Unit = { val time = ((uowTrace.segments.last.timestamp - uowTrace.segments.head.timestamp)/1E9) @@ -20,16 +20,25 @@ class NewRelicReporting extends Actor { NewRelic.recordMetric("HttpDispatcher", time.toFloat) uowTrace.segments.collect { case we: WebExternal => we }.foreach { webExternalTrace => - val external = ((webExternalTrace.end - webExternalTrace.start)/1E9).toFloat - NewRelic.recordMetric(s"External/all", external) - NewRelic.recordMetric(s"External/allWeb", external) + val external = ((webExternalTrace.finish - webExternalTrace.start)/1E9).toFloat 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) + 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(segments: Seq[WebExternal]): Long = { } + + NewRelic.recordMetric(s"External/all", external) + NewRelic.recordMetric(s"External/allWeb", external)*/ + } } |