diff options
author | Ivan Topolnak <ivantopo@gmail.com> | 2013-11-04 18:11:16 -0300 |
---|---|---|
committer | Ivan Topolnak <ivantopo@gmail.com> | 2013-11-04 18:11:16 -0300 |
commit | 84711adba09c64b75369f8b801819a90198238c6 (patch) | |
tree | 1e6193bf3248e82a85c1091110ba3b81d3f34036 /kamon-core/src/main/scala/kamon/trace/UowTracing.scala | |
parent | 227c2dfe6cb8b7e175ad72285dfdfbd15672be24 (diff) | |
download | Kamon-84711adba09c64b75369f8b801819a90198238c6.tar.gz Kamon-84711adba09c64b75369f8b801819a90198238c6.tar.bz2 Kamon-84711adba09c64b75369f8b801819a90198238c6.zip |
wip
Diffstat (limited to 'kamon-core/src/main/scala/kamon/trace/UowTracing.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/trace/UowTracing.scala | 57 |
1 files changed, 0 insertions, 57 deletions
diff --git a/kamon-core/src/main/scala/kamon/trace/UowTracing.scala b/kamon-core/src/main/scala/kamon/trace/UowTracing.scala deleted file mode 100644 index b09478cc..00000000 --- a/kamon-core/src/main/scala/kamon/trace/UowTracing.scala +++ /dev/null @@ -1,57 +0,0 @@ -package kamon.trace - -import akka.actor._ -import scala.concurrent.duration.Duration -import kamon.trace.UowTracing._ - -sealed trait UowSegment { - def timestamp: Long -} - -trait AutoTimestamp extends UowSegment { - val timestamp = System.nanoTime -} - -object UowTracing { - case class Start() extends AutoTimestamp - case class Finish() extends AutoTimestamp - case class Rename(name: String) extends AutoTimestamp - case class WebExternalStart(id: Long, host: String) extends AutoTimestamp - case class WebExternalFinish(id: Long) extends AutoTimestamp - case class WebExternal(start: Long, finish: Long, host: String) extends AutoTimestamp -} - -case class UowTrace(name: String, segments: Seq[UowSegment]) - - -class UowTraceAggregator(reporting: ActorRef, aggregationTimeout: Duration) extends Actor with ActorLogging { - context.setReceiveTimeout(aggregationTimeout) - - var name: Option[String] = None - var segments: Seq[UowSegment] = Nil - - var pendingExternal = List[WebExternalStart]() - - def receive = { - case finish: Finish => segments = segments :+ finish; finishTracing() - case wes: WebExternalStart => pendingExternal = pendingExternal :+ wes - case finish @ WebExternalFinish(id) => pendingExternal.find(_.id == id).map(start => { - segments = segments :+ WebExternal(start.timestamp, finish.timestamp, start.host) - }) - case Rename(newName) => name = Some(newName) - case segment: UowSegment => segments = segments :+ segment - case ReceiveTimeout => - log.warning("Transaction {} did not complete properly, the recorded segments are: {}", name, segments) - context.stop(self) - } - - def finishTracing(): Unit = { - reporting ! UowTrace(name.getOrElse("UNKNOWN"), segments) - println("Recorded Segments: " + segments) - context.stop(self) - } -} - -object UowTraceAggregator { - def props(reporting: ActorRef, aggregationTimeout: Duration) = Props(classOf[UowTraceAggregator], reporting, aggregationTimeout) -}
\ No newline at end of file |