Package akka.persistence.typed.state.internal

Interface DurableStateStoreInteractions<C,S>

public interface DurableStateStoreInteractions<C,S>

INTERNAL API

Method Summary

Modifier and Type	Method	Description
akka.persistence.typed.state.internal.Running.RunningState<S>	internalDelete(ActorContext<InternalProtocol> ctx, java.lang.Object cmd, akka.persistence.typed.state.internal.Running.RunningState<S> state, <any> changeEvent)
void	internalGet(ActorContext<InternalProtocol> ctx)
akka.persistence.typed.state.internal.Running.RunningState<S>	internalUpsert(ActorContext<InternalProtocol> ctx, java.lang.Object cmd, akka.persistence.typed.state.internal.Running.RunningState<S> state, java.lang.Object value, <any> changeEvent)
void	onWriteInitiated(ActorContext<?> ctx, java.lang.Object cmd)
void	requestRecoveryPermit()
scala.PartialFunction<scala.Tuple2<ActorContext<InternalProtocol>,Signal>,Behavior<InternalProtocol>>	returnPermitOnStop()	Intended to be used in .onSignal(returnPermitOnStop) by behaviors
akka.persistence.typed.state.internal.BehaviorSetup<C,S>	setup()
void	tryReturnRecoveryPermit(java.lang.String reason)	Mutates setup, by setting the `holdingRecoveryPermit` to false

Method Detail

internalDelete

akka.persistence.typed.state.internal.Running.RunningState<S> internalDelete(ActorContext<InternalProtocol> ctx,
                                                                             java.lang.Object cmd,
                                                                             akka.persistence.typed.state.internal.Running.RunningState<S> state,
                                                                             <any> changeEvent)

internalGet

void internalGet(ActorContext<InternalProtocol> ctx)

internalUpsert

akka.persistence.typed.state.internal.Running.RunningState<S> internalUpsert(ActorContext<InternalProtocol> ctx,
                                                                             java.lang.Object cmd,
                                                                             akka.persistence.typed.state.internal.Running.RunningState<S> state,
                                                                             java.lang.Object value,
                                                                             <any> changeEvent)

onWriteInitiated

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

requestRecoveryPermit

void requestRecoveryPermit()

returnPermitOnStop

scala.PartialFunction<scala.Tuple2<ActorContext<InternalProtocol>,Signal>,Behavior<InternalProtocol>> returnPermitOnStop()

Intended to be used in .onSignal(returnPermitOnStop) by behaviors

setup

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

tryReturnRecoveryPermit

void tryReturnRecoveryPermit(java.lang.String reason)

Mutates setup, by setting the `holdingRecoveryPermit` to false