1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
package kamon.dashboard
import spray.routing.HttpService
import akka.actor._
import spray.routing.directives.LogEntry
import akka.event.Logging
import spray.http.MediaTypes._
import spray.httpx.SprayJsonSupport
import kamon.Kamon
import spray.http.HttpRequest
import akka.actor.OneForOneStrategy
import com.codahale.metrics.{Metric, MetricFilter}
class DashboardServiceActor extends Actor with DashboardService {
def actorRefFactory = context
def receive = runRoute(DashboardRoute)
override def supervisorStrategy: SupervisorStrategy = OneForOneStrategy() { case _ => SupervisorStrategy.Stop }
}
trait DashboardService extends HttpService with StaticResources with DashboardPages with DashboardMetricsApi {
def showPath(req: HttpRequest) = LogEntry(s"Method = ${req.method}, Path = ${req.uri}", Logging.InfoLevel)
val DashboardRoute =
logRequest(showPath _) {
staticResources ~ dashboardPages //~ dashboardMetricsApi
}
}
trait StaticResources extends HttpService {
val staticResources = get { getFromResourceDirectory("web")}
}
trait DashboardPages extends HttpService {
val dashboardPages =
path("") {
respondWithMediaType(`text/html`) {
getFromResource("web/index.html")
}
}
}
trait DashboardMetricsApi extends HttpService with SprayJsonSupport{
/*import scala.collection.JavaConverters._
import kamon.metric.Metrics._
import kamon.dashboard.protocol.DashboardProtocols._
val metricFilter = new MetricFilter() {
def matches(name: String, m:Metric) = {
!name.contains("kamon") && name.contains("Mailbox/PROCESSINGTIME") && !name.contains("UnhandledMessageForwarder") && !name.contains("deadLetterListener") && !name.contains("$DefaultLogger")
}
}
def actorSystemMetrics = actorSystemNames.flatMap(name => actorSystem(name))
.map(system => ActorSystemMetricsHolder(system.actorSystemName, system.dispatchers.map { case(name, metricCollector) => (name -> DispatcherMetricCollectorHolder(name, metricCollector.activeThreadCount.snapshot.median, metricCollector.poolSize.snapshot.median, metricCollector.queueSize.snapshot.median))}.toMap))
val withTotalMessages = (dataHolders: Seq[TimerDataHolder]) => {
val numberOfMessages = dataHolders.map(_.count).sum
new TotalMessages(numberOfMessages, dataHolders.size, dataHolders)
}
def timerMetrics = registry.getTimers(metricFilter).asScala.map{ case(name, timer) => TimerDataHolder(name, timer.getMeanRate, timer.getSnapshot.get99thPercentile)}.toVector
val dashboardMetricsApi =
pathPrefix("metrics") {
path("dispatchers") {
get {
complete (actorSystemMetrics)
}
} ~
path("messages") {
get {
complete (withTotalMessages(timerMetrics))
}
} ~
path("actorTree") {
get {
complete (ActorTree("/", ActorTree("Pang", ActorTree("Pang-children") :: Nil) :: ActorTree("Ping") :: ActorTree("Pong", ActorTree("Pong-children") :: Nil):: Nil))
}
}
}*/
}
|
