Package akka.persistence.typed.internal

Interface JournalInteractions<C,E,S>

public interface JournalInteractions<C,E,S>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	JournalInteractions.EventToPersist
static class	JournalInteractions.EventToPersist$

Method Summary

Modifier and Type	Method	Description
void	internalDeleteEvents(long lastSequenceNr, long toSequenceNr)	On SaveSnapshotSuccess, if SnapshotCountRetentionCriteria.deleteEventsOnSnapshot is enabled, old messages are deleted based on SnapshotCountRetentionCriteria.snapshotEveryNEvents before old snapshots are deleted.
akka.persistence.typed.internal.Running.RunningState<S>	internalPersist(<any> cmd, akka.persistence.typed.internal.Running.RunningState<S> state, java.lang.Object event, java.lang.String eventAdapterManifest, <any> metadata)
akka.persistence.typed.internal.Running.RunningState<S>	internalPersistAll(<any> cmd, akka.persistence.typed.internal.Running.RunningState<S> state, scala.collection.immutable.Seq<JournalInteractions.EventToPersist> events)
void	onWriteInitiated(ActorContext<?> ctx, java.lang.Object cmd, PersistentRepr repr)
void	onWritesInitiated(ActorContext<?> ctx, java.lang.Object cmd, scala.collection.immutable.Seq<PersistentRepr> repr)
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 behaviors
akka.persistence.typed.internal.BehaviorSetup<C,E,S>	setup()
void	tryReturnRecoveryPermit(java.lang.String reason)	Mutates setup, by setting the `holdingRecoveryPermit` to false

Method Detail

setup

akka.persistence.typed.internal.BehaviorSetup<C,E,S> setup()

internalPersist

akka.persistence.typed.internal.Running.RunningState<S> internalPersist(<any> cmd,
                                                                        akka.persistence.typed.internal.Running.RunningState<S> state,
                                                                        java.lang.Object event,
                                                                        java.lang.String eventAdapterManifest,
                                                                        <any> metadata)

onWriteInitiated

void onWriteInitiated(ActorContext<?> ctx,
                      java.lang.Object cmd,
                      PersistentRepr repr)

internalPersistAll

akka.persistence.typed.internal.Running.RunningState<S> internalPersistAll(<any> cmd,
                                                                           akka.persistence.typed.internal.Running.RunningState<S> state,
                                                                           scala.collection.immutable.Seq<JournalInteractions.EventToPersist> events)

onWritesInitiated

void onWritesInitiated(ActorContext<?> ctx,
                       java.lang.Object cmd,
                       scala.collection.immutable.Seq<PersistentRepr> repr)

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

tryReturnRecoveryPermit

void tryReturnRecoveryPermit(java.lang.String reason)

Mutates setup, by setting the `holdingRecoveryPermit` to false

internalDeleteEvents

void internalDeleteEvents(long lastSequenceNr,
                          long toSequenceNr)

On SaveSnapshotSuccess, if SnapshotCountRetentionCriteria.deleteEventsOnSnapshot is enabled, old messages are deleted based on SnapshotCountRetentionCriteria.snapshotEveryNEvents before old snapshots are deleted.