sdk-core/dev.restate.sdk.core.legacy/LegacyStateMachine

LegacyStateMachine

Legacy pure-Java StateMachine, used on JDK <23 or when the native shared-core library is unavailable/disabled. This is a deprecated fallback that will be removed in a future release; the native (FFM) state machine is the path that supports the latest Restate features.

Constructors

LegacyStateMachine

constructor(headersAccessor: HeadersAccessor, loggingContextSetter: EndpointRequestHandler.LoggingContextSetter)

Functions

attachInvocation

open fun attachInvocation(invocationId: String): Int

awakeable

open fun awakeable(): StateMachine.Awakeable

call

open fun call(target: Target, payload: Slice, @Nullable idempotencyKey: @Nullable String, @Nullable scope: @Nullable String, @Nullable limitKey: @Nullable String, @Nullable headers: @Nullable Collection<Map.Entry<String, String>>): StateMachine.CallHandle

cancelInvocation

open fun cancelInvocation(targetInvocationId: String)

open fun close()

abstract fun close()

completeAwakeable

open fun completeAwakeable(awakeableId: String, value: Slice)

open fun completeAwakeable(awakeableId: String, exception: TerminalException)

completeSignal

open fun completeSignal(targetInvocationId: String, signalName: String, value: Slice)

open fun completeSignal(targetInvocationId: String, signalName: String, exception: TerminalException)

createSignalHandle

open fun createSignalHandle(signalName: String): Int

doAwait

open fun doAwait(future: UnresolvedFuture): StateMachine.AwaitResult

Make progress on the still-uncompleted await tree rooted at future, or return


null

when nothing is left to await (every node already resolved).

end

open fun end()

getInvocationOutput

open fun getInvocationOutput(invocationId: String): Int

getResponseContentType

open fun getResponseContentType(): String

input

open fun input(): StateMachine.Input

isReadyToExecute

open fun isReadyToExecute(): Boolean

notifyError

open fun notifyError(throwable: Throwable)

notifyInput

open fun notifyInput(bytes: Slice)

Feed the next chunk of wire input.

notifyInputClosed

open fun notifyInputClosed()

promiseComplete

open fun promiseComplete(key: String, value: Slice): Int

open fun promiseComplete(key: String, exception: TerminalException): Int

promiseGet

open fun promiseGet(key: String): Int

promisePeek

open fun promisePeek(key: String): Int

proposeRunCompletion

open fun proposeRunCompletion(handle: Int, value: Slice)

open fun proposeRunCompletion(handle: Int, terminalException: TerminalException)

open fun proposeRunCompletion(handle: Int, exception: Throwable, attemptDuration: Duration, @Nullable retryPolicy: @Nullable RetryPolicy)

run

open fun run(name: String): StateMachine.RunResultHandle

send

open fun send(target: Target, payload: Slice, @Nullable idempotencyKey: @Nullable String, @Nullable scope: @Nullable String, @Nullable limitKey: @Nullable String, @Nullable headers: @Nullable Collection<Map.Entry<String, String>>, @Nullable delay: @Nullable Duration): Int

sleep