|
|||||||||
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.
TODO switch to Scala reflection
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 | |
---|---|
akka.cluster.MetricsCollector |
apply(ExtendedActorSystem system,
ClusterSettings settings)
|
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)
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 class JmxMetricsCollector
public akka.cluster.MetricsCollector apply(ExtendedActorSystem system, ClusterSettings settings)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |