public final class GCounter extends java.lang.Object implements ReplicatedData, ReplicatedDataSerialization, RemovedNodePruning, FastMerge
Constructor and Description |
---|
GCounter(scala.collection.immutable.Map<UniqueAddress,scala.math.BigInt> state) |
Modifier and Type | Method and Description |
---|---|
static void |
akka$cluster$ddata$FastMerge$$ancestor_$eq(FastMerge x$1) |
static FastMerge |
akka$cluster$ddata$FastMerge$$ancestor() |
static GCounter |
apply() |
static FastMerge |
assignAncestor(akka.cluster.ddata.ReplicatedData.T newData) |
static FastMerge |
clearAncestor() |
static GCounter |
create()
Java API
|
static GCounter |
empty() |
boolean |
equals(java.lang.Object o) |
java.math.BigInteger |
getValue()
Java API: Current total value of the counter.
|
int |
hashCode() |
GCounter |
increment(Cluster node,
long delta)
Increment the counter with the delta specified.
|
GCounter |
increment(UniqueAddress key)
INTERNAL API
|
GCounter |
increment(UniqueAddress key,
scala.math.BigInt delta)
INTERNAL API
|
static boolean |
isAncestorOf(akka.cluster.ddata.ReplicatedData.T that) |
GCounter |
merge(GCounter that)
INTERNAL API
|
boolean |
needPruningFrom(UniqueAddress removedNode)
Does it have any state changes from a specific node,
which has been removed from the cluster.
|
GCounter |
prune(UniqueAddress removedNode,
UniqueAddress collapseInto)
When the
removed node has been removed from the cluster the state
changes from that node will be pruned by collapsing the data entries
to another node. |
GCounter |
pruningCleanup(UniqueAddress removedNode)
Remove data entries from a node that has been removed from the cluster
and already been pruned.
|
scala.collection.immutable.Map<UniqueAddress,scala.math.BigInt> |
state() |
java.lang.String |
toString() |
static scala.Option<scala.math.BigInt> |
unapply(GCounter c)
Extract the
value() . |
scala.math.BigInt |
value()
Scala API: Current total value of the counter.
|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
merge
assignAncestor, clearAncestor, isAncestorOf
public GCounter(scala.collection.immutable.Map<UniqueAddress,scala.math.BigInt> state)
public static GCounter empty()
public static GCounter apply()
public static GCounter create()
public static scala.Option<scala.math.BigInt> unapply(GCounter c)
value()
.c
- (undocumented)public static FastMerge akka$cluster$ddata$FastMerge$$ancestor()
public static void akka$cluster$ddata$FastMerge$$ancestor_$eq(FastMerge x$1)
public static FastMerge assignAncestor(akka.cluster.ddata.ReplicatedData.T newData)
public static boolean isAncestorOf(akka.cluster.ddata.ReplicatedData.T that)
public static FastMerge clearAncestor()
public scala.collection.immutable.Map<UniqueAddress,scala.math.BigInt> state()
public scala.math.BigInt value()
public java.math.BigInteger getValue()
public GCounter increment(Cluster node, long delta)
node
- (undocumented)delta
- (undocumented)public GCounter increment(UniqueAddress key)
key
- (undocumented)public GCounter increment(UniqueAddress key, scala.math.BigInt delta)
key
- (undocumented)delta
- (undocumented)public GCounter merge(GCounter that)
that
- (undocumented)public boolean needPruningFrom(UniqueAddress removedNode)
RemovedNodePruning
needPruningFrom
in interface RemovedNodePruning
removedNode
- (undocumented)public GCounter prune(UniqueAddress removedNode, UniqueAddress collapseInto)
RemovedNodePruning
removed
node has been removed from the cluster the state
changes from that node will be pruned by collapsing the data entries
to another node.prune
in interface RemovedNodePruning
removedNode
- (undocumented)collapseInto
- (undocumented)public GCounter pruningCleanup(UniqueAddress removedNode)
RemovedNodePruning
pruningCleanup
in interface RemovedNodePruning
removedNode
- (undocumented)public java.lang.String toString()
toString
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object