|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.persistence.snapshot.local.LocalSnapshotStore
public class LocalSnapshotStore
INTERNAL API.
Local filesystem backed snapshot store.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Constructor Summary | |
---|---|
LocalSnapshotStore()
|
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 . |
protected Snapshot |
deserialize(java.io.InputStream inputStream)
|
scala.concurrent.Future<scala.Option<SelectedSnapshot>> |
loadAsync(java.lang.String persistenceId,
SnapshotSelectionCriteria criteria)
Plugin API: asynchronously loads a snapshot. |
void |
preStart()
User overridable callback. |
protected void |
save(SnapshotMetadata metadata,
java.lang.Object 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. |
protected void |
serialize(java.io.OutputStream outputStream,
Snapshot snapshot)
|
protected java.io.File |
withOutputStream(SnapshotMetadata metadata,
scala.Function1<java.io.OutputStream,scala.runtime.BoxedUnit> p)
|
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, self, sender, supervisorStrategy, unhandled |
Methods inherited from interface akka.actor.ActorLogging |
---|
_log, log |
Constructor Detail |
---|
public LocalSnapshotStore()
Method Detail |
---|
public 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 scala.concurrent.Future<scala.runtime.BoxedUnit> saveAsync(SnapshotMetadata metadata, java.lang.Object snapshot)
SnapshotStore
saveAsync
in interface SnapshotStore
metadata
- snapshot metadata.snapshot
- snapshot.
public void saved(SnapshotMetadata metadata)
SnapshotStore
saved
in interface SnapshotStore
metadata
- snapshot metadata.public void delete(SnapshotMetadata metadata)
SnapshotStore
metadata
.
delete
in interface SnapshotStore
metadata
- snapshot metadata.public void delete(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
SnapshotStore
criteria
.
delete
in interface SnapshotStore
persistenceId
- processor id.criteria
- selection criteria for deleting.protected void save(SnapshotMetadata metadata, java.lang.Object snapshot)
protected Snapshot deserialize(java.io.InputStream inputStream)
protected void serialize(java.io.OutputStream outputStream, Snapshot snapshot)
protected java.io.File withOutputStream(SnapshotMetadata metadata, scala.Function1<java.io.OutputStream,scala.runtime.BoxedUnit> p)
public void preStart()
Actor
preStart
in interface Actor
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |