public final class NoSnapshotStore extends java.lang.Object implements SnapshotStore
If a PersistentActor
calls the Snapshotter.saveSnapshot(java.lang.Object)
method,
and at the same time does not configure a specific snapshot-store to be used *and* no default snapshot-store
is available, then the NoSnapshotStore
will be used to signal a snapshot store failure.
Modifier and Type | Class and Description |
---|---|
class |
NoSnapshotStore.NoSnapshotStoreException |
Constructor and Description |
---|
NoSnapshotStore() |
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<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 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 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 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 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.