Search Results for

    Show / Hide Table of Contents

    Class SnapshotStoreSerializationSpec

    Inheritance
    object
    TestKitBase
    TestKit
    PluginSpec
    SnapshotStoreSerializationSpec
    Implements
    IActorRefFactory
    IDisposable
    Inherited Members
    PluginSpec.ActorInstanceId
    PluginSpec.FromConfig(Config)
    PluginSpec.SupportsSerialization
    PluginSpec.Extension
    PluginSpec.Pid
    PluginSpec.WriterGuid
    PluginSpec.Subscribe<T>(IActorRef)
    TestKit.Output
    TestKit.DefaultConfig
    TestKit.FullDebugConfig
    TestKit.Assertions
    TestKit.AfterAll()
    TestKit.InitializeLogger(ActorSystem)
    TestKit.InitializeLogger(ActorSystem, string)
    TestKit.Dispose(bool)
    TestKit.Dispose()
    TestKitBase.InitializeTest(ActorSystem, ActorSystemSetup, string, string)
    TestKitBase.InitializeTest(ActorSystem, Config, string, string)
    TestKitBase.Sys
    TestKitBase.TestKitSettings
    TestKitBase.LastSender
    TestKitBase.Now
    TestKitBase.Log
    TestKitBase.LastMessage
    TestKitBase.TestActor
    TestKitBase.EventFilter
    TestKitBase.CreateEventFilter(ActorSystem)
    TestKitBase.HasMessages
    TestKitBase.IgnoreMessages(Func<object, bool>)
    TestKitBase.IgnoreMessages<TMsg>(Func<TMsg, bool>)
    TestKitBase.IgnoreMessages<TMsg>()
    TestKitBase.IgnoreNoMessages()
    TestKitBase.Watch(IActorRef)
    TestKitBase.WatchAsync(IActorRef)
    TestKitBase.Unwatch(IActorRef)
    TestKitBase.UnwatchAsync(IActorRef)
    TestKitBase.SetAutoPilot(AutoPilot)
    TestKitBase.RemainingOrDefault
    TestKitBase.Remaining
    TestKitBase.RemainingOr(TimeSpan)
    TestKitBase.RemainingOrDilated(TimeSpan?)
    TestKitBase.Dilated(TimeSpan)
    TestKitBase.GetTimeoutOrDefault(TimeSpan?)
    TestKitBase.Shutdown(TimeSpan?, bool)
    TestKitBase.Shutdown(ActorSystem, TimeSpan?, bool)
    TestKitBase.ChildActorOf(Props, string, SupervisorStrategy, CancellationToken)
    TestKitBase.ChildActorOfAsync(Props, string, SupervisorStrategy, CancellationToken)
    TestKitBase.ChildActorOf(Props, SupervisorStrategy, CancellationToken)
    TestKitBase.ChildActorOfAsync(Props, SupervisorStrategy, CancellationToken)
    TestKitBase.ChildActorOf(Props, string, CancellationToken)
    TestKitBase.ChildActorOfAsync(Props, string, CancellationToken)
    TestKitBase.ChildActorOf(Props, CancellationToken)
    TestKitBase.ChildActorOfAsync(Props, CancellationToken)
    TestKitBase.CreateTestActor(string)
    TestKitBase.CreateTestProbe(string)
    TestKitBase.CreateTestProbe(ActorSystem, string)
    TestKitBase.CreateTestLatch(int)
    TestKitBase.CreateTestBarrier(int)
    TestKitBase.ActorOf(Props)
    TestKitBase.ActorOf(Props, string)
    TestKitBase.ActorOf<TActor>()
    TestKitBase.ActorOf<TActor>(string)
    TestKitBase.ActorOf<TActor>(Expression<Func<TActor>>)
    TestKitBase.ActorOf<TActor>(Expression<Func<TActor>>, string)
    TestKitBase.ActorOf(Action<IActorDsl, IActorContext>, string)
    TestKitBase.ActorOf(Action<IActorDsl>, string)
    TestKitBase.ActorSelection(ActorPath)
    TestKitBase.ActorSelection(string)
    TestKitBase.ActorSelection(IActorRef, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(Props, IActorRef, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(Props, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(Expression<Func<TActor>>, IActorRef, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(Expression<Func<TActor>>, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(IActorRef, string)
    TestKitBase.ActorOfAsTestActorRef<TActor>(string)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Props, IActorRef, string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Props, string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(IActorRef, string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Expression<Func<TFsmActor>>, IActorRef, string, bool)
    TestKitBase.ActorOfAsTestFSMRef<TFsmActor, TState, TData>(Expression<Func<TFsmActor>>, string, bool)
    TestKitBase.AwaitAssert(Action, TimeSpan?, TimeSpan?, CancellationToken)
    TestKitBase.AwaitAssertAsync(Action, TimeSpan?, TimeSpan?, CancellationToken)
    TestKitBase.AwaitAssertAsync(Func<Task>, TimeSpan?, TimeSpan?, CancellationToken)
    TestKitBase.AwaitCondition(Func<bool>, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<Task<bool>>, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<bool>, CancellationToken)
    TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, CancellationToken)
    TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitCondition(Func<bool>, TimeSpan?, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<Task<bool>>, TimeSpan?, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionAsync(Func<bool>, TimeSpan?, TimeSpan?, string, CancellationToken)
    TestKitBase.AwaitConditionNoThrow(Func<bool>, TimeSpan, TimeSpan?, CancellationToken)
    TestKitBase.AwaitConditionNoThrowAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, CancellationToken)
    TestKitBase.AwaitConditionNoThrowAsync(Func<bool>, TimeSpan, TimeSpan?, CancellationToken)
    TestKitBase.InternalAwaitCondition(Func<bool>, TimeSpan, TimeSpan?, Action<string, object[]>, CancellationToken)
    TestKitBase.InternalAwaitConditionAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, Action<string, object[]>, CancellationToken)
    TestKitBase.InternalAwaitCondition(Func<bool>, TimeSpan, TimeSpan?, Action<string, object[]>, ILoggingAdapter, CancellationToken)
    TestKitBase.InternalAwaitConditionAsync(Func<Task<bool>>, TimeSpan, TimeSpan?, Action<string, object[]>, ILoggingAdapter, CancellationToken)
    TestKitBase.ExpectMsg<T>(TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(T, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(T, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(Func<T, IActorRef, bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(Func<T, IActorRef, bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(Action<T, IActorRef>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(Action<T, IActorRef>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsg<T>(T, Func<T, T, bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgAsync<T>(T, Func<T, T, bool>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectTerminated(IActorRef, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectTerminatedAsync(IActorRef, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectNoMsg(CancellationToken)
    TestKitBase.ExpectNoMsgAsync(CancellationToken)
    TestKitBase.ExpectNoMsg(TimeSpan, CancellationToken)
    TestKitBase.ExpectNoMsgAsync(TimeSpan, CancellationToken)
    TestKitBase.ExpectNoMsg(int, CancellationToken)
    TestKitBase.ExpectNoMsgAsync(int, CancellationToken)
    TestKitBase.ExpectMsgAnyOf<T>(IEnumerable<T>, CancellationToken)
    TestKitBase.ExpectMsgAnyOfAsync<T>(IEnumerable<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOf<T>(params T[])
    TestKitBase.ExpectMsgAllOf<T>(IReadOnlyCollection<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOfAsync<T>(IReadOnlyCollection<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOf<T>(TimeSpan, params T[])
    TestKitBase.ExpectMsgAllOf<T>(TimeSpan, IReadOnlyCollection<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOfAsync<T>(TimeSpan, IReadOnlyCollection<T>, CancellationToken)
    TestKitBase.ExpectMsgAllOfMatchingPredicates(params PredicateInfo[])
    TestKitBase.ExpectMsgAllOfMatchingPredicates(IReadOnlyCollection<PredicateInfo>, CancellationToken)
    TestKitBase.ExpectMsgAllOfMatchingPredicatesAsync(IReadOnlyCollection<PredicateInfo>, CancellationToken)
    TestKitBase.ExpectMsgAllOfMatchingPredicates(TimeSpan, params PredicateInfo[])
    TestKitBase.ExpectMsgAllOfMatchingPredicates(TimeSpan, IReadOnlyCollection<PredicateInfo>, CancellationToken)
    TestKitBase.ExpectMsgAllOfMatchingPredicatesAsync(TimeSpan, IReadOnlyCollection<PredicateInfo>, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(IActorRef, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(IActorRef, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(IActorRef, T, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(IActorRef, T, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(IActorRef, Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(Predicate<IActorRef>, Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(Predicate<IActorRef>, Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(IActorRef, Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(IActorRef, Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFrom<T>(Action<IActorRef>, Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.ExpectMsgFromAsync<T>(Action<IActorRef>, Action<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessage(Predicate<object>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessageAsync(Predicate<object>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessage<T>(Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessageAsync<T>(Predicate<T>, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessage<T>(Predicate<T>, ArrayList, TimeSpan?, string, CancellationToken)
    TestKitBase.FishForMessageAsync<T>(Predicate<T>, ArrayList, TimeSpan?, string, CancellationToken)
    TestKitBase.FishUntilMessageAsync<T>(TimeSpan?, CancellationToken)
    TestKitBase.WaitForRadioSilenceAsync(TimeSpan?, uint?, CancellationToken)
    TestKitBase.ReceiveOne(TimeSpan?, CancellationToken)
    TestKitBase.ReceiveOneAsync(TimeSpan?, CancellationToken)
    TestKitBase.TryReceiveOne(out MessageEnvelope, TimeSpan?, CancellationToken)
    TestKitBase.TryReceiveOneAsync(TimeSpan?, CancellationToken)
    TestKitBase.PeekOne(TimeSpan?, CancellationToken)
    TestKitBase.PeekOneAsync(TimeSpan?, CancellationToken)
    TestKitBase.PeekOne(CancellationToken)
    TestKitBase.PeekOneAsync(CancellationToken)
    TestKitBase.TryPeekOne(out MessageEnvelope, TimeSpan?, CancellationToken)
    TestKitBase.TryPeekOneAsync(TimeSpan?, CancellationToken)
    TestKitBase.ReceiveWhile<T>(TimeSpan?, Func<object, T>, int, CancellationToken)
    TestKitBase.ReceiveWhileAsync<T>(TimeSpan?, Func<object, T>, int, CancellationToken)
    TestKitBase.ReceiveWhile<T>(TimeSpan?, TimeSpan?, Func<object, T>, int, CancellationToken)
    TestKitBase.ReceiveWhileAsync<T>(TimeSpan?, TimeSpan?, Func<object, T>, int, CancellationToken)
    TestKitBase.ReceiveWhile<T>(Func<object, T>, TimeSpan?, TimeSpan?, int, CancellationToken)
    TestKitBase.ReceiveWhileAsync<T>(Func<object, T>, TimeSpan?, TimeSpan?, int, CancellationToken)
    TestKitBase.ReceiveWhile<T>(Predicate<T>, TimeSpan?, TimeSpan?, int, bool, CancellationToken)
    TestKitBase.ReceiveWhileAsync<T>(Predicate<T>, TimeSpan?, TimeSpan?, int, bool, CancellationToken)
    TestKitBase.ReceiveN(int, CancellationToken)
    TestKitBase.ReceiveNAsync(int, CancellationToken)
    TestKitBase.ReceiveN(int, TimeSpan, CancellationToken)
    TestKitBase.ReceiveNAsync(int, TimeSpan, CancellationToken)
    TestKitBase.Within(TimeSpan, Action, TimeSpan?, CancellationToken)
    TestKitBase.WithinAsync(TimeSpan, Func<Task>, TimeSpan?, CancellationToken)
    TestKitBase.Within(TimeSpan, TimeSpan, Action, string, TimeSpan?, CancellationToken)
    TestKitBase.WithinAsync(TimeSpan, TimeSpan, Func<Task>, string, TimeSpan?, CancellationToken)
    TestKitBase.Within<T>(TimeSpan, Func<T>, TimeSpan?, CancellationToken)
    TestKitBase.WithinAsync<T>(TimeSpan, Func<Task<T>>, TimeSpan?, CancellationToken)
    TestKitBase.Within<T>(TimeSpan, TimeSpan, Func<T>, string, TimeSpan?, CancellationToken)
    TestKitBase.WithinAsync<T>(TimeSpan, TimeSpan, Func<Task<T>>, string, TimeSpan?, CancellationToken)
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Akka.Persistence.TCK.Serialization
    Assembly: Akka.Persistence.TCK.dll
    Syntax
    public abstract class SnapshotStoreSerializationSpec : PluginSpec, IActorRefFactory, IDisposable

    Constructors

    | Edit this page View Source

    SnapshotStoreSerializationSpec(ActorSystemSetup, string, ITestOutputHelper)

    Declaration
    protected SnapshotStoreSerializationSpec(ActorSystemSetup setup, string actorSystem, ITestOutputHelper output)
    Parameters
    Type Name Description
    ActorSystemSetup setup
    string actorSystem
    ITestOutputHelper output
    | Edit this page View Source

    SnapshotStoreSerializationSpec(Config, string, ITestOutputHelper)

    Declaration
    protected SnapshotStoreSerializationSpec(Config config, string actorSystem, ITestOutputHelper output)
    Parameters
    Type Name Description
    Config config
    string actorSystem
    ITestOutputHelper output

    Properties

    | Edit this page View Source

    SnapshotStore

    Declaration
    protected IActorRef SnapshotStore { get; }
    Property Value
    Type Description
    IActorRef

    Methods

    | Edit this page View Source

    FromActorSystemSetup(ActorSystemSetup)

    Declaration
    protected static ActorSystemSetup FromActorSystemSetup(ActorSystemSetup setup)
    Parameters
    Type Name Description
    ActorSystemSetup setup
    Returns
    Type Description
    ActorSystemSetup
    | Edit this page View Source

    SnapshotStore_should_serialize_AtLeastOnceDeliverySnapshot()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_serialize_AtLeastOnceDeliverySnapshot()
    | Edit this page View Source

    SnapshotStore_should_serialize_AtLeastOnceDeliverySnapshot_with_empty_unconfirmed()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_serialize_AtLeastOnceDeliverySnapshot_with_empty_unconfirmed()
    | Edit this page View Source

    SnapshotStore_should_serialize_Payload()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_serialize_Payload()
    | Edit this page View Source

    SnapshotStore_should_serialize_Payload_with_string_manifest()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_serialize_Payload_with_string_manifest()
    | Edit this page View Source

    SnapshotStore_should_serialize_PersistentFSMSnapshot()

    Declaration
    [Fact]
    public virtual void SnapshotStore_should_serialize_PersistentFSMSnapshot()

    Implements

    IActorRefFactory
    IDisposable

    Extension Methods

    ActorRefFactoryExtensions.ActorOf<TActor>(IActorRefFactory, string)
    ActorRefFactoryExtensions.ActorSelection(IActorRefFactory, IActorRef, string)
    ActExtensions.ActorOf(IActorRefFactory, Action<IActorDsl, IActorContext>, string)
    ActExtensions.ActorOf(IActorRefFactory, Action<IActorDsl>, string)
    ActorMaterializerExtensions.Materializer(IActorRefFactory, ActorMaterializerSettings, string)
    ObjectExtensions.IsDefaultForType<T>(T)
    ObjectExtensions.AsOption<T>(T)
    TestPublisher.CreateManualPublisherProbe<T>(TestKitBase, bool)
    TestPublisher.CreatePublisherProbe<T>(TestKitBase, long)
    TestSink.SinkProbe<T>(TestKitBase)
    TestSource.SourceProbe<T>(TestKitBase)
    TestSubscriber.CreateManualSubscriberProbe<T>(TestKitBase)
    TestSubscriber.CreateSubscriberProbe<T>(TestKitBase)
    Utils.AssertAllStagesStopped(TestKitBase, Action, IMaterializer, TimeSpan?, CancellationToken)
    Utils.AssertAllStagesStoppedAsync(TestKitBase, Func<Task>, IMaterializer, TimeSpan?, CancellationToken)
    Utils.AssertAllStagesStoppedAsync<T>(TestKitBase, Func<Task<T>>, IMaterializer, TimeSpan?, CancellationToken)
    Utils.AssertAllStagesStopped<T>(TestKitBase, Func<T>, IMaterializer, TimeSpan?, CancellationToken)
    Extensions.AsInstanceOf<T>(object)
    In this article
    • githubEdit this page
    • 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