Package org.apache.pekko.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 final class	JournalInteractions.EventToPersist
static class	JournalInteractions.EventToPersist$

Method Summary

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

Method Details

setup

org.apache.pekko.persistence.typed.internal.BehaviorSetup<C,E,S> setup()

internalPersist

org.apache.pekko.persistence.typed.internal.Running.RunningState<S,C> internalPersist(ActorContext<?> ctx,
 Object cmd,
 org.apache.pekko.persistence.typed.internal.Running.RunningState<S,C> state,
 Object event,
 String eventAdapterManifest,
 <any> metadata)

onWriteInitiated

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

internalPersistAll

org.apache.pekko.persistence.typed.internal.Running.RunningState<S,C> internalPersistAll(ActorContext<?> ctx,
 Object cmd,
 org.apache.pekko.persistence.typed.internal.Running.RunningState<S,C> state,
 scala.collection.immutable.Seq<JournalInteractions.EventToPersist> events)

onWritesInitiated

void onWritesInitiated(ActorContext<?> ctx,
 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(String reason)

Mutates setup, by setting the `holdingRecoveryPermit` to false

internalDeleteEvents

void internalDeleteEvents(long lastSequenceNr,
 long toSequenceNr)

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