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
|
package kamon.metrics
import kamon.system.native.SigarLoader
import org.hyperic.sigar.{NetInterfaceStat, Swap}
trait SigarExtensionProvider {
self: MetricsCollector =>
lazy val sigar = SigarLoader.init
}
trait MetricsCollector extends SigarExtensionProvider {
def collect: MetricsMeasurement
}
sealed trait MetricsMeasurement
case class MemoryMetricsMeasurement(memUsage: Long, memSwapPageIn: Long, memSwapPageOut: Long) extends MetricsMeasurement
case class NetworkMetricsMeasurement(tcpCurrEstab: Long,
tcpEstabResets: Long,
netRxBytesRate: Long,
netTxBytesRate: Long,
netRxErrors: Long,
netTxErrors: Long) extends MetricsMeasurement
case class CpuMetricsMeasurement(cpuUser: Long, cpuSys: Long, cpuCombined: Long,
loadAverage1min: Long,
loadAverage5min: Long,
loadAverage15min: Long) extends MetricsMeasurement
class CpuMetricsCollector extends MetricsCollector {
val loadAverage = sigar.getLoadAverage
val cpuPerc = sigar.getCpuPerc
def collect(): CpuMetricsMeasurement = {
println(s"ProcCPU->${sigar.getProcCpu(sigar.getPid)}")
val loadAverage1min = loadAverage(0).toLong
val loadAverage5min = loadAverage(1).toLong
val loadAverage15min = loadAverage(2).toLong
CpuMetricsMeasurement(cpuPerc.getUser.toLong, cpuPerc.getSys.toLong, cpuPerc.getCombined.toLong, loadAverage1min, loadAverage5min, loadAverage15min)
}
}
class MemoryMetricsCollector extends MetricsCollector {
val swap: Swap = sigar.getSwap
def collect(): MetricsMeasurement = MemoryMetricsMeasurement(sigar.getMem.getUsedPercent.toLong, swap.getPageIn, swap.getPageOut)
}
class NetWorkMetricsCollector extends MetricsCollector {
val interfaces = sigar.getNetInterfaceList.toSet
val tcp = sigar.getTcp
var netRxBytes = 0L
var netTxBytes = 0L
var netRxErrors = 0L
var netTxErrors = 0L
def collect(): MetricsMeasurement = {
for{
interface <- interfaces
net:NetInterfaceStat <- sigar.getNetInterfaceStat(interface)
}{
netRxBytes += net.getRxBytes
netTxBytes += net.getTxBytes
netRxErrors += net.getRxErrors
netTxErrors += net.getTxErrors
}
NetworkMetricsMeasurement(tcp.getCurrEstab, tcp.getEstabResets,netRxBytes, netTxBytes, netRxErrors, netTxErrors)
}
}
|
