Package akka.cluster.metrics

Interface Summary

Interface	Description
ClusterMetricsEvent	Local cluster metrics extension events.
ClusterMetricsMessage	INTERNAL API.
MetricNumericConverter	An defined value is neither negative nor NaN/Infinite: JMX system load average and max heap can be 'undefined' for certain OS, in which case a -1 is returned SIGAR combined CPU can occasionally return a NaN or Infinite (known bug)
MetricsCollector	Samples and collects new data points.
MetricsSelector	The weights per address, based on the nodeMetrics.
SigarProvider	Library extract location.

Class Summary

Class	Description
AdaptiveLoadBalancingGroup	Java API param: metricsSelector decides what probability to use for selecting a routee, based on remaining capacity as indicated by the node metrics param: routeesPaths string representation of the actor paths of the routees, messages are sent with ActorSelection to these paths
AdaptiveLoadBalancingGroup$
AdaptiveLoadBalancingMetricsListener	INTERNAL API Subscribe to ClusterMetricsEvents and update routing logic depending on the events.
AdaptiveLoadBalancingPool	Java API param: metricsSelector decides what probability to use for selecting a routee, based on remaining capacity as indicated by the node metrics param: nr initial number of routees in the pool
AdaptiveLoadBalancingPool$
AdaptiveLoadBalancingRoutingLogic	Load balancing of messages to cluster nodes based on cluster metric data.
AdaptiveLoadBalancingRoutingLogic$
CapacityMetricsSelector	Remaining capacity for each node.
ClusterMetricsChanged	Java API
ClusterMetricsChanged$
ClusterMetricsCollector	The node ring gossipped that contains only members that are Up.
ClusterMetricsCollector.GossipTick$
ClusterMetricsCollector.MetricsTick$
ClusterMetricsCollector$	INTERNAL API.
ClusterMetricsExtension	Metrics extension configuration.
ClusterMetricsExtension$	Cluster metrics extension provider.
ClusterMetricsSettings	Metrics extension settings.
ClusterMetricsSettings$
ClusterMetricsStrategy	Default ClusterMetricsSupervisor strategy: A configurable OneForOneStrategy with restart-on-throwable decider.
ClusterMetricsStrategy$	SupervisorStrategy Decider which allows to survive intermittent Sigar native method calls failures.
ClusterMetricsSupervisor	INTERNAL API.
CollectionControlMessage	Runtime collection management commands.
CollectionStartMessage	Java API
CollectionStartMessage$	Java API
CollectionStopMessage	Java API
CollectionStopMessage$	Java API
CpuMetricsSelector	Java API: get the singleton instance
CpuMetricsSelector$	Java API: get the singleton instance
DefaultSigarProvider	Provide sigar instance as SigarProxy with configured location via ClusterMetricsSettings.
DefaultSigarProvider$
EWMA	Calculates the exponentially weighted moving average for a given monitored data set.
EWMA$	math.log(2)
HeapMetricsSelector	Java API: get the singleton instance
HeapMetricsSelector$	Java API: get the singleton instance
JmxMetricsCollector	This constructor is used when creating an instance from configured FQCN
Metric	Updates the data point, and if defined, updates the data stream (average).
Metric$	Creates a new Metric instance if the value is valid, otherwise None is returned.
MetricsCollector$	Try to create collector instance in the order of priority.
MetricsGossip
MetricsGossip$	INTERNAL API
MetricsGossipEnvelope	INTERNAL API.
MetricsGossipEnvelope$
MetricsSelector$	Java API: construct a mix-selector from a sequence of selectors
MixMetricsSelector
MixMetricsSelector$	Java API: get the default singleton instance
MixMetricsSelectorBase	Java API: construct a mix-selector from a sequence of selectors
NodeMetrics	Returns the most recent data.
NodeMetrics$
SigarMetricsCollector	This constructor is used when creating an instance from configured FQCN
SigarProvider$	Release underlying sigar proxy resources.
StandardMetrics	Sum of User + Sys + Nice + Wait.
StandardMetrics.Cpu	param: address Address of the node the metrics are gathered at param: timestamp the time of sampling, in milliseconds since midnight, January 1, 1970 UTC param: systemLoadAverage OS-specific average load on the CPUs in the system, for the past 1 minute, The system is possibly nearing a bottleneck if the system load average is nearing number of cpus/cores.
StandardMetrics.Cpu$
StandardMetrics.HeapMemory	The amount of used and committed memory will always be <= max if max is defined.
StandardMetrics.HeapMemory$	Given a NodeMetrics it returns the HeapMemory data if the nodeMetrics contains necessary heap metrics.
StandardMetrics$	Sum of User + Sys + Nice + Wait.
SystemLoadAverageMetricsSelector	Java API: get the singleton instance
SystemLoadAverageMetricsSelector$	Java API: get the singleton instance
TryNative	INTERNAL API
TryNative$	INTERNAL API
WeightedRoutees	Pick the routee matching a value, from 1 to total.