Package org.apache.pekko.cluster.metrics

Class SystemLoadAverageMetricsSelector

java.lang.Object

org.apache.pekko.cluster.metrics.SystemLoadAverageMetricsSelector

public class SystemLoadAverageMetricsSelector
extends Object

MetricsSelector that uses the system load average metrics. System load average is 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. Low load average capacity => small weight.

Constructor Summary

Constructors

Constructor	Description
SystemLoadAverageMetricsSelector()

Method Summary

Modifier and Type	Method	Description
static boolean	canEqual(Object x$1)
static scala.collection.immutable.Map<Address,Object>	capacity(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)
abstract static boolean	equals(Object that)
static SystemLoadAverageMetricsSelector$	getInstance()	Java API: get the singleton instance
static int	hashCode()
static int	productArity()
static Object	productElement(int x$1)
static String	productElementName(int n)
static scala.collection.Iterator<String>	productElementNames()
static scala.collection.Iterator<Object>	productIterator()
static String	productPrefix()
static String	toString()
static scala.collection.immutable.Map<Address,Object>	weights(scala.collection.immutable.Map<Address,Object> capacity)
static scala.collection.immutable.Map<Address,Object>	weights(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SystemLoadAverageMetricsSelector

public SystemLoadAverageMetricsSelector()

Method Details

getInstance

public static SystemLoadAverageMetricsSelector$ getInstance()

Java API: get the singleton instance

capacity

public static scala.collection.immutable.Map<Address,Object> capacity(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)

productPrefix

public static String productPrefix()

productArity

public static int productArity()

productElement

public static Object productElement(int x$1)

productIterator

public static scala.collection.Iterator<Object> productIterator()

canEqual

public static boolean canEqual(Object x$1)

hashCode

public static int hashCode()

toString

public static String toString()

weights

public static scala.collection.immutable.Map<Address,Object> weights(scala.collection.immutable.Map<Address,Object> capacity)

weights

public static scala.collection.immutable.Map<Address,Object> weights(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)

equals

public abstract static boolean equals(Object that)

productElementName

public static String productElementName(int n)

productElementNames

public static scala.collection.Iterator<String> productElementNames()