sdk-common/dev.restate.sdk.common.syscalls/Syscalls

Syscalls

Internal interface to access Restate functionalities. Users can use the ad-hoc RestateContext interfaces provided by the various implementations.

When using executor switching wrappers, the method's callback will be executed in the state machine executor.

Functions

awakeable

abstract fun awakeable(callback: SyscallCallback<Map.Entry<String, Deferred<ByteBuffer>>>)

call

abstract fun call(target: Target, parameter: ByteBuffer, callback: SyscallCallback<Deferred<ByteBuffer>>)

clear

abstract fun clear(name: String, callback: SyscallCallback<Void>)

clearAll

abstract fun clearAll(callback: SyscallCallback<Void>)

createAllDeferred

abstract fun createAllDeferred(children: List<Deferred<out Any>>): Deferred<Void>

createAnyDeferred

abstract fun createAnyDeferred(children: List<Deferred<out Any>>): Deferred<Integer>

enterSideEffectBlock

abstract fun enterSideEffectBlock(@Nullable name: @Nullable String, callback: EnterSideEffectSyscallCallback)

exitSideEffectBlock

abstract fun exitSideEffectBlock(toWrite: ByteBuffer, callback: ExitSideEffectSyscallCallback)

exitSideEffectBlockWithException

abstract fun exitSideEffectBlockWithException(toWrite: Throwable, @Nullable retryPolicy: @Nullable RetryPolicy, callback: ExitSideEffectSyscallCallback)

exitSideEffectBlockWithTerminalException

abstract fun ~~exitSideEffectBlockWithTerminalException~~(toWrite: TerminalException, callback: ExitSideEffectSyscallCallback)

fail

abstract fun fail(cause: Throwable)

get

abstract fun get(name: String, callback: SyscallCallback<Deferred<ByteBuffer>>)

getKeys

abstract fun getKeys(callback: SyscallCallback<Deferred<Collection<String>>>)

isInsideSideEffect

abstract fun isInsideSideEffect(): Boolean

objectKey

abstract fun objectKey(): String

peekPromise

abstract fun peekPromise(key: String, callback: SyscallCallback<Deferred<ByteBuffer>>)

promise

abstract fun promise(key: String, callback: SyscallCallback<Deferred<ByteBuffer>>)

rejectAwakeable

abstract fun rejectAwakeable(id: String, reason: String, requestCallback: SyscallCallback<Void>)

rejectPromise

abstract fun rejectPromise(key: String, reason: String, callback: SyscallCallback<Deferred<Void>>)

request

abstract fun request(): Request

resolveAwakeable

abstract fun resolveAwakeable(id: String, payload: ByteBuffer, requestCallback: SyscallCallback<Void>)

resolveDeferred

abstract fun <T> resolveDeferred(deferredToResolve: Deferred<T>, callback: SyscallCallback<Void>)

resolvePromise

abstract fun resolvePromise(key: String, payload: ByteBuffer, callback: SyscallCallback<Deferred<Void>>)

send

abstract fun send(target: Target, parameter: ByteBuffer, @Nullable delay: @Nullable Duration, requestCallback: SyscallCallback<Void>)

set

abstract fun set(name: String, value: ByteBuffer, callback: SyscallCallback<Void>)

sleep

abstract fun sleep(duration: Duration, callback: SyscallCallback<Deferred<Void>>)

writeOutput

abstract fun writeOutput(exception: TerminalException, callback: SyscallCallback<Void>)

abstract fun writeOutput(value: ByteBuffer, callback: SyscallCallback<Void>)