Package org.apache.pekko.cluster.metrics

Class CpuMetricsSelector

java.lang.Object

org.apache.pekko.cluster.metrics.CpuMetricsSelector

public class CpuMetricsSelector
extends java.lang.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(java.lang.Object x$1)
static scala.collection.immutable.Map<Address,java.lang.Object>	capacity(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)
abstract static boolean	equals(java.lang.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 java.lang.Object	productElement(int x$1)
static java.lang.String	productElementName(int n)
static scala.collection.Iterator<java.lang.String>	productElementNames()
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
static java.lang.String	toString()
static scala.collection.immutable.Map<Address,java.lang.Object>	weights(scala.collection.immutable.Map<Address,java.lang.Object> capacity)
static scala.collection.immutable.Map<Address,java.lang.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 Detail

CpuMetricsSelector

public CpuMetricsSelector()

Method Detail

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,java.lang.Object> capacity(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)

productPrefix

public static java.lang.String productPrefix()

productArity

public static int productArity()

productElement

public static java.lang.Object productElement(int x$1)

productIterator

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

canEqual

public static boolean canEqual(java.lang.Object x$1)

hashCode

public static int hashCode()

toString

public static java.lang.String toString()

weights

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

weights

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

equals

public abstract static boolean equals(java.lang.Object that)

productElementName

public static java.lang.String productElementName(int n)

productElementNames

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