Package akka.cluster.ddata
Class DurableStore$
- java.lang.Object
-
- akka.cluster.ddata.DurableStore$
-
public class DurableStore$ extends java.lang.ObjectAn actor implementing the durable store for the Distributed DataReplicatorhas to implement the protocol with the messages defined here.At startup the
Replicatorcreates the durable store actor and sends theLoadmessage to it. It must then reply with 0 or moreLoadDatamessages followed by oneLoadAllCompletedmessage to thesender(theReplicator).If the
LoadAllfails it can throwLoadFailedand theReplicatorsupervisor will stop itself and the durable store.When the
Replicatorneeds to store a value it sends aStoremessage to the durable store actor, which must then reply with thesuccessMsgorfailureMsgto thereplyTo.When entries have expired the
Replicatorsends aExpiremessage to the durable store actor, which can delete the entries from the backend store.
-
-
Field Summary
Fields Modifier and Type Field Description static DurableStore$MODULE$Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description DurableStore$()
-
-
-
Field Detail
-
MODULE$
public static final DurableStore$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-