Package akka.persistence.testkit

Interface EventStorage

All Superinterfaces:

InMemStorage<java.lang.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(java.lang.String key, java.lang.Object elem)
void	addAny(java.lang.String key, scala.collection.immutable.Seq<java.lang.Object> elems)
void	akka$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1)
Source<java.lang.String,NotUsed>	currentPersistenceIds(scala.Option<java.lang.String> afterId, long limit)
ProcessingPolicy.DefaultPolicies.PassAll	DefaultPolicy()
scala.collection.immutable.Seq<PersistentRepr>	mapAny(java.lang.String key, scala.collection.immutable.Seq<java.lang.Object> elems)
long	reprToSeqNum(PersistentRepr repr)
scala.util.Try<scala.runtime.BoxedUnit>	tryAdd(scala.collection.immutable.Seq<PersistentRepr> elems)
void	tryDelete(java.lang.String persistenceId, long toSeqNumber)
scala.collection.immutable.Seq<PersistentRepr>	tryRead(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, long max)
scala.collection.immutable.Seq<PersistentRepr>	tryRead(java.lang.String processId, scala.Function1<PersistentRepr,java.lang.Object> predicate)
scala.collection.immutable.Seq<PersistentRepr>	tryReadByTag(java.lang.String tag)
long	tryReadSeqNumber(java.lang.String persistenceId)

Methods inherited from interface akka.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 akka.persistence.testkit.internal.InternalReprSupport

toInternal, toRepr

Methods inherited from interface akka.persistence.testkit.internal.PolicyOps

currentPolicy, resetPolicy, setPolicy

Method Detail

akka$persistence$testkit$EventStorage$_setter_$DefaultPolicy_$eq

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

addAny

void addAny(java.lang.String key,
            java.lang.Object elem)

addAny

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

reprToSeqNum

long reprToSeqNum(PersistentRepr repr)

Specified by:

reprToSeqNum in interface InMemStorage<java.lang.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:

java.lang.Exception - from StorageFailure in the current writing policy

tryRead

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

tryReadByTag

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

tryRead

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

tryReadSeqNumber

long tryReadSeqNumber(java.lang.String persistenceId)

tryDelete

void tryDelete(java.lang.String persistenceId,
               long toSeqNumber)

currentPersistenceIds

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

mapAny

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