public final class MetricsGossip
extends java.lang.Object
implements scala.Product, scala.Serializable
Constructor and Description |
---|
MetricsGossip(scala.collection.immutable.Set<NodeMetrics> nodes) |
Modifier and Type | Method and Description |
---|---|
static MetricsGossip |
empty() |
MetricsGossip |
filter(scala.collection.immutable.Set<akka.actor.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(akka.actor.Address address)
Returns
NodeMetrics for a node if exists. |
scala.collection.immutable.Set<NodeMetrics> |
nodes() |
MetricsGossip |
remove(akka.actor.Address node)
Removes nodes if their correlating node ring members are not
MemberStatus Up . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public MetricsGossip(scala.collection.immutable.Set<NodeMetrics> nodes)
public static MetricsGossip empty()
public scala.collection.immutable.Set<NodeMetrics> nodes()
public MetricsGossip remove(akka.actor.Address node)
MemberStatus
Up
.node
- (undocumented)public MetricsGossip filter(scala.collection.immutable.Set<akka.actor.Address> includeNodes)
includeNodes
Set.includeNodes
- (undocumented)public MetricsGossip merge(MetricsGossip otherGossip)
NodeMetrics
and merges existing from a remote gossip.otherGossip
- (undocumented)public scala.Option<NodeMetrics> nodeMetricsFor(akka.actor.Address address)
NodeMetrics
for a node if exists.address
- (undocumented)