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
90
91
92
93
94
|
package kamon.status
import com.grack.nanojson.JsonWriter
import kamon.module.Module
import kamon.module.Module.Registry
import java.lang.{StringBuilder => JavaStringBuilder}
import com.typesafe.config.ConfigRenderOptions
import kamon.metric.MetricRegistry
trait JsonMarshalling[T] {
/**
* Implementations should append a Json object or array that describes the given instance members and any
* additional information that is expected to be shown in the status mini site.
*/
def toJson(instance: T, builder: JavaStringBuilder): Unit
}
object JsonMarshalling {
implicit object ModuleRegistryStatusJsonMarshalling extends JsonMarshalling[Module.Registry.Status] {
override def toJson(instance: Registry.Status, builder: JavaStringBuilder): Unit = {
val array = JsonWriter.on(builder)
.`object`()
.array("modules")
instance.modules.foreach(m => {
array.`object`()
.value("name", m.name)
.value("description", m.description)
.value("kind", m.kind)
.value("enabled", m.enabled)
.value("started", m.started)
.end()
})
array.end().end().done()
}
}
implicit object BaseInfoJsonMarshalling extends JsonMarshalling[Status.BaseInfo] {
override def toJson(instance: Status.BaseInfo, builder: JavaStringBuilder): Unit = {
val baseConfigJson = JsonWriter.on(builder)
.`object`()
.value("version", instance.version)
.value("config", instance.config.root().render(ConfigRenderOptions.concise()))
baseConfigJson.`object`("environment")
.value("service", instance.environment.service)
.value("host", instance.environment.host)
.value("instance", instance.environment.instance)
.`object`("tags")
instance.environment.tags.foreach {
case (key, value) => baseConfigJson.value(key, value)
}
baseConfigJson
.end() // ends tags
.end() // ends environment
.end() // ends base config
.done()
}
}
implicit object MetricRegistryStatusJsonMarshalling extends JsonMarshalling[MetricRegistry.Status] {
override def toJson(instance: MetricRegistry.Status, builder: JavaStringBuilder): Unit = {
val metricsObject = JsonWriter.on(builder)
.`object`
.array("metrics")
instance.metrics.foreach(metric => {
metricsObject
.`object`()
.value("name", metric.name)
.value("type", metric.instrumentType.name)
.`object`("tags")
metric.tags.foreach { case (tag, value) => metricsObject.value(tag, value) }
metricsObject
.end() // tags
.end() // metric info
})
metricsObject
.end() // metrics array
.end() // object
.done()
}
}
}
|
