sdk-core/dev.restate.sdk.core.statemachine/StateMachine

StateMachine

interface StateMachine : Flow.Processor<T, R>

More or less same as the VM trait

Types

class Awakeable : Record

class CallHandle : Record

DoProgressResponse

interface DoProgressResponse

class Input : Record

Functions

attachInvocation

abstract fun attachInvocation(invocationId: String): Int

abstract fun awakeable(): StateMachine.Awakeable

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

cancelInvocation

abstract fun cancelInvocation(targetInvocationId: String)

completeAwakeable

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

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

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

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

createSignalHandle

abstract fun createSignalHandle(signalName: String): Int

abstract fun doProgress(anyHandle: List<Integer>): StateMachine.DoProgressResponse

abstract fun end()

getInvocationOutput

abstract fun getInvocationOutput(invocationId: String): Int

getResponseContentType

abstract fun getResponseContentType(): String

open fun init(headersAccessor: HeadersAccessor, loggingContextSetter: EndpointRequestHandler.LoggingContextSetter): StateMachine

@Nullable

abstract fun input(): @Nullable StateMachine.Input

abstract fun isCompleted(handle: Int): Boolean

abstract fun onComplete()

abstract fun onError(p: Throwable)

abstract fun onNext(p: T)

abstract fun onSubscribe(p: Flow.Subscription)

promiseComplete

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

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

abstract fun promiseGet(key: String): Int

abstract fun promisePeek(key: String): Int

proposeRunCompletion

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

abstract fun proposeRunCompletion(handle: Int, exception: Throwable, attemptDuration: Duration, retryPolicy: RetryPolicy)

abstract fun run(name: String): Int

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

abstract fun sleep(duration: Duration, name: String): Int

abstract fun state(): InvocationState

abstract fun stateClear(key: String)

abstract fun stateClearAll()

abstract fun stateGet(key: String): Int

abstract fun stateGetKeys(): Int

abstract fun stateSet(key: String, bytes: Slice)

abstract fun subscribe(p: Flow.Subscriber<in T>)

takeNotification

abstract fun takeNotification(handle: Int): Optional<NotificationValue>

abstract fun waitForReady(): CompletableFuture<Void>

waitNextInputSignal

abstract fun waitNextInputSignal(): CompletableFuture<Void>

abstract fun writeOutput(value: Slice)

abstract fun writeOutput(exception: TerminalException)