Interface SnapshotStore
-
- All Superinterfaces:
Actor
,ActorLogging
- All Known Implementing Classes:
NoSnapshotStore
,PersistenceTestKitSnapshotPlugin
,SnapshotStore
public interface SnapshotStore extends Actor, ActorLogging
Abstract snapshot store.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.concurrent.Future<scala.runtime.BoxedUnit>
deleteAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Plugin API: deletes all snapshots matchingcriteria
.scala.concurrent.Future<scala.runtime.BoxedUnit>
deleteAsync(SnapshotMetadata metadata)
Plugin API: deletes the snapshot identified bymetadata
.scala.concurrent.Future<scala.Option<SelectedSnapshot>>
loadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Plugin API: asynchronously loads a snapshot.void
org$apache$pekko$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receivePluginInternal()
Plugin API Allows plugin implementers to usef pipeTo self
and handle additional messages for implementing advanced featuresscala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receiveSnapshotStore()
scala.concurrent.Future<scala.runtime.BoxedUnit>
saveAsync(SnapshotMetadata metadata, java.lang.Object snapshot)
Plugin API: asynchronously saves a snapshot.ActorRef
senderPersistentActor()
Documents intent that the sender() is expected to be the PersistentActorvoid
tryReceivePluginInternal(java.lang.Object evt)
-
Methods inherited from interface org.apache.pekko.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
-
Methods inherited from interface org.apache.pekko.actor.ActorLogging
_log_$eq, log
-
-
-
-
Method Detail
-
deleteAsync
scala.concurrent.Future<scala.runtime.BoxedUnit> deleteAsync(SnapshotMetadata metadata)
Plugin API: deletes the snapshot identified bymetadata
.This call is protected with a circuit-breaker.
- Parameters:
metadata
- snapshot metadata.
-
deleteAsync
scala.concurrent.Future<scala.runtime.BoxedUnit> deleteAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Plugin API: deletes all snapshots matchingcriteria
.This call is protected with a circuit-breaker.
- Parameters:
persistenceId
- id of the persistent actor.criteria
- selection criteria for deleting.
-
loadAsync
scala.concurrent.Future<scala.Option<SelectedSnapshot>> loadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Plugin API: asynchronously loads a snapshot.If the future
Option
isNone
then all events will be replayed, i.e. there was no snapshot. If snapshot could not be loaded theFuture
should be completed with failure. That is important because events may have been deleted and just replaying the events might not result in a valid state.This call is protected with a circuit-breaker.
- Parameters:
persistenceId
- id of the persistent actor.criteria
- selection criteria for loading.
-
org$apache$pekko$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq
void org$apache$pekko$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
-
receive
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
-
receivePluginInternal
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receivePluginInternal()
Plugin API Allows plugin implementers to usef pipeTo self
and handle additional messages for implementing advanced features
-
receiveSnapshotStore
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveSnapshotStore()
-
saveAsync
scala.concurrent.Future<scala.runtime.BoxedUnit> saveAsync(SnapshotMetadata metadata, java.lang.Object snapshot)
Plugin API: asynchronously saves a snapshot.This call is protected with a circuit-breaker.
- Parameters:
metadata
- snapshot metadata.snapshot
- snapshot.
-
senderPersistentActor
ActorRef senderPersistentActor()
Documents intent that the sender() is expected to be the PersistentActor
-
tryReceivePluginInternal
void tryReceivePluginInternal(java.lang.Object evt)
-
-