Package org.apache.pekko.persistence.testkit.scaladsl

Interface PersistenceTestKitOps<S,P>

All Superinterfaces:

ClearOps, ClearPreservingSeqNums, CommonTestKitOps<S,P>, PolicyOpsTestKit<P>, RejectSupport<P>

All Known Implementing Classes:

PersistenceTestKit

public interface PersistenceTestKitOps<S,P>
extends RejectSupport<P>, ClearPreservingSeqNums, CommonTestKitOps<S,P>

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.Seq<Object>	persistedInStorage(String persistenceId)	Retrieve all snapshots saved in storage by persistence id.
void	persistForRecovery(String persistenceId, scala.collection.immutable.Seq<Object> events)	Persist snapshots into storage in order.
void	rejectNextDelete()	Reject next delete from storage operation for any persistence id with default exception.
void	rejectNextDelete(String persistenceId)	Reject next delete from storage operations for particular persistence id with default exception.
void	rejectNextDelete(String persistenceId, Throwable cause)	Reject next delete from storage operations for particular persistence id with cause exception.
void	rejectNextDelete(Throwable cause)	Reject next delete from storage operation for any persistence id with cause exception.
void	rejectNextNDeletes(int n)	Reject next n delete from storage operations for any persistence id with default exception.
void	rejectNextNDeletes(int n, Throwable cause)	Reject next n delete from storage operations for any persistence id with cause exception.
void	rejectNextNDeletes(String persistenceId, int n)	Reject next n delete from storage operations for particular persistence id with default exception.
void	rejectNextNDeletes(String persistenceId, int n, Throwable cause)	Reject next n delete from storage operations for particular persistence id with cause exception.
void	rejectNextNPersisted(int n)	Reject next n save in storage operations for any persistence id with default exception.
void	rejectNextNPersisted(int n, Throwable cause)	Reject next n save in storage operations for any persistence id with cause exception.
void	rejectNextNPersisted(String persistenceId, int n)	Reject next n save in storage operations for particular persistence id with default exception.
void	rejectNextNPersisted(String persistenceId, int n, Throwable cause)	Reject next n save in storage operations for particular persistence id with cause exception.
void	rejectNextNReads(int n)	Reject next n read from storage operations for any persistence id with default exception.
void	rejectNextNReads(int n, Throwable cause)	Reject next n read from storage operations for any persistence id with cause exception.
void	rejectNextNReads(String persistenceId, int n)	Reject next n read from storage operations for particular persistence id with default exception.
void	rejectNextNReads(String persistenceId, int n, Throwable cause)	Reject next n read from storage operations for particular persistence id with cause exception.
void	rejectNextPersisted()	Reject next save in storage operation for any persistence id with default exception.
void	rejectNextPersisted(String persistenceId)	Reject next save in storage operation for particular persistence id with default exception.
void	rejectNextPersisted(String persistenceId, Throwable cause)	Reject next save in storage operation for particular persistence id with cause exception.
void	rejectNextPersisted(Throwable cause)	Reject next save in storage operation for any persistence id with cause exception.
void	rejectNextRead()	Reject next read from storage operation for any persistence id with default exception.
void	rejectNextRead(String persistenceId)	Reject next read from storage operation for particular persistence id with default exception.
void	rejectNextRead(String persistenceId, Throwable cause)	Reject next read from storage operation for particular persistence id with cause exception.
void	rejectNextRead(Throwable cause)	Reject next read from storage operation for any persistence id with cause exception.

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.ClearOps

clearAll, clearByPersistenceId

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.ClearPreservingSeqNums

clearAllPreservingSeqNumbers, clearByIdPreservingSeqNumbers

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.CommonTestKitOps

expectNextPersisted, expectNextPersisted, expectNothingPersisted, expectNothingPersisted, failNextDelete, failNextDelete, failNextDelete, failNextDelete, failNextNDeletes, failNextNDeletes, failNextNDeletes, failNextNDeletes, failNextNPersisted, failNextNPersisted, failNextNPersisted, failNextNPersisted, failNextNReads, failNextNReads, failNextNReads, failNextNReads, failNextPersisted, failNextPersisted, failNextPersisted, failNextPersisted, failNextRead, failNextRead, failNextRead, failNextRead

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.PolicyOpsTestKit

failNextNOps, failNextNOps, failNextNOpsCond, failNextNOpsCond, Policies, resetPolicy, withPolicy

Methods inherited from interface org.apache.pekko.persistence.testkit.scaladsl.RejectSupport

rejectNextNOps, rejectNextNOps, rejectNextNOpsCond, rejectNextNOpsCond

Method Details

persistForRecovery

void persistForRecovery(String persistenceId,
 scala.collection.immutable.Seq<Object> events)

Persist snapshots into storage in order.

persistedInStorage

scala.collection.immutable.Seq<Object> persistedInStorage(String persistenceId)

Retrieve all snapshots saved in storage by persistence id.

rejectNextDelete

void rejectNextDelete()

Reject next delete from storage operation for any persistence id with default exception.

rejectNextDelete

void rejectNextDelete(Throwable cause)

Reject next delete from storage operation for any persistence id with cause exception.

rejectNextDelete

void rejectNextDelete(String persistenceId)

Reject next delete from storage operations for particular persistence id with default exception.

rejectNextDelete

void rejectNextDelete(String persistenceId,
 Throwable cause)

Reject next delete from storage operations for particular persistence id with cause exception.

rejectNextNDeletes

void rejectNextNDeletes(int n)

Reject next n delete from storage operations for any persistence id with default exception.

rejectNextNDeletes

void rejectNextNDeletes(int n,
 Throwable cause)

Reject next n delete from storage operations for any persistence id with cause exception.

rejectNextNDeletes

void rejectNextNDeletes(String persistenceId,
 int n)

Reject next n delete from storage operations for particular persistence id with default exception.

rejectNextNDeletes

void rejectNextNDeletes(String persistenceId,
 int n,
 Throwable cause)

Reject next n delete from storage operations for particular persistence id with cause exception.

rejectNextNPersisted

void rejectNextNPersisted(String persistenceId,
 int n,
 Throwable cause)

Reject next n save in storage operations for particular persistence id with cause exception.

rejectNextNPersisted

void rejectNextNPersisted(String persistenceId,
 int n)

Reject next n save in storage operations for particular persistence id with default exception.

rejectNextNPersisted

void rejectNextNPersisted(int n)

Reject next n save in storage operations for any persistence id with default exception.

rejectNextNPersisted

void rejectNextNPersisted(int n,
 Throwable cause)

Reject next n save in storage operations for any persistence id with cause exception.

rejectNextNReads

void rejectNextNReads(int n)

Reject next n read from storage operations for any persistence id with default exception.

rejectNextNReads

void rejectNextNReads(int n,
 Throwable cause)

Reject next n read from storage operations for any persistence id with cause exception.

rejectNextNReads

void rejectNextNReads(String persistenceId,
 int n)

Reject next n read from storage operations for particular persistence id with default exception.

rejectNextNReads

void rejectNextNReads(String persistenceId,
 int n,
 Throwable cause)

Reject next n read from storage operations for particular persistence id with cause exception.

rejectNextPersisted

void rejectNextPersisted(String persistenceId)

Reject next save in storage operation for particular persistence id with default exception.

rejectNextPersisted

void rejectNextPersisted(String persistenceId,
 Throwable cause)

Reject next save in storage operation for particular persistence id with cause exception.

rejectNextPersisted

void rejectNextPersisted(Throwable cause)

Reject next save in storage operation for any persistence id with cause exception.

rejectNextPersisted

void rejectNextPersisted()

Reject next save in storage operation for any persistence id with default exception.

rejectNextRead

void rejectNextRead()

Reject next read from storage operation for any persistence id with default exception.

rejectNextRead

void rejectNextRead(Throwable cause)

Reject next read from storage operation for any persistence id with cause exception.

rejectNextRead

void rejectNextRead(String persistenceId)

Reject next read from storage operation for particular persistence id with default exception.

rejectNextRead

void rejectNextRead(String persistenceId,
 Throwable cause)

Reject next read from storage operation for particular persistence id with cause exception.