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