Package org.apache.pekko.cluster.metrics
Class MixMetricsSelectorBase
- java.lang.Object
-
- org.apache.pekko.cluster.metrics.CapacityMetricsSelector
-
- org.apache.pekko.cluster.metrics.MixMetricsSelectorBase
-
- All Implemented Interfaces:
java.io.Serializable
,MetricsSelector
- Direct Known Subclasses:
MixMetricsSelector
,MixMetricsSelector$
public abstract class MixMetricsSelectorBase extends CapacityMetricsSelector
Base class for MetricsSelector that combines other selectors and aggregates their capacity.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MixMetricsSelectorBase(java.lang.Iterable<CapacityMetricsSelector> selectors)
Java API: construct a mix-selector from a sequence of selectorsMixMetricsSelectorBase(scala.collection.immutable.IndexedSeq<CapacityMetricsSelector> selectors)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.collection.immutable.Map<Address,java.lang.Object>
capacity(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)
Remaining capacity for each node.-
Methods inherited from class org.apache.pekko.cluster.metrics.CapacityMetricsSelector
weights, weights
-
-
-
-
Constructor Detail
-
MixMetricsSelectorBase
public MixMetricsSelectorBase(scala.collection.immutable.IndexedSeq<CapacityMetricsSelector> selectors)
-
MixMetricsSelectorBase
public MixMetricsSelectorBase(java.lang.Iterable<CapacityMetricsSelector> selectors)
Java API: construct a mix-selector from a sequence of selectors
-
-
Method Detail
-
capacity
public scala.collection.immutable.Map<Address,java.lang.Object> capacity(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)
Description copied from class:CapacityMetricsSelector
Remaining capacity for each node. The value is between 0.0 and 1.0, where 0.0 means no remaining capacity (full utilization) and 1.0 means full remaining capacity (zero utilization).- Specified by:
capacity
in classCapacityMetricsSelector
-
-