Class SharedMemoryJournal

Inheritance

object

ActorBase

WriteJournalBase

AsyncWriteJournal

MemoryJournal

SharedMemoryJournal

Implements

IInternalActor

IAsyncRecovery

Inherited Members

MemoryJournal.WriteMessagesAsync(IEnumerable<AtomicWrite>, CancellationToken)

MemoryJournal.ReadHighestSequenceNrAsync(string, long, CancellationToken)

MemoryJournal.ReplayMessagesAsync(IActorContext, string, long, long, long, Action<IPersistentRepresentation>)

MemoryJournal.DeleteMessagesToAsync(string, long, CancellationToken)

MemoryJournal.Add(IPersistentRepresentation)

MemoryJournal.Delete(string, long)

MemoryJournal.Read(string, long, long, long)

MemoryJournal.HighestSequenceNr(string)

MemoryJournal.ReceivePluginInternal(object)

AsyncWriteJournal.CanPublish

AsyncWriteJournal.CheckHealthAsync(CancellationToken)

AsyncWriteJournal.Receive(object)

AsyncWriteJournal.ReceiveWriteJournal(object)

AsyncWriteJournal.TryUnwrapException(Exception)

WriteJournalBase.PreparePersistentBatch(IEnumerable<IPersistentEnvelope>)

WriteJournalBase.AdaptToJournal(IPersistentRepresentation)

ActorBase.Sender

ActorBase.Self

ActorBase.Context

ActorBase.AroundReceive(Receive, object)

ActorBase.EmptyReceive

ActorBase.Unhandled(object)

ActorBase.Become(Receive)

ActorBase.BecomeStacked(Receive)

ActorBase.UnbecomeStacked()

ActorBase.SetReceiveTimeout(TimeSpan?)

ActorBase.AroundPreRestart(Exception, object)

ActorBase.AroundPreStart()

ActorBase.PreStart()

ActorBase.AroundPostRestart(Exception, object)

ActorBase.PreRestart(Exception, object)

ActorBase.PostRestart(Exception)

ActorBase.AroundPostStop()

ActorBase.PostStop()

ActorBase.SupervisorStrategy()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Akka.Persistence.Journal

Assembly: Akka.Persistence.dll

Syntax

public class SharedMemoryJournal : MemoryJournal, IInternalActor, IAsyncRecovery

Properties

DeletedTo

Declaration

protected override Dictionary<string, long> DeletedTo { get; }

Property Value

Type	Description
Dictionary<string, long>

Overrides

MemoryJournal.DeletedTo

EventLog

Declaration

protected override List<IPersistentRepresentation> EventLog { get; }

Property Value

Type	Description
List<IPersistentRepresentation>

Overrides

MemoryJournal.EventLog

EventsByPersistenceId

Declaration

protected override Dictionary<string, List<IPersistentRepresentation>> EventsByPersistenceId { get; }

Property Value

Type	Description
Dictionary<string, List<IPersistentRepresentation>>

Overrides

MemoryJournal.EventsByPersistenceId

Lock

Declaration

protected override ReaderWriterLockSlim Lock { get; }

Property Value

Type	Description
ReaderWriterLockSlim

Overrides

MemoryJournal.Lock

Implements

IInternalActor

IAsyncRecovery

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(object)