Package dev.restate.sdk.endpoint.definition

Interface HandlerContext

public interface HandlerContext

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

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final record	HandlerContext.Awakeable
static final record	HandlerContext.CallResult
static interface	HandlerContext.RunCompleter

Method Summary

Modifier and Type	Method	Description
CompletableFuture<AsyncResult<Slice>>	attachInvocation(String invocationId)
CompletableFuture<HandlerContext.Awakeable>	awakeable()
CompletableFuture<HandlerContext.CallResult>	call(Target target, Slice parameter, @Nullable String idempotencyKey, @Nullable Collection<Map.Entry<String,String>> headers)
CompletableFuture<Void>	cancelInvocation(String invocationId)
CompletableFuture<Void>	clear(String name)
CompletableFuture<Void>	clearAll()
AsyncResult<Void>	createAllAsyncResult(List<AsyncResult<?>> children)
AsyncResult<Integer>	createAnyAsyncResult(List<AsyncResult<?>> children)
void	fail(Throwable cause)
CompletableFuture<AsyncResult<Optional<Slice>>>	get(String name)
CompletableFuture<AsyncResult<Output<Slice>>>	getInvocationOutput(String invocationId)
CompletableFuture<AsyncResult<Collection<String>>>	getKeys()
String	objectKey()
CompletableFuture<AsyncResult<Output<Slice>>>	peekPromise(String key)
CompletableFuture<AsyncResult<Slice>>	promise(String key)
CompletableFuture<Void>	rejectAwakeable(String id, TerminalException reason)
CompletableFuture<AsyncResult<Void>>	rejectPromise(String key, TerminalException reason)
HandlerRequest	request()
CompletableFuture<Void>	resolveAwakeable(String id, Slice payload)
CompletableFuture<AsyncResult<Void>>	resolvePromise(String key, Slice payload)
CompletableFuture<AsyncResult<String>>	send(Target target, Slice parameter, @Nullable String idempotencyKey, @Nullable Collection<Map.Entry<String,String>> headers, @Nullable Duration delay)
CompletableFuture<Void>	set(String name, Slice value)
CompletableFuture<AsyncResult<Slice>>	submitRun(@Nullable String name, Consumer<HandlerContext.RunCompleter> closure)
CompletableFuture<AsyncResult<Void>>	timer(Duration duration, @Nullable String name)
CompletableFuture<Void>	writeOutput(Slice value)
CompletableFuture<Void>	writeOutput(TerminalException exception)

Method Details

objectKey

String objectKey()

request

HandlerRequest request()

writeOutput

CompletableFuture<Void> writeOutput(Slice value)

writeOutput

CompletableFuture<Void> writeOutput(TerminalException exception)

get

CompletableFuture<AsyncResult<Optional<Slice>>> get(String name)

getKeys

CompletableFuture<AsyncResult<Collection<String>>> getKeys()

clear

CompletableFuture<Void> clear(String name)

clearAll

CompletableFuture<Void> clearAll()

set

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

timer

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

call

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

send

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

submitRun

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

awakeable

CompletableFuture<HandlerContext.Awakeable> awakeable()

resolveAwakeable

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

rejectAwakeable

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

promise

CompletableFuture<AsyncResult<Slice>> promise(String key)

peekPromise

CompletableFuture<AsyncResult<Output<Slice>>> peekPromise(String key)

resolvePromise

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

rejectPromise

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

cancelInvocation

CompletableFuture<Void> cancelInvocation(String invocationId)

attachInvocation

CompletableFuture<AsyncResult<Slice>> attachInvocation(String invocationId)

getInvocationOutput

CompletableFuture<AsyncResult<Output<Slice>>> getInvocationOutput(String invocationId)

fail

void fail(Throwable cause)

createAnyAsyncResult

AsyncResult<Integer> createAnyAsyncResult(List<AsyncResult<?>> children)

createAllAsyncResult

AsyncResult<Void> createAllAsyncResult(List<AsyncResult<?>> children)