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