diff options
| author | Diego <diegolparra@gmail.com> | 2014-12-06 17:50:44 -0300 |
|---|---|---|
| committer | Diego <diegolparra@gmail.com> | 2014-12-06 17:50:44 -0300 |
| commit | 9b0bf679201c6831855ca54e20d92e5495789943 (patch) | |
| tree | 5fd8d8a038f70da10c1b0784381866658e41a3ef /kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala | |
| parent | e828ee9f33c65063775a7b84da91d8e073b7600a (diff) | |
| download | Kamon-9b0bf679201c6831855ca54e20d92e5495789943.tar.gz Kamon-9b0bf679201c6831855ca54e20d92e5495789943.tar.bz2 Kamon-9b0bf679201c6831855ca54e20d92e5495789943.zip | |
+ system-metrics: include RxDropped and TxDropped in NetworkMetrics
Diffstat (limited to 'kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala')
| -rw-r--r-- | kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala | 4 |
1 files changed, 3 insertions, 1 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 8094cac4..c200091e 100644 --- a/kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala +++ b/kamon-system-metrics/src/main/scala/kamon/system/SystemMetricsCollector.scala @@ -104,6 +104,8 @@ class SystemMetricsCollector(collectInterval: FiniteDuration) extends Actor with nr.txBytes.record(collect(sigar, interfaces)(net ⇒ toKB(net.getTxBytes))) nr.rxErrors.record(collect(sigar, interfaces)(net ⇒ net.getRxErrors)) nr.txErrors.record(collect(sigar, interfaces)(net ⇒ net.getTxErrors)) + nr.rxDropped.record(collect(sigar, interfaces)(net ⇒ net.getRxDropped)) + nr.txDropped.record(collect(sigar, interfaces)(net ⇒ net.getTxDropped)) def collect(sigar: SigarProxy, interfaces: Set[String])(block: NetInterfaceStat ⇒ Long): Long = { interfaces.foldLeft(0L) { (totalBytes, interface) ⇒ @@ -197,5 +199,5 @@ object SystemMetricsCollector { def isLinux: Boolean = System.getProperty("os.name").indexOf("Linux") != -1 } - def props(collectInterval: FiniteDuration): Props = Props[SystemMetricsCollector](new SystemMetricsCollector(collectInterval)) + def props(collectInterval: FiniteDuration): Props = Props(classOf[SystemMetricsCollector], collectInterval) }
\ No newline at end of file |