public abstract class SnapshotStore extends java.lang.Object implements SnapshotStore
Constructor and Description |
---|
SnapshotStore() |
Modifier and Type | Method and Description |
---|---|
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.concurrent.Future<scala.runtime.BoxedUnit> |
saveAsync(SnapshotMetadata metadata,
java.lang.Object snapshot)
Plugin API: asynchronously saves a snapshot.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
breaker, extension, publish, receive, receivePluginInternal, receiveSnapshotStore, senderPersistentActor, tryReceivePluginInternal
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled
public final scala.concurrent.Future<scala.Option<SelectedSnapshot>> loadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
SnapshotStore
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.