Package akka.persistence.testkit.internal

Class SimpleSnapshotStorageImpl

java.lang.Object

akka.persistence.testkit.internal.SimpleSnapshotStorageImpl

All Implemented Interfaces:

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>>, SnapshotStorage

public class SimpleSnapshotStorageImpl
extends java.lang.Object
implements SnapshotStorage

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from interface akka.persistence.testkit.SnapshotStorage

SnapshotStorage.SnapshotPolicies$

Constructor Summary

Constructors

Constructor	Description
SimpleSnapshotStorageImpl()

Method Summary

Modifier and Type	Method	Description
protected void	akka$persistence$testkit$SnapshotStorage$_setter_$DefaultPolicy_$eq(ProcessingPolicy.DefaultPolicies.PassAll x$1)
protected ProcessingPolicy.DefaultPolicies.PassAll	DefaultPolicy()
scala.Tuple2<SnapshotMetadata,java.lang.Object>	toInternal(scala.Tuple2<SnapshotMetadata,java.lang.Object> repr)
scala.Tuple2<SnapshotMetadata,java.lang.Object>	toRepr(scala.Tuple2<SnapshotMetadata,java.lang.Object> internal)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

add, add, clearAll, clearAllPreservingSeqNumbers, delete, deleteToSeqNumber, eventsMap_$eq, expectNextQueue_$eq, findMany, findOneByIndex, firstInExpectNextQueue, getHighestSeqNumber, getLastSeqNumber, read, read, readAll, removeFirstInExpectNextQueue, removeKey, removePreservingSeqNumber, updateOrSetNew

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

toRepr

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

currentPolicy, resetPolicy, setPolicy

Methods inherited from interface akka.persistence.testkit.SnapshotStorage

reprToSeqNum, tryAdd, tryDelete, tryDelete, tryRead

Constructor Detail

SimpleSnapshotStorageImpl

public SimpleSnapshotStorageImpl()

Method Detail

DefaultPolicy

protected ProcessingPolicy.DefaultPolicies.PassAll DefaultPolicy()

Specified by:

DefaultPolicy in interface PolicyOps<SnapshotOperation>

Specified by:

DefaultPolicy in interface SnapshotStorage

akka$persistence$testkit$SnapshotStorage$_setter_$DefaultPolicy_$eq

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

Specified by:

akka$persistence$testkit$SnapshotStorage$_setter_$DefaultPolicy_$eq in interface SnapshotStorage

toInternal

public scala.Tuple2<SnapshotMetadata,java.lang.Object> toInternal(scala.Tuple2<SnapshotMetadata,java.lang.Object> repr)

Specified by:

toInternal in interface InternalReprSupport<scala.Tuple2<SnapshotMetadata,java.lang.Object>>

toRepr

public scala.Tuple2<SnapshotMetadata,java.lang.Object> toRepr(scala.Tuple2<SnapshotMetadata,java.lang.Object> internal)