o

akka.cluster.metrics

HeapMetricsSelector

object HeapMetricsSelector extends CapacityMetricsSelector with Product with Serializable

MetricsSelector that uses the heap metrics. Low heap capacity => small weight.

Annotations
@SerialVersionUID()
Source
ClusterMetricsRouting.scala
Linear Supertypes
Product, Equals, CapacityMetricsSelector, MetricsSelector, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. HeapMetricsSelector
  2. Product
  3. Equals
  4. CapacityMetricsSelector
  5. MetricsSelector
  6. Serializable
  7. Serializable
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. 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
    HeapMetricsSelector → CapacityMetricsSelector
  2. def getInstance: HeapMetricsSelector.type

    Java API: get the singleton instance

  3. 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
  4. 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