blob: 441178dfcb5194462d350e472515d22e8b67fb13 (
plain) (
blame)
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()
|