Class JournalPerfSpec

This spec measures execution times of the basic operations that an PersistentActor provides, using the provided Journal (plugin).

It is NOT meant to be a comprehensive benchmark, but rather aims to help plugin developers to easily determine if their plugin's performance is roughly as expected. It also validates the plugin still works under "more messages" scenarios.

In case your journal plugin needs some kind of teardown, override the AfterAll method (don't forget to call base in your overridden methods).

Inheritance

object

TestKitBase

TestKit

JournalPerfSpec

Implements

IActorRefFactory

IDisposable

Inherited Members

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.TestKit.Performance

Assembly: Akka.Persistence.TCK.dll

Syntax

public abstract class JournalPerfSpec : TestKit, IActorRefFactory, IDisposable

Constructors

| Edit this page View Source

JournalPerfSpec(Config, string, ITestOutputHelper)

Declaration

protected JournalPerfSpec(Config config, string actorSystem, ITestOutputHelper output)

Parameters

Type	Name	Description
Config	config
string	actorSystem
ITestOutputHelper	output

Fields

| Edit this page View Source

EventsCount

Number of messages sent to the PersistentActor under test for each test iteration

Declaration

protected int EventsCount

Field Value

Type	Description
int

| Edit this page View Source

ExpectDuration

Override in order to customize timeouts used for ExpectMsg, in order to tune the awaits to your journal's perf

Declaration

protected TimeSpan ExpectDuration

Field Value

Type	Description
TimeSpan

| Edit this page View Source

MeasurementIterations

Number of measurement iterations each test will be run.

Declaration

protected int MeasurementIterations

Field Value

Type	Description
int

| Edit this page View Source

OutlierRejectionSigma

Sigma value for the z-score outlier rejection algorithm

Declaration

protected double OutlierRejectionSigma

Field Value

Type	Description
double

Methods

| Edit this page View Source

PersistenceActor_performance_must_measure_Persist()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_Persist()

| Edit this page View Source

PersistenceActor_performance_must_measure_PersistAll()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_PersistAll()

| Edit this page View Source

PersistenceActor_performance_must_measure_PersistAllAsync()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_PersistAllAsync()

| Edit this page View Source

PersistenceActor_performance_must_measure_PersistAsync()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_PersistAsync()

| Edit this page View Source

PersistenceActor_performance_must_measure_PersistGroup10()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_PersistGroup10()

| Edit this page View Source

PersistenceActor_performance_must_measure_PersistGroup100()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_PersistGroup100()

| Edit this page View Source

PersistenceActor_performance_must_measure_PersistGroup200()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_PersistGroup200()

| Edit this page View Source

PersistenceActor_performance_must_measure_PersistGroup25()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_PersistGroup25()

| Edit this page View Source

PersistenceActor_performance_must_measure_PersistGroup50()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_PersistGroup50()

| Edit this page View Source

PersistenceActor_performance_must_measure_Recovering()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_Recovering()

| Edit this page View Source

PersistenceActor_performance_must_measure_RecoveringFour()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_RecoveringFour()

| Edit this page View Source

PersistenceActor_performance_must_measure_RecoveringTwo()

Declaration

[Fact]
public void PersistenceActor_performance_must_measure_RecoveringTwo()

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)