Package akka.cluster.ddata
Class DurableStore$
- java.lang.Object
-
- akka.cluster.ddata.DurableStore$
-
public class DurableStore$ extends java.lang.Object
An actor implementing the durable store for the Distributed DataReplicator
has to implement the protocol with the messages defined here.At startup the
Replicator
creates the durable store actor and sends theLoad
message to it. It must then reply with 0 or moreLoadData
messages followed by oneLoadAllCompleted
message to thesender
(theReplicator
).If the
LoadAll
fails it can throwLoadFailed
and theReplicator
supervisor will stop itself and the durable store.When the
Replicator
needs to store a value it sends aStore
message to the durable store actor, which must then reply with thesuccessMsg
orfailureMsg
to thereplyTo
.When entries have expired the
Replicator
sends aExpire
message 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.
-
-