Package org.apache.pekko.cluster.ddata
Class DurableStore$
- java.lang.Object
-
- org.apache.pekko.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.
-
-
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.
-
-