diff options
author | Ivan Topolnak <ivantopo@gmail.com> | 2013-05-21 18:31:50 -0300 |
---|---|---|
committer | Ivan Topolnak <ivantopo@gmail.com> | 2013-05-21 18:31:50 -0300 |
commit | c56018c9a3bef9e99cc38f1804eafdfe5c8be45c (patch) | |
tree | e6a9c4fc5a3fb81b2f5eaa6b554c52f87425bebe /src/main/scala/kamon | |
parent | fa11dbb9448e002de4863fd67924946b7157913d (diff) | |
download | Kamon-c56018c9a3bef9e99cc38f1804eafdfe5c8be45c.tar.gz Kamon-c56018c9a3bef9e99cc38f1804eafdfe5c8be45c.tar.bz2 Kamon-c56018c9a3bef9e99cc38f1804eafdfe5c8be45c.zip |
started working on metrics aggregation using dedicated actors
Diffstat (limited to 'src/main/scala/kamon')
-rw-r--r-- | src/main/scala/kamon/Aggregator.scala | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/src/main/scala/kamon/Aggregator.scala b/src/main/scala/kamon/Aggregator.scala new file mode 100644 index 00000000..441178df --- /dev/null +++ b/src/main/scala/kamon/Aggregator.scala @@ -0,0 +1,18 @@ +package kamon + +import akka.actor.Actor +import scala.collection.mutable + +class Aggregator extends Actor { + + val parts = mutable.LinkedList[TraceEntry]() + + def receive = { + case ContextPart(ctx) => println("registering context information") + case FinishAggregation() => println("report to newrelic") + } + +} + +case class ContextPart(context: TraceContext) +case class FinishAggregation() |