Package akka.persistence.testkit.internal

Class SerializedSnapshotStorageImpl

java.lang.Object

akka.persistence.testkit.internal.SerializedSnapshotStorageImpl

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 SerializedSnapshotStorageImpl
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
SerializedSnapshotStorageImpl(ActorSystem system)

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.Tuple4<SnapshotMetadata,java.lang.String,java.lang.Object,byte[]>	toInternal(scala.Tuple2<SnapshotMetadata,java.lang.Object> repr)
scala.Tuple2<SnapshotMetadata,java.lang.Object>	toRepr(scala.Tuple4<SnapshotMetadata,java.lang.String,java.lang.Object,byte[]> 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

SerializedSnapshotStorageImpl

public SerializedSnapshotStorageImpl(ActorSystem system)

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.Tuple4<SnapshotMetadata,java.lang.String,java.lang.Object,byte[]> 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.Tuple4<SnapshotMetadata,java.lang.String,java.lang.Object,byte[]> internal)