Package akka.persistence.snapshot.local
Class LocalSnapshotStore
- java.lang.Object
-
- akka.persistence.snapshot.local.LocalSnapshotStore
-
- All Implemented Interfaces:
Actor
,ActorLogging
,SnapshotStore
public class LocalSnapshotStore extends java.lang.Object implements SnapshotStore, ActorLogging
Only by persistenceId and sequenceNr, timestamp is informational - accommodates for 2.13.x series files
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description LocalSnapshotStore(com.typesafe.config.Config config)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.protected void
akka$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.scala.concurrent.Future<scala.runtime.BoxedUnit>
deleteAsync(SnapshotMetadata metadata)
Plugin API: deletes the snapshot identified bymetadata
.scala.concurrent.Future<scala.runtime.BoxedUnit>
deleteAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Plugin API: deletes all snapshots matchingcriteria
.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.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receivePluginInternal()
Plugin API Allows plugin implementers to usef pipeTo self
and handle additional messages for implementing advanced featuresscala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receiveSnapshotStore()
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.ActorRef
self()
The 'self' field holds the ActorRef for this actor.protected void
serialize(java.io.OutputStream outputStream, Snapshot snapshot)
protected java.io.File
snapshotFileForWrite(SnapshotMetadata metadata, java.lang.String extension)
Only by persistenceId and sequenceNr, timestamp is informational - accommodates for 2.13.x series filesprotected java.lang.String
snapshotFileForWrite$default$2()
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.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preRestart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.persistence.snapshot.SnapshotStore
receive, senderPersistentActor, tryReceivePluginInternal
-
-
-
-
Method Detail
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
akka$actor$Actor$_setter_$self_$eq
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
akka$actor$Actor$_setter_$self_$eq
in interfaceActor
- Parameters:
x$1
- (undocumented)
-
akka$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq
protected final void akka$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
- Specified by:
akka$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq
in interfaceSnapshotStore
-
context
public ActorContext context()
Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
deleteAsync
public scala.concurrent.Future<scala.runtime.BoxedUnit> deleteAsync(SnapshotMetadata metadata)
Description copied from interface:SnapshotStore
Plugin API: deletes the snapshot identified bymetadata
.This call is protected with a circuit-breaker.
- Specified by:
deleteAsync
in interfaceSnapshotStore
- Parameters:
metadata
- snapshot metadata.- Returns:
- (undocumented)
-
deleteAsync
public scala.concurrent.Future<scala.runtime.BoxedUnit> deleteAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Description copied from interface:SnapshotStore
Plugin API: deletes all snapshots matchingcriteria
.This call is protected with a circuit-breaker.
- Specified by:
deleteAsync
in interfaceSnapshotStore
- Parameters:
persistenceId
- id of the persistent actor.criteria
- selection criteria for deleting.- Returns:
- (undocumented)
-
deserialize
protected Snapshot deserialize(java.io.InputStream inputStream)
-
loadAsync
public scala.concurrent.Future<scala.Option<SelectedSnapshot>> loadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Description copied from interface:SnapshotStore
Plugin API: asynchronously loads a snapshot.If the future
Option
isNone
then all events will be replayed, i.e. there was no snapshot. If snapshot could not be loaded theFuture
should be completed with failure. That is important because events may have been deleted and just replaying the events might not result in a valid state.This call is protected with a circuit-breaker.
- Specified by:
loadAsync
in interfaceSnapshotStore
- Parameters:
persistenceId
- id of the persistent actor.criteria
- selection criteria for loading.- Returns:
- (undocumented)
-
preStart
public void preStart()
Description copied from interface:Actor
User overridable callback. Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
-
receivePluginInternal
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receivePluginInternal()
Description copied from interface:SnapshotStore
Plugin API Allows plugin implementers to usef pipeTo self
and handle additional messages for implementing advanced features- Specified by:
receivePluginInternal
in interfaceSnapshotStore
- Returns:
- (undocumented)
-
receiveSnapshotStore
public final scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveSnapshotStore()
- Specified by:
receiveSnapshotStore
in interfaceSnapshotStore
-
save
protected void save(SnapshotMetadata metadata, java.lang.Object snapshot)
-
saveAsync
public scala.concurrent.Future<scala.runtime.BoxedUnit> saveAsync(SnapshotMetadata metadata, java.lang.Object snapshot)
Description copied from interface:SnapshotStore
Plugin API: asynchronously saves a snapshot.This call is protected with a circuit-breaker.
- Specified by:
saveAsync
in interfaceSnapshotStore
- Parameters:
metadata
- snapshot metadata.snapshot
- snapshot.- Returns:
- (undocumented)
-
self
public final ActorRef self()
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
-
serialize
protected void serialize(java.io.OutputStream outputStream, Snapshot snapshot)
-
snapshotFileForWrite
protected java.io.File snapshotFileForWrite(SnapshotMetadata metadata, java.lang.String extension)
Only by persistenceId and sequenceNr, timestamp is informational - accommodates for 2.13.x series files
-
snapshotFileForWrite$default$2
protected java.lang.String snapshotFileForWrite$default$2()
-
withOutputStream
protected java.io.File withOutputStream(SnapshotMetadata metadata, scala.Function1<java.io.OutputStream,scala.runtime.BoxedUnit> p)
-
-