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 ClusterMetricsEvent s 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 |
|
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 |
|
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.
|