Package org.apache.pekko.cluster.ddata

Class DurableStore

java.lang.Object

org.apache.pekko.cluster.ddata.DurableStore

public class DurableStore
extends Object

An actor implementing the durable store for the Distributed Data Replicator has to implement the protocol with the messages defined here.

At startup the Replicator creates the durable store actor and sends the Load message to it. It must then reply with 0 or more LoadData messages followed by one LoadAllCompleted message to the sender (the Replicator).

If the LoadAll fails it can throw LoadFailed and the Replicator supervisor will stop itself and the durable store.

When the Replicator needs to store a value it sends a Store message to the durable store actor, which must then reply with the successMsg or failureMsg to the replyTo.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DurableStore.DurableDataEnvelope	Wrapper class for serialization of a data value.
static class	DurableStore.LoadAll$	Request to load all entries.
static class	DurableStore.LoadAllCompleted$
static final class	DurableStore.LoadData
static class	DurableStore.LoadData$
static class	DurableStore.LoadFailed
static final class	DurableStore.Store	Request to store an entry.
static class	DurableStore.Store$
static final class	DurableStore.StoreReply
static class	DurableStore.StoreReply$

Constructor Summary

Constructors

Constructor	Description
DurableStore()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DurableStore

public DurableStore()