Package org.apache.pekko.persistence.typed.state.internal

Interface DurableStateStoreInteractions<C,S>

public interface DurableStateStoreInteractions<C,S>

INTERNAL API

Method Summary

Modifier and Type	Method	Description
org.apache.pekko.persistence.typed.state.internal.Running.RunningState<S>	internalDelete(ActorContext<InternalProtocol> ctx, java.lang.Object cmd, org.apache.pekko.persistence.typed.state.internal.Running.RunningState<S> state)
void	internalGet(ActorContext<InternalProtocol> ctx)
org.apache.pekko.persistence.typed.state.internal.Running.RunningState<S>	internalUpsert(ActorContext<InternalProtocol> ctx, java.lang.Object cmd, org.apache.pekko.persistence.typed.state.internal.Running.RunningState<S> state, java.lang.Object value)
void	onDeleteInitiated(ActorContext<?> ctx, java.lang.Object cmd)
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
org.apache.pekko.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

org.apache.pekko.persistence.typed.state.internal.Running.RunningState<S> internalDelete(ActorContext<InternalProtocol> ctx,
                                                                                         java.lang.Object cmd,
                                                                                         org.apache.pekko.persistence.typed.state.internal.Running.RunningState<S> state)

internalGet

void internalGet(ActorContext<InternalProtocol> ctx)

internalUpsert

org.apache.pekko.persistence.typed.state.internal.Running.RunningState<S> internalUpsert(ActorContext<InternalProtocol> ctx,
                                                                                         java.lang.Object cmd,
                                                                                         org.apache.pekko.persistence.typed.state.internal.Running.RunningState<S> state,
                                                                                         java.lang.Object value)

onDeleteInitiated

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

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

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

tryReturnRecoveryPermit

void tryReturnRecoveryPermit(java.lang.String reason)

Mutates setup, by setting the `holdingRecoveryPermit` to false