Package dev.restate.sdk.endpoint.definition

Interface HandlerRunner<REQ,RES>

All Known Implementing Classes:

HandlerRunner

public interface HandlerRunner<REQ,RES>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	HandlerRunner.Options	Marker interface of runner options.

Field Summary

Fields

Modifier and Type	Field	Description
static final ThreadLocal<HandlerContext>	HANDLER_CONTEXT_THREAD_LOCAL	Thread local to store HandlerContext.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Slice>	run(HandlerContext handlerContext, Serde<REQ> requestSerde, Serde<RES> responseSerde, AtomicReference<Runnable> onClosedInvocationStreamHook)

Field Details

HANDLER_CONTEXT_THREAD_LOCAL

static final ThreadLocal<HandlerContext> HANDLER_CONTEXT_THREAD_LOCAL

Thread local to store HandlerContext.

Implementations of HandlerRunner should correctly propagate this thread local in order for logging to work correctly. Could be improved if ScopedContext will ever be introduced in log4j2.

Method Details

run

CompletableFuture<Slice> run(HandlerContext handlerContext,
 Serde<REQ> requestSerde,
 Serde<RES> responseSerde,
 AtomicReference<Runnable> onClosedInvocationStreamHook)