Class JournalPerfSpec

  • All Implemented Interfaces:
    CapabilityFlags, JournalCapabilityFlags, MayVerb, OptionalTests, TestKitBase, java.io.Serializable, org.scalactic.Explicitly, org.scalactic.Tolerance, org.scalactic.TripleEquals, org.scalactic.TripleEqualsSupport, org.scalatest.Alerting, org.scalatest.Assertions, org.scalatest.BeforeAndAfterAll, org.scalatest.BeforeAndAfterEach, org.scalatest.Documenting, org.scalatest.Informing, org.scalatest.Matchers, org.scalatest.Notifying, org.scalatest.Suite, org.scalatest.SuiteMixin, org.scalatest.TestRegistration, org.scalatest.TestSuite, org.scalatest.words.CanVerb, org.scalatest.words.MatcherWords, org.scalatest.words.MustVerb, org.scalatest.words.ShouldVerb, org.scalatest.WordSpecLike, scala.Serializable
    Direct Known Subclasses:
    JavaJournalPerfSpec

    public abstract class JournalPerfSpec
    extends JournalSpec
    Executes a block of code multiple times (no warm-up)
    See Also:
    Serialized Form
    • Constructor Detail

      • JournalPerfSpec

        public JournalPerfSpec​(com.typesafe.config.Config config)
    • Method Detail

      • benchActor

        public ActorRef benchActor​(int replyAfter)
      • feedAndExpectLast

        public void feedAndExpectLast​(ActorRef actor,
                                      java.lang.String mode,
                                      scala.collection.immutable.Seq<java.lang.Object> cmnds)
      • measure

        public 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 warm-up)
      • awaitDurationMillis

        public long awaitDurationMillis()
        Override in order to customize timeouts used for expectMsg, in order to tune the awaits to your journal's perf
      • eventsCount

        public int eventsCount()
        Number of messages sent to the PersistentActor under test for each test iteration
      • measurementIterations

        public int measurementIterations()
        Number of measurement iterations each test will be run.