Package akka.persistence.typed.internal
Interface JournalInteractions<C,E,S>
-
- All Known Implementing Classes:
ReplayingEvents
,ReplayingSnapshot
,RequestingRecoveryPermit
,Running
public interface JournalInteractions<C,E,S>
Intended to be used in .onSignal(returnPermitOnStop) by behaviors
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
internalDeleteEvents(long lastSequenceNr, long toSequenceNr)
OnSaveSnapshotSuccess
, ifSnapshotCountRetentionCriteria.deleteEventsOnSnapshot
is enabled, old messages are deleted based onSnapshotCountRetentionCriteria.snapshotEveryNEvents
before old snapshots are deleted.Running.RunningState<S>
internalPersist(Running.RunningState<S> state, java.lang.Object event)
Running.RunningState<S>
internalPersistAll(scala.collection.immutable.Seq<java.lang.Object> events, Running.RunningState<S> state)
void
replayEvents(long fromSeqNr, long toSeqNr)
void
requestRecoveryPermit()
scala.PartialFunction<scala.Tuple2<ActorContext<InternalProtocol>,Signal>,Behavior<InternalProtocol>>
returnPermitOnStop()
Intended to be used in .onSignal(returnPermitOnStop) by behaviorsBehaviorSetup<C,E,S>
setup()
void
tryReturnRecoveryPermit(java.lang.String reason)
Mutates setup, by setting the `holdingRecoveryPermit` to false
-
-
-
Method Detail
-
internalDeleteEvents
void internalDeleteEvents(long lastSequenceNr, long toSequenceNr)
OnSaveSnapshotSuccess
, ifSnapshotCountRetentionCriteria.deleteEventsOnSnapshot
is enabled, old messages are deleted based onSnapshotCountRetentionCriteria.snapshotEveryNEvents
before old snapshots are deleted.- Parameters:
lastSequenceNr
- (undocumented)toSequenceNr
- (undocumented)
-
internalPersist
Running.RunningState<S> internalPersist(Running.RunningState<S> state, java.lang.Object event)
-
internalPersistAll
Running.RunningState<S> internalPersistAll(scala.collection.immutable.Seq<java.lang.Object> events, Running.RunningState<S> state)
-
replayEvents
void replayEvents(long fromSeqNr, long toSeqNr)
-
requestRecoveryPermit
void requestRecoveryPermit()
-
returnPermitOnStop
scala.PartialFunction<scala.Tuple2<ActorContext<InternalProtocol>,Signal>,Behavior<InternalProtocol>> returnPermitOnStop()
Intended to be used in .onSignal(returnPermitOnStop) by behaviors
-
setup
BehaviorSetup<C,E,S> setup()
-
tryReturnRecoveryPermit
void tryReturnRecoveryPermit(java.lang.String reason)
Mutates setup, by setting the `holdingRecoveryPermit` to false
-
-