Class NoSnapshotStore
- java.lang.Object
-
- org.apache.pekko.persistence.snapshot.NoSnapshotStore
-
- All Implemented Interfaces:
Actor
,ActorLogging
,SnapshotStore
public final class NoSnapshotStore extends java.lang.Object implements SnapshotStore
Used as default snapshot-store in case no other store was configured.If a
pekko.persistence.PersistentActor
calls thepekko.persistence.PersistentActor#saveSnapshot
method, and at the same time does not configure a specific snapshot-store to be used *and* no default snapshot-store is available, then theNoSnapshotStore
will be used to signal a snapshot store failure.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
NoSnapshotStore.NoSnapshotStoreException
-
Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description NoSnapshotStore()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.scala.concurrent.Future<scala.runtime.BoxedUnit>
deleteAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Plugin API: deletes all snapshots matchingcriteria
.scala.concurrent.Future<scala.runtime.BoxedUnit>
deleteAsync(SnapshotMetadata metadata)
Plugin API: deletes the snapshot identified bymetadata
.scala.concurrent.Future<scala.Option<SelectedSnapshot>>
loadAsync(java.lang.String persistenceId, SnapshotSelectionCriteria criteria)
Plugin API: asynchronously loads a snapshot.protected void
org$apache$pekko$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Scala API: Stores the context for this actor, including self, and sender.protected void
org$apache$pekko$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.protected void
org$apache$pekko$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
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.ActorRef
self()
The 'self' field holds the ActorRef for this actor.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.pekko.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface org.apache.pekko.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface org.apache.pekko.persistence.snapshot.SnapshotStore
receive, receivePluginInternal, senderPersistentActor, tryReceivePluginInternal
-
-
-
-
Method Detail
-
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!
pekko.actor.ActorContext
is the Scala API.getContext
returns apekko.actor.AbstractActor.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.
-
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.
-
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.
-
org$apache$pekko$actor$Actor$_setter_$context_$eq
protected void org$apache$pekko$actor$Actor$_setter_$context_$eq(ActorContext x$1)
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!
pekko.actor.ActorContext
is the Scala API.getContext
returns apekko.actor.AbstractActor.ActorContext
, which is the Java API of the actor context.- Specified by:
org$apache$pekko$actor$Actor$_setter_$context_$eq
in interfaceActor
-
org$apache$pekko$actor$Actor$_setter_$self_$eq
protected final void org$apache$pekko$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:
org$apache$pekko$actor$Actor$_setter_$self_$eq
in interfaceActor
-
org$apache$pekko$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq
protected final void org$apache$pekko$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> x$1)
- Specified by:
org$apache$pekko$persistence$snapshot$SnapshotStore$_setter_$receiveSnapshotStore_$eq
in interfaceSnapshotStore
-
receiveSnapshotStore
public final scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveSnapshotStore()
- Specified by:
receiveSnapshotStore
in interfaceSnapshotStore
-
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.
-
-