Search Results for

    Show / Hide Table of Contents

    Class WriteJournalBase

    TBD

    Inheritance
    Object
    ActorBase
    WriteJournalBase
    AsyncWriteJournal
    BatchingSqlJournal<TConnection, TCommand>
    Implements
    IInternalActor
    Inherited Members
    ActorBase.Sender
    ActorBase.Self
    ActorBase.IInternalActor.ActorContext
    ActorBase.Context
    ActorBase.AroundReceive(Receive, Object)
    ActorBase.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.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 abstract class WriteJournalBase : ActorBase, IInternalActor

    Constructors

    | Improve this Doc View Source

    WriteJournalBase()

    TBD

    Declaration
    protected WriteJournalBase()

    Methods

    | Improve this Doc View Source

    AdaptToJournal(IPersistentRepresentation)

    INTERNAL API

    Declaration
    protected IPersistentRepresentation AdaptToJournal(IPersistentRepresentation representation)
    Parameters
    Type Name Description
    IPersistentRepresentation representation
    Returns
    Type Description
    IPersistentRepresentation
    | Improve this Doc View Source

    PreparePersistentBatch(IEnumerable<IPersistentEnvelope>)

    TBD

    Declaration
    protected IEnumerable<AtomicWrite> PreparePersistentBatch(IEnumerable<IPersistentEnvelope> resequenceables)
    Parameters
    Type Name Description
    IEnumerable<IPersistentEnvelope> resequenceables

    TBD

    Returns
    Type Description
    IEnumerable<AtomicWrite>

    TBD

    Implements

    IInternalActor

    Extension Methods

    ObjectExtensions.IsDefaultForType<T>(T)
    PatternMatch.Match(Object)
    PatternMatch.Match<T>(Object)
    ObjectExtensions.AsOption<T>(T)
    Extensions.AsInstanceOf<T>(Object)
    In This Article
    • githubImprove this Doc
    • View Source
    Back to top
    Contribute
    • Project Chat
    • Discussion Forum
    • Source Code
    Support
    • Akka.NET Support Plans
    • Akka.NET Observability Tools
    • Akka.NET Training & Consulting
    Maintained By
    • Petabridge - The Akka.NET Company
    • Learn Akka.NET