akka.cluster.metrics

Class NodeMetrics

java.lang.Object

akka.cluster.metrics.NodeMetrics

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

public final class NodeMetrics
extends java.lang.Object
implements scala.Product, scala.Serializable

The snapshot of current sampled health metrics for any monitored process. Collected and gossipped at regular intervals for dynamic cluster management strategies.

Equality of NodeMetrics is based on its address.

param: address Address of the node the metrics are gathered at param: timestamp the time of sampling, in milliseconds since midnight, January 1, 1970 UTC param: metrics the set of sampled Metric

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NodeMetrics(Address address, long timestamp, scala.collection.immutable.Set<Metric> metrics)

Method Summary

Modifier and Type	Method and Description
Address	address()
abstract static boolean	canEqual(java.lang.Object that)
boolean	equals(java.lang.Object obj)
java.lang.Iterable<Metric>	getMetrics() Java API
int	hashCode()
NodeMetrics	merge(NodeMetrics that) Returns the most recent data.
scala.Option<Metric>	metric(java.lang.String key)
scala.collection.immutable.Set<Metric>	metrics()
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
boolean	sameAs(NodeMetrics that) Returns true if that address is the same as this
long	timestamp()
NodeMetrics	update(NodeMetrics that) Returns the most recent data with EWMA averaging.

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual

Constructor Detail

NodeMetrics

public NodeMetrics(Address address,
                   long timestamp,
                   scala.collection.immutable.Set<Metric> metrics)

Method Detail

canEqual

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

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

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

productPrefix

public static java.lang.String productPrefix()

address

public Address address()

timestamp

public long timestamp()

metrics

public scala.collection.immutable.Set<Metric> metrics()

merge

public NodeMetrics merge(NodeMetrics that)

Returns the most recent data.

Parameters:

that - (undocumented)

Returns:

(undocumented)

update

public NodeMetrics update(NodeMetrics that)

Returns the most recent data with EWMA averaging.

Parameters:

that - (undocumented)

Returns:

(undocumented)

metric

public scala.Option<Metric> metric(java.lang.String key)

getMetrics

public java.lang.Iterable<Metric> getMetrics()

Java API

Returns:

(undocumented)

sameAs

public boolean sameAs(NodeMetrics that)

Returns true if that address is the same as this

Parameters:

that - (undocumented)

Returns:

(undocumented)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class java.lang.Object