Apache Pekko
1.1.5
API
Generated with
Apache Pekko/org.apache.pekko.persistence.testkit

org.apache.pekko.persistence.testkit

package org.apache.pekko.persistence.testkit

Members list

Packages

package org.apache.pekko.persistence.testkit.internal
package org.apache.pekko.persistence.testkit.javadsl
package org.apache.pekko.persistence.testkit.query
package org.apache.pekko.persistence.testkit.scaladsl
package org.apache.pekko.persistence.testkit.state

Type members

Classlikes

final case class DeleteEvents(toSeqNumber: Long) extends JournalOperation

Delete events in the journal up to toSeqNumber operation.

Delete events in the journal up to toSeqNumber operation.

Attributes

Source
EventStorage.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
sealed abstract class DeleteSnapshot extends SnapshotOperation

INTERNAL API

INTERNAL API

Attributes

Source
SnapshotStorage.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
final case class DeleteSnapshotByMeta(metadata: SnapshotMeta) extends DeleteSnapshot

Delete particular snapshot from storage by its metadata.

Delete particular snapshot from storage by its metadata.

Attributes

Source
SnapshotStorage.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
final case class DeleteSnapshotsByCriteria(criteria: SnapshotSelectionCriteria) extends DeleteSnapshot

Delete snapshots from storage by criteria.

Delete snapshots from storage by criteria.

Attributes

Source
SnapshotStorage.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
object EventStorage

Attributes

Source
EventStorage.scala
Supertypes
class Object
trait Matchable
class Any
Self type
sealed abstract class ExpectedFailure extends Throwable, NoStackTrace

Attributes

Companion
object
Source
ProcessingPolicy.scala
Supertypes
trait NoStackTrace
class Throwable
trait Serializable
class Object
trait Matchable
class Any
Show all
Known subtypes
object ExpectedFailure extends ExpectedFailure

Attributes

Companion
class
Source
ProcessingPolicy.scala
Supertypes
trait Sum
trait Mirror
trait NoStackTrace
class Throwable
trait Serializable
class Object
trait Matchable
class Any
Show all
Self type
sealed abstract class ExpectedRejection extends Throwable

Attributes

Companion
object
Source
ProcessingPolicy.scala
Supertypes
class Throwable
trait Serializable
class Object
trait Matchable
class Any
Known subtypes
object ExpectedRejection extends ExpectedRejection

Attributes

Companion
class
Source
ProcessingPolicy.scala
Supertypes
trait Sum
trait Mirror
class Throwable
trait Serializable
class Object
trait Matchable
class Any
Show all
Self type
sealed trait JournalOperation

INTERNAL API

INTERNAL API

Persistent journal operations.

Attributes

Source
EventStorage.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class DeleteEvents
class ReadEvents
object ReadSeqNum
class WriteEvents
object PersistenceTestKitDurableStateStorePlugin

Attributes

Source
PersistenceTestKitPlugin.scala
Supertypes
class Object
trait Matchable
class Any
Self type
class PersistenceTestKitPlugin(cfg: Config, cfgPath: String) extends AsyncWriteJournal, ActorLogging

INTERNAL API

INTERNAL API

Persistence testkit plugin for events.

Attributes

Companion
object
Source
PersistenceTestKitPlugin.scala
Supertypes
trait ActorLogging
trait Actor
class Object
trait Matchable
class Any
Show all
object PersistenceTestKitPlugin

Attributes

Companion
class
Source
PersistenceTestKitPlugin.scala
Supertypes
class Object
trait Matchable
class Any
Self type
class PersistenceTestKitSnapshotPlugin(cfg: Config, cfgPath: String) extends SnapshotStore

INTERNAL API

INTERNAL API

Persistence testkit plugin for snapshots.

Attributes

Companion
object
Source
PersistenceTestKitPlugin.scala
Supertypes
trait ActorLogging
trait Actor
class Object
trait Matchable
class Any
Show all
object PersistenceTestKitSnapshotPlugin

Attributes

Companion
class
Source
PersistenceTestKitPlugin.scala
Supertypes
class Object
trait Matchable
class Any
Self type
sealed trait ProcessingFailure extends ProcessingResult

Attributes

Source
ProcessingPolicy.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Reject
trait ProcessingPolicy[U]

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

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

Type parameters

U

type determines operations which storage can perform.

Attributes

Companion
object
Source
ProcessingPolicy.scala
Supertypes
class Object
trait Matchable
class Any
object ProcessingPolicy

INTERNAL API

INTERNAL API

Attributes

Companion
trait
Source
ProcessingPolicy.scala
Supertypes
class Object
trait Matchable
class Any
Self type
sealed trait ProcessingResult

INTERNAL API

INTERNAL API

Attributes

Source
ProcessingPolicy.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class Reject
sealed abstract class ProcessingSuccess extends ProcessingResult

Attributes

Companion
object
Source
ProcessingPolicy.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
case object ProcessingSuccess extends ProcessingSuccess

Emulates successful processing of some operation.

Emulates successful processing of some operation.

Attributes

Companion
class
Source
ProcessingPolicy.scala
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
Self type
final case class ReadEvents(batch: Seq[Any]) extends JournalOperation

Read from journal operation with events that were read.

Read from journal operation with events that were read.

Attributes

Source
EventStorage.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
case object ReadSeqNum extends JournalOperation

Read persistent actor's sequence number operation.

Read persistent actor's sequence number operation.

Attributes

Source
EventStorage.scala
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
Self type
ReadSeqNum.type
final case class ReadSnapshot(criteria: SnapshotSelectionCriteria, snapshot: Option[Any]) extends SnapshotOperation

Storage read operation for recovery of the persistent actor.

Storage read operation for recovery of the persistent actor.

Value parameters

criteria

criteria with which snapshot is searched

snapshot

snapshot found by criteria

Attributes

Source
SnapshotStorage.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
final case class Reject(error: Throwable) extends ProcessingFailure

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.

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.

Attributes

Companion
object
Source
ProcessingPolicy.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
object Reject

Attributes

Companion
class
Source
ProcessingPolicy.scala
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
Reject.type
final case class SnapshotMeta(sequenceNr: Long, timestamp: Long)

Snapshot metainformation.

Snapshot metainformation.

Attributes

Companion
object
Source
SnapshotStorage.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
case object SnapshotMeta

Attributes

Companion
class
Source
SnapshotStorage.scala
Supertypes
trait Singleton
trait Product
trait Mirror
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
Self type
sealed trait SnapshotOperation

INTERNAL API Operations supported by snapshot plugin

INTERNAL API Operations supported by snapshot plugin

Attributes

Source
SnapshotStorage.scala
Supertypes
class Object
trait Matchable
class Any
Known subtypes
class ReadSnapshot
object SnapshotStorage

Attributes

Source
SnapshotStorage.scala
Supertypes
class Object
trait Matchable
class Any
Self type
final case class StorageFailure(error: Throwable) extends ProcessingFailure

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

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

Attributes

Companion
object
Source
ProcessingPolicy.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
object StorageFailure

Attributes

Companion
class
Source
ProcessingPolicy.scala
Supertypes
trait Product
trait Mirror
class Object
trait Matchable
class Any
Self type
final case class WriteEvents(batch: Seq[Any]) extends JournalOperation

Write in journal operation with events to be written.

Write in journal operation with events to be written.

Attributes

Source
EventStorage.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
final case class WriteSnapshot(metadata: SnapshotMeta, snapshot: Any) extends SnapshotOperation

Storage write operation to persist snapshot in the storage.

Storage write operation to persist snapshot in the storage.

Value parameters

metadata

snapshot metadata

snapshot

snapshot payload

Attributes

Source
SnapshotStorage.scala
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
Generated with