Package akka.cluster.ddata
Class Replicator.Internal$.DataEnvelope
- java.lang.Object
-
- akka.cluster.ddata.Replicator.Internal$.DataEnvelope
-
- All Implemented Interfaces:
Replicator.ReplicatorMessage
,java.io.Serializable
,scala.Equals
,scala.Product
,scala.Serializable
- Enclosing class:
- Replicator.Internal$
public final class Replicator.Internal$.DataEnvelope extends java.lang.Object implements Replicator.ReplicatorMessage, scala.Product, scala.Serializable
We only use the deltaVersions to track versions per node, not for ordering comparisons, so we can just remove the entry for the removed node.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description DataEnvelope(ReplicatedData data, scala.collection.immutable.Map<UniqueAddress,PruningState> pruning, VersionVector deltaVersions)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static scala.collection.immutable.Map<UniqueAddress,PruningState>
$lessinit$greater$default$2()
static VersionVector
$lessinit$greater$default$3()
akka.cluster.ddata.Replicator.Internal.DataEnvelope
addSeen(Address node)
static akka.cluster.ddata.Replicator.Internal.DataEnvelope
apply(ReplicatedData data, scala.collection.immutable.Map<UniqueAddress,PruningState> pruning, VersionVector deltaVersions)
static scala.collection.immutable.Map<UniqueAddress,PruningState>
apply$default$2()
static VersionVector
apply$default$3()
boolean
canEqual(java.lang.Object x$1)
akka.cluster.ddata.Replicator.Internal.DataEnvelope
copy(ReplicatedData data, scala.collection.immutable.Map<UniqueAddress,PruningState> pruning, VersionVector deltaVersions)
ReplicatedData
copy$default$1()
scala.collection.immutable.Map<UniqueAddress,PruningState>
copy$default$2()
VersionVector
copy$default$3()
ReplicatedData
data()
VersionVector
deltaVersions()
boolean
equals(java.lang.Object x$1)
int
hashCode()
akka.cluster.ddata.Replicator.Internal.DataEnvelope
initRemovedNodePruning(UniqueAddress removed, UniqueAddress owner)
akka.cluster.ddata.Replicator.Internal.DataEnvelope
merge(ReplicatedData otherData)
akka.cluster.ddata.Replicator.Internal.DataEnvelope
merge(akka.cluster.ddata.Replicator.Internal.DataEnvelope other)
boolean
needPruningFrom(UniqueAddress removedNode)
int
productArity()
java.lang.Object
productElement(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
akka.cluster.ddata.Replicator.Internal.DataEnvelope
prune(UniqueAddress from, PruningState.PruningPerformed pruningPerformed)
scala.collection.immutable.Map<UniqueAddress,PruningState>
pruning()
java.lang.String
toString()
static scala.Option<scala.Tuple3<ReplicatedData,scala.collection.immutable.Map<UniqueAddress,PruningState>,VersionVector>>
unapply(akka.cluster.ddata.Replicator.Internal.DataEnvelope x$0)
akka.cluster.ddata.Replicator.Internal.DataEnvelope
withoutDeltaVersions()
-
-
-
Constructor Detail
-
DataEnvelope
public DataEnvelope(ReplicatedData data, scala.collection.immutable.Map<UniqueAddress,PruningState> pruning, VersionVector deltaVersions)
-
-
Method Detail
-
$lessinit$greater$default$2
public static scala.collection.immutable.Map<UniqueAddress,PruningState> $lessinit$greater$default$2()
-
$lessinit$greater$default$3
public static VersionVector $lessinit$greater$default$3()
-
apply
public static akka.cluster.ddata.Replicator.Internal.DataEnvelope apply(ReplicatedData data, scala.collection.immutable.Map<UniqueAddress,PruningState> pruning, VersionVector deltaVersions)
-
apply$default$2
public static scala.collection.immutable.Map<UniqueAddress,PruningState> apply$default$2()
-
apply$default$3
public static VersionVector apply$default$3()
-
unapply
public static scala.Option<scala.Tuple3<ReplicatedData,scala.collection.immutable.Map<UniqueAddress,PruningState>,VersionVector>> unapply(akka.cluster.ddata.Replicator.Internal.DataEnvelope x$0)
-
data
public ReplicatedData data()
-
pruning
public scala.collection.immutable.Map<UniqueAddress,PruningState> pruning()
-
deltaVersions
public VersionVector deltaVersions()
-
withoutDeltaVersions
public akka.cluster.ddata.Replicator.Internal.DataEnvelope withoutDeltaVersions()
-
needPruningFrom
public boolean needPruningFrom(UniqueAddress removedNode)
-
initRemovedNodePruning
public akka.cluster.ddata.Replicator.Internal.DataEnvelope initRemovedNodePruning(UniqueAddress removed, UniqueAddress owner)
-
prune
public akka.cluster.ddata.Replicator.Internal.DataEnvelope prune(UniqueAddress from, PruningState.PruningPerformed pruningPerformed)
-
merge
public akka.cluster.ddata.Replicator.Internal.DataEnvelope merge(akka.cluster.ddata.Replicator.Internal.DataEnvelope other)
-
merge
public akka.cluster.ddata.Replicator.Internal.DataEnvelope merge(ReplicatedData otherData)
-
addSeen
public akka.cluster.ddata.Replicator.Internal.DataEnvelope addSeen(Address node)
-
copy
public akka.cluster.ddata.Replicator.Internal.DataEnvelope copy(ReplicatedData data, scala.collection.immutable.Map<UniqueAddress,PruningState> pruning, VersionVector deltaVersions)
-
copy$default$1
public ReplicatedData copy$default$1()
-
copy$default$2
public scala.collection.immutable.Map<UniqueAddress,PruningState> copy$default$2()
-
copy$default$3
public VersionVector copy$default$3()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-