Interface SnapshotStorage
- All Superinterfaces:
Extension,InMemStorage<String,,scala.Tuple2<SnapshotMetadata, Object>> InternalReprSupport<scala.Tuple2<SnapshotMetadata,,Object>> PolicyOps<SnapshotOperation>,TestKitStorage<SnapshotOperation,scala.Tuple2<SnapshotMetadata, Object>>
public interface SnapshotStorage
extends TestKitStorage<SnapshotOperation,scala.Tuple2<SnapshotMetadata,Object>>, Extension
INTERNAL API
-
Nested Class Summary
Nested Classes -
Method Summary
Modifier and TypeMethodDescriptionvoidorg$apache$pekko$persistence$testkit$SnapshotStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1) longreprToSeqNum(scala.Tuple2<SnapshotMetadata, Object> repr) voidtryAdd(SnapshotMetadata meta, Object payload) voidtryDelete(String persistenceId, SnapshotSelectionCriteria selectionCriteria) voidtryDelete(SnapshotMetadata meta) scala.Option<SelectedSnapshot>tryRead(String persistenceId, SnapshotSelectionCriteria criteria) 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, updateOrSetNewMethods inherited from interface org.apache.pekko.persistence.testkit.internal.InternalReprSupport
toInternal, toReprMethods inherited from interface org.apache.pekko.persistence.testkit.internal.PolicyOps
currentPolicy, resetPolicy, setPolicy
-
Method Details
-
org$apache$pekko$persistence$testkit$SnapshotStorage$_setter_$DefaultPolicy_$eq
void org$apache$pekko$persistence$testkit$SnapshotStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1) -
reprToSeqNum
- Specified by:
reprToSeqNumin interfaceInMemStorage<String,scala.Tuple2<SnapshotMetadata, Object>>
-
DefaultPolicy
ProcessingPolicy.DefaultPolicies.PassAll DefaultPolicy()- Specified by:
DefaultPolicyin interfacePolicyOps<SnapshotOperation>
-
tryAdd
-
tryRead
-
tryDelete
-
tryDelete
-