sdk-common/dev.restate.sdk.endpoint.definition/HandlerContext

HandlerContext

interface HandlerContext

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

Types

class Awakeable : Record

class CallResult : Record

interface RunCompleter

Functions

attachInvocation

abstract fun attachInvocation(invocationId: String): CompletableFuture<AsyncResult<Slice>>

abstract fun awakeable(): CompletableFuture<HandlerContext.Awakeable>

abstract fun call(target: Target, parameter: Slice, @Nullable idempotencyKey: @Nullable String, @Nullable headers: @Nullable Collection<Map.Entry<String, String>>): CompletableFuture<HandlerContext.CallResult>

cancelInvocation

abstract fun cancelInvocation(invocationId: String): CompletableFuture<Void>

abstract fun clear(name: String): CompletableFuture<Void>

abstract fun clearAll(): CompletableFuture<Void>

createAllAsyncResult

abstract fun createAllAsyncResult(children: List<AsyncResult<out Any>>): AsyncResult<Void>

createAnyAsyncResult

abstract fun createAnyAsyncResult(children: List<AsyncResult<out Any>>): AsyncResult<Integer>

abstract fun fail(cause: Throwable)

abstract fun get(name: String): CompletableFuture<AsyncResult<Optional<Slice>>>

getInvocationOutput

abstract fun getInvocationOutput(invocationId: String): CompletableFuture<AsyncResult<Output<Slice>>>

abstract fun getKeys(): CompletableFuture<AsyncResult<Collection<String>>>

abstract fun objectKey(): String

abstract fun peekPromise(key: String): CompletableFuture<AsyncResult<Output<Slice>>>

abstract fun promise(key: String): CompletableFuture<AsyncResult<Slice>>

rejectAwakeable

abstract fun rejectAwakeable(id: String, reason: TerminalException): CompletableFuture<Void>

abstract fun rejectPromise(key: String, reason: TerminalException): CompletableFuture<AsyncResult<Void>>

abstract fun request(): HandlerRequest

resolveAwakeable

abstract fun resolveAwakeable(id: String, payload: Slice): CompletableFuture<Void>

abstract fun resolvePromise(key: String, payload: Slice): CompletableFuture<AsyncResult<Void>>

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

abstract fun set(name: String, value: Slice): CompletableFuture<Void>

abstract fun submitRun(@Nullable name: @Nullable String, closure: Consumer<HandlerContext.RunCompleter>): CompletableFuture<AsyncResult<Slice>>

abstract fun timer(duration: Duration, @Nullable name: @Nullable String): CompletableFuture<AsyncResult<Void>>

abstract fun writeOutput(value: Slice): CompletableFuture<Void>

abstract fun writeOutput(exception: TerminalException): CompletableFuture<Void>