package testkit

Content Hierarchy
Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package internal
  2. package javadsl
  3. package query
  4. package scaladsl

Type Members

  1. final case class DeleteEvents(toSeqNumber: Long) extends JournalOperation with Product with Serializable

    Delete events in the journal up to toSeqNumber operation.

  2. sealed abstract class DeleteSnapshot extends SnapshotOperation

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  3. final case class DeleteSnapshotByMeta(metadata: SnapshotMeta) extends DeleteSnapshot with Product with Serializable

    Delete particular snapshot from storage by its metadata.

  4. final case class DeleteSnapshotsByCriteria(criteria: SnapshotSelectionCriteria) extends DeleteSnapshot with Product with Serializable

    Delete snapshots from storage by criteria.

  5. sealed abstract class ExpectedFailure extends Throwable with NoStackTrace
  6. sealed abstract class ExpectedRejection extends Throwable
  7. sealed trait JournalOperation extends AnyRef

    INTERNAL API

    INTERNAL API

    Persistent journal operations.

    Annotations
    @InternalApi()
  8. class PersistenceTestKitPlugin extends AsyncWriteJournal with ActorLogging

    INTERNAL API

    INTERNAL API

    Persistence testkit plugin for events.

    Annotations
    @InternalApi()
  9. class PersistenceTestKitSnapshotPlugin extends SnapshotStore

    INTERNAL API

    INTERNAL API

    Persistence testkit plugin for snapshots.

    Annotations
    @InternalApi()
  10. sealed trait ProcessingFailure extends ProcessingResult
  11. trait ProcessingPolicy[U] extends AnyRef

    Policies allow to emulate behavior of the storage (failures and rejections).

    Policies allow to emulate behavior of the storage (failures and rejections).

    U

    type determines operations which storage can perform.

    Annotations
    @ApiMayChange()
  12. sealed trait ProcessingResult extends AnyRef

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  13. sealed abstract class ProcessingSuccess extends ProcessingResult
  14. final case class ReadEvents(batch: Seq[Any]) extends JournalOperation with Product with Serializable

    Read from journal operation with events that were read.

  15. final case class ReadSnapshot(criteria: SnapshotSelectionCriteria, snapshot: Option[Any]) extends SnapshotOperation with Product with Serializable

    Storage read operation for recovery of the persistent actor.

    Storage read operation for recovery of the persistent actor.

    criteria

    criteria with which snapshot is searched

    snapshot

    snapshot found by criteria

  16. final case class Reject(error: Throwable = ExpectedRejection) extends ProcessingFailure with Product with Serializable

    Emulates rejection of operation by the journal with error exception.

    Emulates rejection of operation by the journal with error exception. Has the same meaning as StorageFailure for snapshot storage, because it does not support rejections.

  17. final case class SnapshotMeta(sequenceNr: Long, timestamp: Long = 0L) extends Product with Serializable

    Snapshot metainformation.

  18. sealed trait SnapshotOperation extends AnyRef

    INTERNAL API Operations supported by snapshot plugin

    INTERNAL API Operations supported by snapshot plugin

    Annotations
    @InternalApi()
  19. final case class StorageFailure(error: Throwable = ExpectedFailure) extends ProcessingFailure with Product with Serializable

    Emulates exception thrown by the storage on the attempt to perform some operation.

  20. final case class WriteEvents(batch: Seq[Any]) extends JournalOperation with Product with Serializable

    Write in journal operation with events to be written.

  21. final case class WriteSnapshot(metadata: SnapshotMeta, snapshot: Any) extends SnapshotOperation with Product with Serializable

    Storage write operation to persist snapshot in the storage.

    Storage write operation to persist snapshot in the storage.

    metadata

    snapshot metadata

    snapshot

    snapshot payload

Value Members

  1. object EventStorage
  2. object ExpectedFailure extends ExpectedFailure
  3. object ExpectedRejection extends ExpectedRejection
  4. object PersistenceTestKitPlugin
  5. object PersistenceTestKitSnapshotPlugin
  6. object ProcessingPolicy

    INTERNAL API

    INTERNAL API

    Annotations
    @InternalApi()
  7. case object ProcessingSuccess extends ProcessingSuccess with Product with Serializable

    Emulates successful processing of some operation.

  8. case object ReadSeqNum extends JournalOperation with Product with Serializable

    Read persistent actor's sequence number operation.

  9. object Reject extends Serializable
  10. case object SnapshotMeta extends Product with Serializable
  11. object SnapshotStorage
  12. object StorageFailure extends Serializable

Ungrouped