Package akka.persistence.typed.internal

Interface Summary

Interface	Description
BehaviorSetup.SnapshotAfterPersist
InternalProtocol	Protocol used internally by the eventsourced behaviors.
JournalInteractions<C,E,S>	Intended to be used in .onSignal(returnPermitOnStop) by behaviors
Running.WithSeqNrAccessible
SnapshotInteractions<C,E,S>	Instructs the snapshot store to load the specified snapshot and send it via an SnapshotOffer to the running PersistentActor.
StashManagement<C,E,S>	Stash a command to the internal stash buffer, which is used while waiting for persist to be completed.
StashOverflowStrategy	INTERNAL API

Class Summary

Class	Description
BehaviorSetup<C,E,S>	catchAndLog=true should be used for "unknown" signals in the phases before Running to avoid restart loops if restart supervision is used.
BehaviorSetup.NoSnapshot$
BehaviorSetup.SnapshotWithoutRetention$
BehaviorSetup.SnapshotWithRetention$
BehaviorSetup$	INTERNAL API
Callback<State>	INTERNAL API
CompositeEffect<Event,State>
CompositeEffect$	INTERNAL API
DisabledRetentionCriteria	INTERNAL API
DisabledRetentionCriteria$	INTERNAL API
EffectImpl<Event,State>	INTERNAL API
EventSourcedBehaviorImpl<Command,Event,State>
EventSourcedBehaviorImpl.WriterIdentity
EventSourcedBehaviorImpl.WriterIdentity$
EventSourcedBehaviorImpl$
EventSourcedSettings
EventSourcedSettings$	INTERNAL API
InternalProtocol.IncomingCommand<C>
InternalProtocol.IncomingCommand$
InternalProtocol.JournalResponse
InternalProtocol.JournalResponse$
InternalProtocol.RecoveryPermitGranted$
InternalProtocol.RecoveryTickEvent
InternalProtocol.RecoveryTickEvent$
InternalProtocol.SnapshotterResponse
InternalProtocol.SnapshotterResponse$
InternalProtocol$
NoOpSnapshotAdapter	INTERNAL API
NoOpSnapshotAdapter$	INTERNAL API
NoReplyEffectImpl<State>	INTERNAL API
Persist<Event,State>	INTERNAL API
Persist$
PersistAll<Event,State>	INTERNAL API
PersistAll$
PersistenceMdc	INTERNAL API
PersistenceMdc$	INTERNAL API
PersistNothing	INTERNAL API
PersistNothing$	INTERNAL API
ReplayingEvents<C,E,S>	Called whenever a message replay fails.
ReplayingEvents.ReplayingState<State>
ReplayingEvents.ReplayingState$
ReplayingEvents$	INTERNAL API
ReplayingSnapshot<C,E,S>	Called whenever snapshot recovery fails.
ReplayingSnapshot$	INTERNAL API
ReplyEffectImpl<ReplyMessage,State>	INTERNAL API
RequestingRecoveryPermit<C,E,S>
RequestingRecoveryPermit$	INTERNAL API
Running<C,E,S>	INTERNAL API
Running.RunningState<State>
Running.RunningState$
Running$	INTERNAL API
SideEffect<State>	A SideEffect is an side effect that can be chained after a main effect.
SideEffect$	INTERNAL API
SnapshotCountRetentionCriteriaImpl	INTERNAL API
SnapshotCountRetentionCriteriaImpl$
Stash	INTERNAL API
Stash$	INTERNAL API
StashOverflowStrategy.Drop$
StashOverflowStrategy.Fail$
StashOverflowStrategy$	INTERNAL API
StashState	INTERNAL API: stash buffer state in order to survive restart of internal behavior
Stop	INTERNAL API
Stop$	INTERNAL API
Unhandled	INTERNAL API
Unhandled$	INTERNAL API
UnstashAll	INTERNAL API
UnstashAll$	INTERNAL API

Exception Summary

Exception	Description
JournalFailureException	INTERNAL API