src/main/scala/kamon/Aggregator.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
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()