public abstract class SnapshotStore extends java.lang.Object implements SnapshotStore
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
SnapshotStore() |
Modifier and Type | Method and Description |
---|---|
ActorContext |
context()
Stores the context for this actor, including self, and sender.
|
scala.concurrent.Future<scala.runtime.BoxedUnit> |
deleteAsync(SnapshotMetadata metadata)
Plugin API: deletes the snapshot identified by
metadata . |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
deleteAsync(java.lang.String persistenceId,
SnapshotSelectionCriteria criteria)
Plugin API: deletes all snapshots matching
criteria . |
scala.concurrent.Future<java.lang.Void> |
doDeleteAsync(SnapshotMetadata metadata)
Java API, Plugin API: deletes the snapshot identified by `metadata`.
|
scala.concurrent.Future<java.lang.Void> |
doDeleteAsync(java.lang.String persistenceId,
SnapshotSelectionCriteria criteria)
Java API, Plugin API: deletes all snapshots matching `criteria`.
|
scala.concurrent.Future<java.util.Optional<SelectedSnapshot>> |
doLoadAsync(java.lang.String persistenceId,
SnapshotSelectionCriteria criteria)
Java API, Plugin API: asynchronously loads a snapshot.
|
scala.concurrent.Future<java.lang.Void> |
doSaveAsync(SnapshotMetadata metadata,
java.lang.Object snapshot)
Java API, Plugin API: asynchronously saves a snapshot.
|
scala.concurrent.Future<scala.Option<SelectedSnapshot>> |
loadAsync(java.lang.String persistenceId,
SnapshotSelectionCriteria criteria)
Plugin API: asynchronously loads a snapshot.
|
scala.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 |
self()
The 'self' field holds the ActorRef for this actor.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
receive, receivePluginInternal, senderPersistentActor, tryReceivePluginInternal
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled
log
public final scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveSnapshotStore()
receiveSnapshotStore
in interface SnapshotStore
public ActorContext context()
Actor
forward
.
WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API. getContext
returns a
UntypedActorContext
, which is the Java API of the actor
context.
public final ActorRef self()
Actor
self ! message
public final scala.concurrent.Future<scala.Option<SelectedSnapshot>> loadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
SnapshotStore
If the future Option
is None
then all events will be replayed,
i.e. there was no snapshot. If snapshot could not be loaded the Future
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.
loadAsync
in interface SnapshotStore
persistenceId
- id of the persistent actor.criteria
- selection criteria for loading.public final scala.concurrent.Future<scala.runtime.BoxedUnit> saveAsync(SnapshotMetadata metadata, java.lang.Object snapshot)
SnapshotStore
This call is protected with a circuit-breaker.
saveAsync
in interface SnapshotStore
metadata
- snapshot metadata.snapshot
- snapshot.public final scala.concurrent.Future<scala.runtime.BoxedUnit> deleteAsync(SnapshotMetadata metadata)
SnapshotStore
metadata
.
This call is protected with a circuit-breaker.
deleteAsync
in interface SnapshotStore
metadata
- snapshot metadata.public final scala.concurrent.Future<scala.runtime.BoxedUnit> deleteAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
SnapshotStore
criteria
.
This call is protected with a circuit-breaker.
deleteAsync
in interface SnapshotStore
persistenceId
- id of the persistent actor.criteria
- selection criteria for deleting.public scala.concurrent.Future<java.util.Optional<SelectedSnapshot>> doLoadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
persistenceId
- id of the persistent actor.criteria
- selection criteria for loading.public scala.concurrent.Future<java.lang.Void> doSaveAsync(SnapshotMetadata metadata, java.lang.Object snapshot)
metadata
- snapshot metadata.snapshot
- snapshot.public scala.concurrent.Future<java.lang.Void> doDeleteAsync(SnapshotMetadata metadata)
metadata
- snapshot metadata.public scala.concurrent.Future<java.lang.Void> doDeleteAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
persistenceId
- id of the persistent actor.criteria
- selection criteria for deleting.