|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.persistence.snapshot.japi.SnapshotStore
public abstract class SnapshotStore
Java API: abstract snapshot store.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Constructor Summary | |
---|---|
SnapshotStore()
|
Method Summary | |
---|---|
void |
delete(SnapshotMetadata metadata)
Plugin API: deletes the snapshot identified by metadata . |
void |
delete(java.lang.String persistenceId,
SnapshotSelectionCriteria criteria)
Plugin API: deletes all snapshots matching criteria . |
void |
doDelete(SnapshotMetadata metadata)
Java API, Plugin API: deletes the snapshot identified by `metadata`. |
void |
doDelete(java.lang.String persistenceId,
SnapshotSelectionCriteria criteria)
Java API, Plugin API: deletes all snapshots matching `criteria`. |
scala.concurrent.Future<Option<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. |
void |
onSaved(SnapshotMetadata metadata)
Java API, Plugin API: called after successful saving of a snapshot. |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
saveAsync(SnapshotMetadata metadata,
java.lang.Object snapshot)
Plugin API: asynchronously saves a snapshot. |
void |
saved(SnapshotMetadata metadata)
Plugin API: called after successful saving of a snapshot. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.persistence.snapshot.SnapshotStore |
---|
extension, publish, receive |
Methods inherited from interface akka.actor.Actor |
---|
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, postStop, preRestart, preStart, self, sender, supervisorStrategy, unhandled |
Constructor Detail |
---|
public SnapshotStore()
Method Detail |
---|
public final scala.concurrent.Future<scala.Option<SelectedSnapshot>> loadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
SnapshotStore
loadAsync
in interface SnapshotStore
persistenceId
- processor id.criteria
- selection criteria for loading.
public final scala.concurrent.Future<scala.runtime.BoxedUnit> saveAsync(SnapshotMetadata metadata, java.lang.Object snapshot)
SnapshotStore
saveAsync
in interface SnapshotStore
metadata
- snapshot metadata.snapshot
- snapshot.
public final void saved(SnapshotMetadata metadata)
SnapshotStore
saved
in interface SnapshotStore
metadata
- snapshot metadata.public final void delete(SnapshotMetadata metadata)
SnapshotStore
metadata
.
delete
in interface SnapshotStore
metadata
- snapshot metadata.public final void delete(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
SnapshotStore
criteria
.
delete
in interface SnapshotStore
persistenceId
- processor id.criteria
- selection criteria for deleting.public scala.concurrent.Future<Option<SelectedSnapshot>> doLoadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
persistenceId
- processor id.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 void onSaved(SnapshotMetadata metadata) throws java.lang.Exception
metadata
- snapshot metadata.
java.lang.Exception
public void doDelete(SnapshotMetadata metadata) throws java.lang.Exception
metadata
- snapshot metadata.
java.lang.Exception
public void doDelete(java.lang.String persistenceId, SnapshotSelectionCriteria criteria) throws java.lang.Exception
persistenceId
- processor id.criteria
- selection criteria for deleting.
java.lang.Exception
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |