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.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
DurableStore.DurableDataEnvelope
Wrapper class for serialization of a data value.static class
DurableStore.Expire
Request to expire (remove) entries.static class
DurableStore.Expire$
static class
DurableStore.LoadAll$
Request to load all entries.static class
DurableStore.LoadAllCompleted$
static class
DurableStore.LoadData
static class
DurableStore.LoadData$
static class
DurableStore.LoadFailed
static class
DurableStore.Store
Request to store an entry.static class
DurableStore.Store$
static class
DurableStore.StoreReply
static class
DurableStore.StoreReply$
-
Constructor Summary
Constructors Constructor Description DurableStore()
-