sdk-core/dev.restate.sdk.core/SyscallsImpl

SyscallsImpl

class SyscallsImpl : SyscallsInternal

Functions

awakeable

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

call

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

clear

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

clearAll

open fun clearAll(callback: SyscallCallback<Void>)

open fun close()

createAllDeferred

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

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

createAnyDeferred

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

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

enterSideEffectBlock

open fun enterSideEffectBlock(name: String, callback: EnterSideEffectSyscallCallback)

exitSideEffectBlock

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

exitSideEffectBlockWithException

open fun exitSideEffectBlockWithException(runException: Throwable, @Nullable retryPolicy: @Nullable RetryPolicy, callback: ExitSideEffectSyscallCallback)

exitSideEffectBlockWithTerminalException

open fun exitSideEffectBlockWithTerminalException(toWrite: TerminalException, callback: ExitSideEffectSyscallCallback)

fail

open fun fail(cause: Throwable)

get

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

getFullyQualifiedMethodName

open fun getFullyQualifiedMethodName(): String

getInvocationState

open fun getInvocationState(): InvocationState

getKeys

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

isInsideSideEffect

open fun isInsideSideEffect(): Boolean

objectKey

open fun objectKey(): String

peekPromise

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

promise

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

rejectAwakeable

open fun rejectAwakeable(serializedId: String, reason: String, callback: SyscallCallback<Void>)

rejectPromise

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

request

open fun request(): Request

resolveAwakeable

open fun resolveAwakeable(serializedId: String, payload: ByteBuffer, callback: SyscallCallback<Void>)

resolveDeferred

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

resolvePromise

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

send

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

set

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

sleep

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

writeOutput

open fun writeOutput(throwable: TerminalException, callback: SyscallCallback<Void>)

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