started working on metrics aggregation using dedicated actors

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()