Package akka.cluster.ddata
Class WriteAggregator
- java.lang.Object
-
- akka.cluster.ddata.ReadWriteAggregator
-
- akka.cluster.ddata.WriteAggregator
-
- All Implemented Interfaces:
Actor
,ActorLogging
public class WriteAggregator extends ReadWriteAggregator implements ActorLogging
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.cluster.ddata.ReadWriteAggregator
ReadWriteAggregator.SendToSecondary$
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description WriteAggregator(Key<ReplicatedData> key, akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope, scala.Option<akka.cluster.ddata.Replicator.Internal.Delta> delta, Replicator.WriteConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, ActorRef replyTo, boolean durable)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.Option<akka.cluster.ddata.Replicator.Internal.DeltaPropagation>
deltaMsg()
int
doneWhenRemainingSize()
boolean
gotLocalStoreReply()
void
gotLocalStoreReply_$eq(boolean x$1)
scala.collection.immutable.Set<Address>
gotWriteNackFrom()
void
gotWriteNackFrom_$eq(scala.collection.immutable.Set<Address> x$1)
boolean
isDone()
scala.collection.immutable.Set<UniqueAddress>
nodes()
boolean
notEnoughNodes()
void
preStart()
User overridable callback.static Props
props(Key<ReplicatedData> key, akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope, scala.Option<akka.cluster.ddata.Replicator.Internal.Delta> delta, Replicator.WriteConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, ActorRef replyTo, boolean durable)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.void
reply(boolean isTimeout)
Address
senderAddress()
scala.concurrent.duration.FiniteDuration
timeout()
scala.collection.immutable.Set<UniqueAddress>
unreachable()
akka.cluster.ddata.Replicator.Internal.Write
writeMsg()
-
Methods inherited from class akka.cluster.ddata.ReadWriteAggregator
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, calculateMajorityWithMinCap, context, MaxSecondaryNodes, postStop, primaryAndSecondaryNodes, reachableNodes, remaining, remaining_$eq, replica, self, sendToSecondarySchedule, sendToSecondarySchedule_$eq, timeoutSchedule, timeoutSchedule_$eq
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
-
-
-
Constructor Detail
-
WriteAggregator
public WriteAggregator(Key<ReplicatedData> key, akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope, scala.Option<akka.cluster.ddata.Replicator.Internal.Delta> delta, Replicator.WriteConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, ActorRef replyTo, boolean durable)
-
-
Method Detail
-
props
public static Props props(Key<ReplicatedData> key, akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope, scala.Option<akka.cluster.ddata.Replicator.Internal.Delta> delta, Replicator.WriteConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, ActorRef replyTo, boolean durable)
-
nodes
public scala.collection.immutable.Set<UniqueAddress> nodes()
- Specified by:
nodes
in classReadWriteAggregator
-
unreachable
public scala.collection.immutable.Set<UniqueAddress> unreachable()
- Specified by:
unreachable
in classReadWriteAggregator
-
timeout
public scala.concurrent.duration.FiniteDuration timeout()
- Specified by:
timeout
in classReadWriteAggregator
-
doneWhenRemainingSize
public int doneWhenRemainingSize()
- Specified by:
doneWhenRemainingSize
in classReadWriteAggregator
-
writeMsg
public akka.cluster.ddata.Replicator.Internal.Write writeMsg()
-
deltaMsg
public scala.Option<akka.cluster.ddata.Replicator.Internal.DeltaPropagation> deltaMsg()
-
gotLocalStoreReply
public boolean gotLocalStoreReply()
-
gotLocalStoreReply_$eq
public void gotLocalStoreReply_$eq(boolean x$1)
-
gotWriteNackFrom
public scala.collection.immutable.Set<Address> gotWriteNackFrom()
-
gotWriteNackFrom_$eq
public void gotWriteNackFrom_$eq(scala.collection.immutable.Set<Address> x$1)
-
preStart
public void preStart()
Description copied from interface:Actor
User overridable callback. Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
-
senderAddress
public Address senderAddress()
-
isDone
public boolean isDone()
-
notEnoughNodes
public boolean notEnoughNodes()
-
reply
public void reply(boolean isTimeout)
-
-