Package akka.persistence.testkit

Interface EventStorage

All Superinterfaces:

Extension, InMemStorage<java.lang.String,PersistentRepr>, InternalReprSupport<PersistentRepr>, PolicyOps<JournalOperation>, TestKitStorage<JournalOperation,PersistentRepr>

All Known Implementing Classes:

SerializedEventStorageImpl, SimpleEventStorageImpl

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)
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)
long	tryReadSeqNumber(java.lang.String persistenceId)

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

add, add, clearAll, clearAllPreservingSeqNumbers, delete, deleteToSeqNumber, findMany, findOneByIndex, getHighestSeqNumber, getLastSeqNumber, read, read, 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)

tryReadSeqNumber

long tryReadSeqNumber(java.lang.String persistenceId)

tryDelete

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

mapAny

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