Search Results for

    Show / Hide Table of Contents

    Class ReplayFilter

    Detect corrupt event stream during replay. It uses the WriterGuid and the SequenceNr in the replayed events to find events emitted by overlapping writers.

    Inheritance
    Object
    ActorBase
    ReplayFilter
    Implements
    IInternalActor
    Inherited Members
    ActorBase.Sender
    ActorBase.Self
    ActorBase.IInternalActor.ActorContext
    ActorBase.Context
    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.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 ReplayFilter : ActorBase, IInternalActor

    Constructors

    | Improve this Doc View Source

    ReplayFilter(IActorRef, ReplayFilterMode, Int32, Int32, Boolean)

    TBD

    Declaration
    public ReplayFilter(IActorRef persistentActor, ReplayFilterMode mode, int windowSize, int maxOldWriters, bool debugEnabled)
    Parameters
    Type Name Description
    IActorRef persistentActor

    TBD

    ReplayFilterMode mode

    TBD

    Int32 windowSize

    TBD

    Int32 maxOldWriters

    TBD

    Boolean debugEnabled

    TBD

    Properties

    | Improve this Doc View Source

    DebugEnabled

    TBD

    Declaration
    public bool DebugEnabled { get; }
    Property Value
    Type Description
    Boolean
    | Improve this Doc View Source

    MaxOldWriters

    TBD

    Declaration
    public int MaxOldWriters { get; }
    Property Value
    Type Description
    Int32
    | Improve this Doc View Source

    Mode

    TBD

    Declaration
    public ReplayFilterMode Mode { get; }
    Property Value
    Type Description
    ReplayFilterMode
    | Improve this Doc View Source

    PersistentActor

    TBD

    Declaration
    public IActorRef PersistentActor { get; }
    Property Value
    Type Description
    IActorRef
    | Improve this Doc View Source

    WindowSize

    TBD

    Declaration
    public int WindowSize { get; }
    Property Value
    Type Description
    Int32

    Methods

    | Improve this Doc View Source

    Props(IActorRef, ReplayFilterMode, Int32, Int32, Boolean)

    TBD

    Declaration
    public static Props Props(IActorRef persistentActor, ReplayFilterMode mode, int windowSize, int maxOldWriters, bool debugEnabled)
    Parameters
    Type Name Description
    IActorRef persistentActor

    TBD

    ReplayFilterMode mode

    TBD

    Int32 windowSize

    TBD

    Int32 maxOldWriters

    TBD

    Boolean debugEnabled

    TBD

    Returns
    Type Description
    Props

    TBD

    Exceptions
    Type Condition
    ArgumentNullException

    This exception is thrown for a number of reasons. These include:

    • The specified windowSize is less than or equal to zero.
    • The specified maxOldWriters is less than or equal to zero.
    • The specified mode is Disabled.

    | Improve this Doc View Source

    Receive(Object)

    TBD

    Declaration
    protected override bool Receive(object message)
    Parameters
    Type Name Description
    Object message

    TBD

    Returns
    Type Description
    Boolean

    TBD

    Overrides
    ActorBase.Receive(Object)
    Exceptions
    Type Condition
    ArgumentException

    This exception is thrown when the Mode is set to Disabled.

    IllegalStateException

    This exception is thrown when either the replayed event is in the wrong order or from an old writer.

    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