akka.cluster.ddata

Class GCounter

java.lang.Object

akka.cluster.ddata.GCounter

All Implemented Interfaces:

FastMerge, RemovedNodePruning, ReplicatedData, ReplicatedDataSerialization, java.io.Serializable

public final class GCounter
extends java.lang.Object
implements ReplicatedData, ReplicatedDataSerialization, RemovedNodePruning, FastMerge

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GCounter(scala.collection.immutable.Map<UniqueAddress,scala.math.BigInt> state)

Method Summary

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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.cluster.ddata.ReplicatedData

merge

Methods inherited from interface akka.cluster.ddata.FastMerge

assignAncestor, clearAncestor, isAncestorOf

Constructor Detail

GCounter

public GCounter(scala.collection.immutable.Map<UniqueAddress,scala.math.BigInt> state)

Method Detail

empty

public static GCounter empty()

apply

public static GCounter apply()

create

public static GCounter create()

Java API

Returns:

(undocumented)

unapply

public static scala.Option<scala.math.BigInt> unapply(GCounter c)

Extract the value().

Parameters:

c - (undocumented)

Returns:

(undocumented)

akka$cluster$ddata$FastMerge$$ancestor

public static FastMerge akka$cluster$ddata$FastMerge$$ancestor()

akka$cluster$ddata$FastMerge$$ancestor_$eq

public static void akka$cluster$ddata$FastMerge$$ancestor_$eq(FastMerge x$1)

assignAncestor

public static FastMerge assignAncestor(akka.cluster.ddata.ReplicatedData.T newData)

isAncestorOf

public static boolean isAncestorOf(akka.cluster.ddata.ReplicatedData.T that)

clearAncestor

public static FastMerge clearAncestor()

state

public scala.collection.immutable.Map<UniqueAddress,scala.math.BigInt> state()

value

public scala.math.BigInt value()

Scala API: Current total value of the counter.

Returns:

(undocumented)

getValue

public java.math.BigInteger getValue()

Java API: Current total value of the counter.

Returns:

(undocumented)

increment

public GCounter increment(Cluster node,
                          long delta)

Increment the counter with the delta specified. The delta must be zero or positive.

Parameters:

node - (undocumented)

delta - (undocumented)

Returns:

(undocumented)

increment

public GCounter increment(UniqueAddress key)

INTERNAL API

Parameters:

key - (undocumented)

Returns:

(undocumented)

increment

public GCounter increment(UniqueAddress key,
                          scala.math.BigInt delta)

INTERNAL API

Parameters:

key - (undocumented)

delta - (undocumented)

Returns:

(undocumented)

merge

public GCounter merge(GCounter that)

INTERNAL API

Parameters:

that - (undocumented)

Returns:

(undocumented)

needPruningFrom

public boolean needPruningFrom(UniqueAddress removedNode)

Description copied from interface: RemovedNodePruning

Does it have any state changes from a specific node, which has been removed from the cluster.

Specified by:

needPruningFrom in interface RemovedNodePruning

Parameters:

removedNode - (undocumented)

Returns:

(undocumented)

prune

public GCounter prune(UniqueAddress removedNode,
                      UniqueAddress collapseInto)

Description copied from interface: RemovedNodePruning

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.

Specified by:

prune in interface RemovedNodePruning

Parameters:

removedNode - (undocumented)

collapseInto - (undocumented)

Returns:

(undocumented)

pruningCleanup

public GCounter pruningCleanup(UniqueAddress removedNode)

Description copied from interface: RemovedNodePruning

Remove data entries from a node that has been removed from the cluster and already been pruned.

Specified by:

pruningCleanup in interface RemovedNodePruning

Parameters:

removedNode - (undocumented)

Returns:

(undocumented)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object