Package akka.cluster.ddata
Class ReadAggregator
- java.lang.Object
-
- akka.cluster.ddata.ReadWriteAggregator
-
- akka.cluster.ddata.ReadAggregator
-
- All Implemented Interfaces:
Actor
public class ReadAggregator extends ReadWriteAggregator
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 ReadAggregator(Key<ReplicatedData> key, Replicator.ReadConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> localValue, ActorRef replyTo)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
doneWhenRemainingSize()
scala.collection.immutable.Set<UniqueAddress>
nodes()
void
preStart()
User overridable callback.static Props
props(Key<ReplicatedData> key, Replicator.ReadConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> localValue, ActorRef replyTo)
akka.cluster.ddata.Replicator.Internal.Read
readMsg()
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 ok)
scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope>
result()
void
result_$eq(scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> x$1)
scala.concurrent.duration.FiniteDuration
timeout()
scala.collection.immutable.Set<UniqueAddress>
unreachable()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
waitReadRepairAck(akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope)
-
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
-
-
-
-
Constructor Detail
-
ReadAggregator
public ReadAggregator(Key<ReplicatedData> key, Replicator.ReadConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> localValue, ActorRef replyTo)
-
-
Method Detail
-
props
public static Props props(Key<ReplicatedData> key, Replicator.ReadConsistency consistency, scala.Option<java.lang.Object> req, UniqueAddress selfUniqueAddress, scala.collection.immutable.Set<UniqueAddress> nodes, scala.collection.immutable.Set<UniqueAddress> unreachable, scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> localValue, ActorRef replyTo)
-
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
-
result
public scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> result()
-
result_$eq
public void result_$eq(scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> x$1)
-
doneWhenRemainingSize
public int doneWhenRemainingSize()
- Specified by:
doneWhenRemainingSize
in classReadWriteAggregator
-
readMsg
public akka.cluster.ddata.Replicator.Internal.Read readMsg()
-
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.- Returns:
- (undocumented)
-
reply
public void reply(boolean ok)
-
waitReadRepairAck
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitReadRepairAck(akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope)
-
-