|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface 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 setup or teardown, override the beforeAll
or afterAll
methods (don't forget to call super
in your overriden methods).
For a Java and JUnit consumable version of the TCK please refer to JavaJournalPerfSpec
.
JournalSpec
Nested Class Summary | |
---|---|
static class |
JournalPerfSpec.BenchActor
|
static class |
JournalPerfSpec.Cmd
|
static class |
JournalPerfSpec.Cmd$
|
static class |
JournalPerfSpec.ResetCounter$
|
Method Summary | |
---|---|
scala.concurrent.duration.FiniteDuration |
awaitDuration()
Override in order to customize timeouts used for expectMsg, in order to tune the awaits to your journal's perf |
long |
awaitDurationMillis()
Override in order to customize timeouts used for expectMsg, in order to tune the awaits to your journal's perf |
ActorRef |
benchActor(int replyAfter)
|
scala.collection.immutable.Vector<java.lang.Object> |
commands()
|
int |
eventsCount()
Numbe of messages sent to the PersistentActor under test for each test iteration |
void |
feedAndExpectLast(ActorRef actor,
java.lang.String mode,
scala.collection.immutable.Seq<java.lang.Object> cmnds)
|
void |
measure(scala.Function1<scala.concurrent.duration.Duration,java.lang.String> msg,
scala.Function0<scala.runtime.BoxedUnit> block)
Executes a block of code multiple times (no warmup) |
int |
measurementIterations()
Number of measurement iterations each test will be run. |
TestProbe |
testProbe()
|
Methods inherited from interface akka.persistence.PluginSpec |
---|
_extension, _pid, actorInstanceId, afterAll, beforeAll, beforeEach, config, counter, extension, pid, subscribe |
Method Detail |
---|
TestProbe testProbe()
ActorRef benchActor(int replyAfter)
void feedAndExpectLast(ActorRef actor, java.lang.String mode, scala.collection.immutable.Seq<java.lang.Object> cmnds)
void measure(scala.Function1<scala.concurrent.duration.Duration,java.lang.String> msg, scala.Function0<scala.runtime.BoxedUnit> block)
long awaitDurationMillis()
scala.concurrent.duration.FiniteDuration awaitDuration()
int eventsCount()
int measurementIterations()
scala.collection.immutable.Vector<java.lang.Object> commands()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |