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

IInternalActor

IInitializableActor

IWithTimers

Inherited Members

ReceiveActor.IInitializableActor.Init()

ReceiveActor.OnReceive(Object)

ReceiveActor.Become(Action)

ReceiveActor.BecomeStacked(Action)

ReceiveActor.ReceiveAsync<T>(Func<T, Task>, Predicate<T>)

ReceiveActor.ReceiveAsync<T>(Predicate<T>, Func<T, Task>)

ReceiveActor.ReceiveAsync(Type, Func<Object, Task>, Predicate<Object>)

ReceiveActor.ReceiveAsync(Type, Predicate<Object>, Func<Object, Task>)

ReceiveActor.ReceiveAnyAsync(Func<Object, Task>)

ReceiveActor.Receive<T>(Action<T>, Predicate<T>)

ReceiveActor.Receive<T>(Predicate<T>, Action<T>)

ReceiveActor.Receive(Type, Action<Object>, Predicate<Object>)

ReceiveActor.Receive(Type, Predicate<Object>, Action<Object>)

ReceiveActor.Receive<T>(Func<T, Boolean>)

ReceiveActor.Receive(Type, Func<Object, Boolean>)

ReceiveActor.ReceiveAny(Action<Object>)

UntypedActor.Receive(Object)

UntypedActor.RunTask(Action)

UntypedActor.RunTask(Func<Task>)

UntypedActor.Become(UntypedReceive)

UntypedActor.BecomeStacked(UntypedReceive)

UntypedActor.Context

ActorBase.Sender

ActorBase.Self

ActorBase.IInternalActor.ActorContext

ActorBase.AroundReceive(Receive, Object)

ActorBase.EmptyReceive

ActorBase.Unhandled(Object)

ActorBase.Become(Receive)

ActorBase.BecomeStacked(Receive)

ActorBase.UnbecomeStacked()

ActorBase.SetReceiveTimeout(Nullable<TimeSpan>)

ActorBase.AroundPreRestart(Exception, Object)

ActorBase.AroundPreStart()

ActorBase.AroundPostRestart(Exception, Object)

ActorBase.PreRestart(Exception, Object)

ActorBase.AroundPostStop()

ActorBase.SupervisorStrategy()

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.DistributedData.LightningDB

Assembly: Akka.DistributedData.LightningDB.dll

Syntax

public sealed class LmdbDurableStore : ReceiveActor, IInternalActor, IInitializableActor, IWithTimers

Constructors

LmdbDurableStore(Config)

Declaration

public LmdbDurableStore(Config config)

Parameters

Type	Name	Description
Config	config

Fields

DatabaseName

Declaration

public const string DatabaseName = "ddata"

Field Value

Type	Description
String

Properties

Timers

Declaration

public ITimerScheduler Timers { get; set; }

Property Value

Type	Description
ITimerScheduler

Methods

PostRestart(Exception)

Declaration

protected override void PostRestart(Exception reason)

Parameters

Type	Name	Description
Exception	reason

Overrides

ActorBase.PostRestart(Exception)

PostStop()

Declaration

protected override void PostStop()

Overrides

ActorBase.PostStop()

PreStart()

Declaration

protected override void PreStart()

Overrides

ActorBase.PreStart()

Props(Config)

Declaration

public static Props Props(Config config)

Parameters

Type	Name	Description
Config	config

Returns

Type	Description
Props

Implements

IInternalActor

IInitializableActor

IWithTimers

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)