Package org.apache.pekko.cluster.metrics

Class CpuMetricsSelector

java.lang.Object

org.apache.pekko.cluster.metrics.CpuMetricsSelector

public class CpuMetricsSelector
extends Object

MetricsSelector that uses the combined CPU time metrics and stolen CPU time metrics. In modern Linux kernels: CpuCombined + CpuStolen + CpuIdle = 1.0 or 100%. Combined CPU is sum of User + Sys + Nice + Wait times, as percentage. Stolen CPU is the amount of CPU taken away from this virtual machine by the hypervisor, as percentage.

Low CPU capacity => small node weight.

Constructor Summary

Constructors

Constructor	Description
CpuMetricsSelector()

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 double	factor()	How much extra weight to give to the stolen time.
static CpuMetricsSelector$	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

CpuMetricsSelector

public CpuMetricsSelector()

Method Details

getInstance

public static CpuMetricsSelector$ getInstance()

Java API: get the singleton instance

factor

public static double factor()

How much extra weight to give to the stolen time.

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()