Class LmdbDurableStore

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

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

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

When the Akka.DistributedData.Replicator needs to store a value it sends a Store message to the durable store actor, which must then reply with the SuccessMessage or FailureMessage to the ReplyTo.

Inheritance
object
ActorBase
UntypedActor
ReceiveActor
LmdbDurableStore
Implements
Inherited Members
Namespace: Akka.DistributedData.LightningDB
Assembly: Akka.DistributedData.LightningDB.dll
Syntax
public sealed class LmdbDurableStore : ReceiveActor, IInternalActor, IInitializableActor, IWithTimers

Constructors

| Edit this page View Source

LmdbDurableStore(Config)

Declaration
public LmdbDurableStore(Config config)
Parameters
Type Name Description
Config config

Fields

| Edit this page View Source

DatabaseName

Declaration
public const string DatabaseName = "ddata"
Field Value
Type Description
string

Properties

| Edit this page View Source

Timers

Gets or sets the TimerScheduler. This will be automatically populated by the framework in base constructor. Implement this as an auto property.

Declaration
public ITimerScheduler Timers { get; set; }
Property Value
Type Description
ITimerScheduler

Methods

| Edit this page View Source

PostRestart(Exception)

User overridable callback: By default it calls PreStart().

Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.
Declaration
protected override void PostRestart(Exception reason)
Parameters
Type Name Description
Exception reason

the Exception that caused the restart to happen.
Overrides
| Edit this page View Source

PostStop()

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
Declaration
protected override void PostStop()
Overrides
| Edit this page View Source

PreStart()

User overridable callback.

Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
Declaration
protected override void PreStart()
Overrides
| Edit this page View Source

Props(Config)

Declaration
public static Props Props(Config config)
Parameters
Type Name Description
Config config
Returns
Type Description
Props

Implements

Extension Methods