public interface SnapshotStore
extends akka.actor.Actor, akka.actor.ActorLogging
Modifier and Type | Method and Description |
---|---|
akka.pattern.CircuitBreaker |
breaker() |
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 . |
Persistence |
extension() |
scala.concurrent.Future<scala.Option<SelectedSnapshot>> |
loadAsync(java.lang.String persistenceId,
SnapshotSelectionCriteria criteria)
Plugin API: asynchronously loads a snapshot.
|
boolean |
publish() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receivePluginInternal()
Plugin API
Allows plugin implementers to use
f pipeTo self and
handle additional messages for implementing advanced features |
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.
|
akka.actor.ActorRef |
senderPersistentActor()
Documents intent that the sender() is expected to be the PersistentActor
|
void |
tryReceivePluginInternal(java.lang.Object evt) |
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
Persistence extension()
boolean publish()
akka.pattern.CircuitBreaker breaker()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveSnapshotStore()
akka.actor.ActorRef senderPersistentActor()
void tryReceivePluginInternal(java.lang.Object evt)
scala.concurrent.Future<scala.Option<SelectedSnapshot>> loadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
This call is protected with a circuit-breaker.
persistenceId
- id of the persistent actor.criteria
- selection criteria for loading.scala.concurrent.Future<scala.runtime.BoxedUnit> saveAsync(SnapshotMetadata metadata, java.lang.Object snapshot)
This call is protected with a circuit-breaker.
metadata
- snapshot metadata.snapshot
- snapshot.scala.concurrent.Future<scala.runtime.BoxedUnit> deleteAsync(SnapshotMetadata metadata)
metadata
.
This call is protected with a circuit-breaker.
metadata
- snapshot metadata.scala.concurrent.Future<scala.runtime.BoxedUnit> deleteAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
criteria
.
This call is protected with a circuit-breaker.
persistenceId
- id of the persistent actor.criteria
- selection criteria for deleting.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receivePluginInternal()
f pipeTo self
and
handle additional messages for implementing advanced features