blob: dffebf5a2327962a541845ff204e27be9e701230 (
plain) (
blame)
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
|
package kamon.system.sigar
import kamon.metric.GenericEntityRecorder
import kamon.metric.instrument.{ Memory, InstrumentFactory }
import org.hyperic.sigar.{ DiskUsage, FileSystem, Sigar }
class FileSystemMetrics(instrumentFactory: InstrumentFactory) extends GenericEntityRecorder(instrumentFactory) with SigarMetric {
val reads = DiffRecordingHistogram(histogram("file-system-reads", Memory.Bytes))
val writes = DiffRecordingHistogram(histogram("file-system-writes", Memory.Bytes))
def sumOfAllFileSystems(sigar: Sigar, thunk: DiskUsage ⇒ Long): Long = {
val fileSystems = sigar.getFileSystemList.filter(_.getType == FileSystem.TYPE_LOCAL_DISK).map(_.getDevName).toSet
fileSystems.map(i ⇒ thunk(sigar.getDiskUsage(i))).fold(0L)(_ + _)
}
def update(sigar: Sigar): Unit = {
reads.record(sumOfAllFileSystems(sigar, _.getReadBytes))
writes.record(sumOfAllFileSystems(sigar, _.getWriteBytes))
}
}
object FileSystemMetrics extends SigarMetricRecorderCompanion("file-system") {
def apply(instrumentFactory: InstrumentFactory): FileSystemMetrics =
new FileSystemMetrics(instrumentFactory)
}
|