final case class MixMetricsSelector(selectors: IndexedSeq[CapacityMetricsSelector]) extends MixMetricsSelectorBase with Product with Serializable
MetricsSelector that combines other selectors and aggregates their capacity values. By default it uses [akka.cluster.routing.HeapMetricsSelector], [akka.cluster.routing.CpuMetricsSelector], and [akka.cluster.routing.SystemLoadAverageMetricsSelector]
- Annotations
- @SerialVersionUID()
- Source
- ClusterMetricsRouting.scala
- Alphabetic
- By Inheritance
- MixMetricsSelector
- Product
- Equals
- MixMetricsSelectorBase
- CapacityMetricsSelector
- MetricsSelector
- Serializable
- Serializable
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new MixMetricsSelector(selectors: IndexedSeq[CapacityMetricsSelector])
Value Members
-
def
capacity(nodeMetrics: Set[NodeMetrics]): Map[Address, Double]
Remaining capacity for each node.
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).
- Definition Classes
- MixMetricsSelectorBase → CapacityMetricsSelector
- val selectors: IndexedSeq[CapacityMetricsSelector]
-
def
weights(nodeMetrics: Set[NodeMetrics]): Map[Address, Int]
The weights per address, based on the capacity produced by the nodeMetrics.
The weights per address, based on the capacity produced by the nodeMetrics.
- Definition Classes
- CapacityMetricsSelector → MetricsSelector
-
def
weights(capacity: Map[Address, Double]): Map[Address, Int]
Converts the capacity values to weights.
Converts the capacity values to weights. The node with lowest capacity gets weight 1 (lowest usable capacity is 1%) and other nodes gets weights proportional to their capacity compared to the node with lowest capacity.
- Definition Classes
- CapacityMetricsSelector