|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.cluster.JmxMetricsCollector akka.cluster.SigarMetricsCollector
public class SigarMetricsCollector
Loads metrics through Hyperic SIGAR and JMX monitoring beans. This loads wider and more accurate range of metrics compared to JmxMetricsCollector by using SIGAR's native OS library.
The constructor will by design throw exception if org.hyperic.sigar.Sigar can't be loaded, due to missing classes or native libraries.
param: address The Address
of the node being sampled
param: decay how quickly the exponential weighting of past data is decayed
param: sigar the org.hyperic.Sigar instance
Constructor Summary | |
---|---|
SigarMetricsCollector(ActorSystem system)
This constructor is used when creating an instance from configured FQCN |
|
SigarMetricsCollector(Address address,
double decayFactor,
java.lang.Object sigar)
|
Method Summary | |
---|---|
void |
close()
Releases any native resources associated with this instance. |
scala.Option<Metric> |
cpuCombined()
(SIGAR) Returns the combined CPU sum of User + Sys + Nice + Wait, in percentage. |
scala.collection.immutable.Set<Metric> |
metrics()
|
long |
pid()
|
scala.Option<Metric> |
systemLoadAverage()
(SIGAR / JMX) Returns the OS-specific average load on the CPUs in the system, for the past 1 minute. |
Methods inherited from class akka.cluster.JmxMetricsCollector |
---|
heapCommitted, heapMax, heapMemoryUsage, heapUsed, processors, sample |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public SigarMetricsCollector(Address address, double decayFactor, java.lang.Object sigar)
public SigarMetricsCollector(ActorSystem system)
system
- (undocumented)Method Detail |
---|
public long pid()
public scala.collection.immutable.Set<Metric> metrics()
metrics
in class JmxMetricsCollector
public scala.Option<Metric> systemLoadAverage()
systemLoadAverage
in class JmxMetricsCollector
public scala.Option<Metric> cpuCombined()
In the data stream, this will sometimes return with a valid metric value, and sometimes as a NaN or Infinite. Documented bug https://bugzilla.redhat.com/show_bug.cgi?id=749121 and several others.
Creates a new instance each time.
public void close()
close
in interface java.io.Closeable
close
in class JmxMetricsCollector
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |