Package org.apache.pekko.persistence.testkit

Interface EventStorage

All Superinterfaces:

InMemStorage<String,PersistentRepr>, InternalReprSupport<PersistentRepr>, PolicyOps<JournalOperation>, TestKitStorage<JournalOperation,PersistentRepr>

public interface EventStorage
extends TestKitStorage<JournalOperation,PersistentRepr>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	EventStorage.JournalPolicies$

Method Summary

Modifier and Type	Method	Description
void	add(scala.collection.immutable.Seq<PersistentRepr> elems)
void	addAny(String key, Object elem)
void	addAny(String key, scala.collection.immutable.Seq<Object> elems)
Source<String,NotUsed>	currentPersistenceIds(scala.Option<String> afterId, long limit)
ProcessingPolicy.DefaultPolicies.PassAll	DefaultPolicy()
scala.collection.immutable.Seq<PersistentRepr>	mapAny(String key, scala.collection.immutable.Seq<Object> elems)
void	org$apache$pekko$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1)
long	reprToSeqNum(PersistentRepr repr)
scala.util.Try<scala.runtime.BoxedUnit>	tryAdd(scala.collection.immutable.Seq<PersistentRepr> elems)
void	tryDelete(String persistenceId, long toSeqNumber)
scala.collection.immutable.Seq<PersistentRepr>	tryRead(String persistenceId, long fromSequenceNr, long toSequenceNr, long max)
scala.collection.immutable.Seq<PersistentRepr>	tryRead(String processId, scala.Function1<PersistentRepr,Object> predicate)
scala.collection.immutable.Seq<PersistentRepr>	tryReadByTag(String tag)
long	tryReadSeqNumber(String persistenceId)

Methods inherited from interface org.apache.pekko.persistence.testkit.internal.InMemStorage

add, add, clearAll, clearAllPreservingSeqNumbers, delete, deleteToSeqNumber, eventsMap_$eq, expectNextQueue_$eq, findMany, findOneByIndex, firstInExpectNextQueue, getHighestSeqNumber, getLastSeqNumber, keys, read, read, readAll, removeFirstInExpectNextQueue, removeKey, removePreservingSeqNumber, updateOrSetNew

Methods inherited from interface org.apache.pekko.persistence.testkit.internal.InternalReprSupport

toInternal, toRepr

Methods inherited from interface org.apache.pekko.persistence.testkit.internal.PolicyOps

currentPolicy, resetPolicy, setPolicy

Method Details

org$apache$pekko$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq

void org$apache$pekko$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1)

addAny

void addAny(String key,
 Object elem)

addAny

void addAny(String key,
 scala.collection.immutable.Seq<Object> elems)

reprToSeqNum

long reprToSeqNum(PersistentRepr repr)

Specified by:

reprToSeqNum in interface InMemStorage<String,PersistentRepr>

add

void add(scala.collection.immutable.Seq<PersistentRepr> elems)

DefaultPolicy

ProcessingPolicy.DefaultPolicies.PassAll DefaultPolicy()

Specified by:

DefaultPolicy in interface PolicyOps<JournalOperation>

tryAdd

scala.util.Try<scala.runtime.BoxedUnit> tryAdd(scala.collection.immutable.Seq<PersistentRepr> elems)

Throws:

Exception - from StorageFailure in the current writing policy

tryRead

scala.collection.immutable.Seq<PersistentRepr> tryRead(String persistenceId,
 long fromSequenceNr,
 long toSequenceNr,
 long max)

tryReadByTag

scala.collection.immutable.Seq<PersistentRepr> tryReadByTag(String tag)

tryRead

scala.collection.immutable.Seq<PersistentRepr> tryRead(String processId,
 scala.Function1<PersistentRepr,Object> predicate)

tryReadSeqNumber

long tryReadSeqNumber(String persistenceId)

tryDelete

void tryDelete(String persistenceId,
 long toSeqNumber)

currentPersistenceIds

Source<String,NotUsed> currentPersistenceIds(scala.Option<String> afterId,
 long limit)

mapAny

scala.collection.immutable.Seq<PersistentRepr> mapAny(String key,
 scala.collection.immutable.Seq<Object> elems)