akka.cluster
Class MetricsGossip

java.lang.Object
  extended by akka.cluster.MetricsGossip
All Implemented Interfaces:
java.io.Serializable, scala.Equals, scala.Product

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

See Also:
Serialized Form

Constructor Summary
MetricsGossip(scala.collection.immutable.Set<NodeMetrics> nodes)
           
 
Method Summary
static MetricsGossip empty()
           
 MetricsGossip filter(scala.collection.immutable.Set<Address> includeNodes)
          Only the nodes that are in the includeNodes Set.
 MetricsGossip merge(MetricsGossip otherGossip)
          Adds new remote NodeMetrics and merges existing from a remote gossip.
 scala.Option<NodeMetrics> nodeMetricsFor(Address address)
          Returns NodeMetrics for a node if exists.
 scala.collection.immutable.Set<NodeMetrics> nodes()
           
 MetricsGossip remove(Address node)
          Removes nodes if their correlating node ring members are not akka.cluster.MemberStatus.Up
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface scala.Product
productArity, productElement, productIterator, productPrefix
 
Methods inherited from interface scala.Equals
canEqual, equals
 

Constructor Detail

MetricsGossip

public MetricsGossip(scala.collection.immutable.Set<NodeMetrics> nodes)
Method Detail

empty

public static MetricsGossip empty()

nodes

public scala.collection.immutable.Set<NodeMetrics> nodes()

remove

public MetricsGossip remove(Address node)
Removes nodes if their correlating node ring members are not akka.cluster.MemberStatus.Up

Parameters:
node - (undocumented)
Returns:
(undocumented)

filter

public MetricsGossip filter(scala.collection.immutable.Set<Address> includeNodes)
Only the nodes that are in the includeNodes Set.

Parameters:
includeNodes - (undocumented)
Returns:
(undocumented)

merge

public MetricsGossip merge(MetricsGossip otherGossip)
Adds new remote NodeMetrics and merges existing from a remote gossip.

Parameters:
otherGossip - (undocumented)
Returns:
(undocumented)

nodeMetricsFor

public scala.Option<NodeMetrics> nodeMetricsFor(Address address)
Returns NodeMetrics for a node if exists.

Parameters:
address - (undocumented)
Returns:
(undocumented)