Package akka.persistence.testkit

Interface SnapshotStorage

All Superinterfaces:

Extension, InMemStorage<java.lang.String,scala.Tuple2<SnapshotMetadata,java.lang.Object>>, InternalReprSupport<scala.Tuple2<SnapshotMetadata,java.lang.Object>>, PolicyOps<SnapshotOperation>, TestKitStorage<SnapshotOperation,scala.Tuple2<SnapshotMetadata,java.lang.Object>>

public interface SnapshotStorage
extends TestKitStorage<SnapshotOperation,scala.Tuple2<SnapshotMetadata,java.lang.Object>>, Extension

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	SnapshotStorage.SnapshotPolicies$

Method Summary

Modifier and Type	Method	Description
void	akka$persistence$testkit$SnapshotStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1)
ProcessingPolicy.DefaultPolicies.PassAll	DefaultPolicy()
long	reprToSeqNum(scala.Tuple2<SnapshotMetadata,java.lang.Object> repr)
void	tryAdd(SnapshotMetadata meta, java.lang.Object payload)
void	tryDelete(SnapshotMetadata meta)
void	tryDelete(java.lang.String persistenceId, SnapshotSelectionCriteria selectionCriteria)
scala.Option<SelectedSnapshot>	tryRead(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)

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$SnapshotStorage$_setter_$DefaultPolicy_$eq

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

reprToSeqNum

long reprToSeqNum(scala.Tuple2<SnapshotMetadata,java.lang.Object> repr)

Specified by:

reprToSeqNum in interface InMemStorage<java.lang.String,scala.Tuple2<SnapshotMetadata,java.lang.Object>>

DefaultPolicy

ProcessingPolicy.DefaultPolicies.PassAll DefaultPolicy()

Specified by:

DefaultPolicy in interface PolicyOps<SnapshotOperation>

tryAdd

void tryAdd(SnapshotMetadata meta,
            java.lang.Object payload)

tryRead

scala.Option<SelectedSnapshot> tryRead(java.lang.String persistenceId,
                                       SnapshotSelectionCriteria criteria)

tryDelete

void tryDelete(java.lang.String persistenceId,
               SnapshotSelectionCriteria selectionCriteria)

tryDelete

void tryDelete(SnapshotMetadata meta)