Package org.apache.pekko.cluster.metrics
Class CpuMetricsSelector$
- java.lang.Object
-
- org.apache.pekko.cluster.metrics.CapacityMetricsSelector
-
- org.apache.pekko.cluster.metrics.CpuMetricsSelector$
-
- All Implemented Interfaces:
java.io.Serializable
,MetricsSelector
,scala.Equals
,scala.Product
public class CpuMetricsSelector$ extends CapacityMetricsSelector implements scala.Product, java.io.Serializable
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.
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static CpuMetricsSelector$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description CpuMetricsSelector$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
canEqual(java.lang.Object x$1)
scala.collection.immutable.Map<Address,java.lang.Object>
capacity(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)
Remaining capacity for each node.double
factor()
How much extra weight to give to the stolen time.CpuMetricsSelector$
getInstance()
Java API: get the singleton instanceint
hashCode()
int
productArity()
java.lang.Object
productElement(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
java.lang.String
toString()
-
Methods inherited from class org.apache.pekko.cluster.metrics.CapacityMetricsSelector
weights, weights
-
-
-
-
Field Detail
-
MODULE$
public static final CpuMetricsSelector$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
getInstance
public CpuMetricsSelector$ getInstance()
Java API: get the singleton instance
-
factor
public double factor()
How much extra weight to give to the stolen time.
-
capacity
public scala.collection.immutable.Map<Address,java.lang.Object> capacity(scala.collection.immutable.Set<NodeMetrics> nodeMetrics)
Description copied from class:CapacityMetricsSelector
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).- Specified by:
capacity
in classCapacityMetricsSelector
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-