Interface DurableStateStoreInteractions<C,​S>


  • public interface DurableStateStoreInteractions<C,​S>
    INTERNAL API
    • Method Detail

      • 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)
      • onWriteInitiated

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

        void requestRecoveryPermit()
      • 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