diff options
author | Diego <diegolparra@gmail.com> | 2014-08-13 14:24:48 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2014-08-13 14:24:48 -0300 |
commit | 489748e11734ea09fbdc270e01b3c66fff78cd03 (patch) | |
tree | 481ceec8f6d35fc6184e80ba91bda1605456aeb8 /kamon-system-metrics | |
parent | 8b4a6a39c0f66033716fa576c65f2db485ae31a8 (diff) | |
download | Kamon-489748e11734ea09fbdc270e01b3c66fff78cd03.tar.gz Kamon-489748e11734ea09fbdc270e01b3c66fff78cd03.tar.bz2 Kamon-489748e11734ea09fbdc270e01b3c66fff78cd03.zip |
+ log-reporter: include Cpu and Network metrics
Diffstat (limited to 'kamon-system-metrics')
-rw-r--r-- | kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala b/kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala index a5a2f411..31963487 100644 --- a/kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala +++ b/kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala @@ -42,8 +42,7 @@ class SystemMetricsCollector(collectInterval: FiniteDuration) extends Actor with val networkRecorder = systemMetricsExtension.register(NetworkMetrics(Network), NetworkMetrics.Factory) def receive: Receive = { - case Collect ⇒ collectMetrics() - case anything ⇒ + case Collect ⇒ collectMetrics() } override def postStop() = collectSchedule.cancel() @@ -56,18 +55,24 @@ class SystemMetricsCollector(collectInterval: FiniteDuration) extends Actor with } private def recordCpu(cpur: CPUMetricRecorder) = { - cpur.user.record(toLong(cpu.getUser)) - cpur.system.record(toLong(cpu.getSys)) - cpur.cpuWait.record(toLong(cpu.getWait())) - cpur.idle.record(toLong(cpu.getIdle)) + val cpuPerc = sigar.getCpuPerc + cpur.user.record(toLong(cpuPerc.getUser)) + cpur.system.record(toLong(cpuPerc.getSys)) + cpur.cpuWait.record(toLong(cpuPerc.getWait)) + cpur.idle.record(toLong(cpuPerc.getIdle)) } private def recordProcessCpu(pcpur: ProcessCPUMetricsRecorder) = { + val procCpu = sigar.getProcCpu(pid) + pcpur.user.record(procCpu.getUser) pcpur.system.record(procCpu.getSys) } private def recordMemory(mr: MemoryMetricRecorder) = { + val mem = sigar.getMem + val swap = sigar.getSwap + mr.used.record(toMB(mem.getUsed)) mr.free.record(toMB(mem.getFree)) mr.swapUsed.record(toMB(swap.getUsed)) @@ -106,10 +111,6 @@ trait SigarExtensionProvider { lazy val sigar = SigarHolder.instance() def pid = sigar.getPid - def procCpu = sigar.getProcCpu(pid) - def cpu = sigar.getCpuPerc - def mem = sigar.getMem - def swap = sigar.getSwap val interfaces: Set[String] = sigar.getNetInterfaceList.toSet } |