c

akka.cluster.metrics

MixMetricsSelectorBase

abstract class MixMetricsSelectorBase extends CapacityMetricsSelector

Base class for MetricsSelector that combines other selectors and aggregates their capacity.

Annotations
@SerialVersionUID()
Source
ClusterMetricsRouting.scala
Linear Supertypes
CapacityMetricsSelector, MetricsSelector, Serializable, AnyRef, Any
Known Subclasses
MixMetricsSelector, MixMetricsSelector
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MixMetricsSelectorBase
  2. CapacityMetricsSelector
  3. MetricsSelector
  4. Serializable
  5. AnyRef
  6. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new MixMetricsSelectorBase(selectors: [CapacityMetricsSelector])

    Java API: construct a mix-selector from a sequence of selectors

  2. new MixMetricsSelectorBase(selectors: [CapacityMetricsSelector])

Value Members

  1. def capacity(nodeMetrics: Set[NodeMetrics]): Map[, 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
    → CapacityMetricsSelector
  2. def weights(nodeMetrics: Set[NodeMetrics]): Map[, 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
    → MetricsSelector
  3. def weights(capacity: Map[, Double]): Map[, 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