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

Modifier and Type

Interface

Description

static class

SnapshotStorage.SnapshotPolicies$
Method Summary

Modifier and Type

Method

Description

ProcessingPolicy.DefaultPolicies.PassAll

DefaultPolicy()

void

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

long

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

void

tryAdd(SnapshotMetadata meta, Object payload)

void

tryDelete(String persistenceId, SnapshotSelectionCriteria selectionCriteria)

void

tryDelete(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, 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$SnapshotStorage$_setter_$DefaultPolicy_$eq
  
  void org$apache$pekko$persistence$testkit$SnapshotStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1)
- reprToSeqNum
  
  long reprToSeqNum(scala.Tuple2<SnapshotMetadata,Object> repr)
  
  Specified by:
  
  reprToSeqNum in interface InMemStorage<String,scala.Tuple2<SnapshotMetadata,Object>>
- DefaultPolicy
  
  ProcessingPolicy.DefaultPolicies.PassAll DefaultPolicy()
  
  Specified by:
  
  DefaultPolicy in interface PolicyOps<SnapshotOperation>
- tryAdd
  
  void tryAdd(SnapshotMetadata meta, Object payload)
- tryRead
  
  scala.Option<SelectedSnapshot> tryRead(String persistenceId, SnapshotSelectionCriteria criteria)
- tryDelete
  
  void tryDelete(String persistenceId, SnapshotSelectionCriteria selectionCriteria)
- tryDelete
  
  void tryDelete(SnapshotMetadata meta)