Package dev.restate.sdk.core

Class EndpointRequestHandler

java.lang.Object

dev.restate.sdk.core.EndpointRequestHandler

public final class EndpointRequestHandler
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	EndpointRequestHandler.LoggingContextSetter	Interface to abstract setting the logging context variables.

Method Summary

Modifier and Type	Method	Description
static EndpointRequestHandler	create(Endpoint endpoint)
static EndpointRequestHandler	forBidiStream(Endpoint endpoint)	Deprecated. The protocol mode is now established on request basis, use create(Endpoint) instead.
static EndpointRequestHandler	forRequestResponse(Endpoint endpoint)	Deprecated. The protocol mode is now established on request basis, use create(Endpoint) instead.
RequestProcessor	processorForRequest(String path, HeadersAccessor headersAccessor, EndpointRequestHandler.LoggingContextSetter loggingContextSetter, Executor coreExecutor)	Deprecated. Use processorForRequest(String, HeadersAccessor, LoggingContextSetter, Executor, boolean) instead.
RequestProcessor	processorForRequest(String path, HeadersAccessor headersAccessor, EndpointRequestHandler.LoggingContextSetter loggingContextSetter, Executor coreExecutor, boolean supportsBidirectionalStreaming)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static EndpointRequestHandler create(Endpoint endpoint)

forBidiStream

@Deprecated
public static EndpointRequestHandler forBidiStream(Endpoint endpoint)

Deprecated.

The protocol mode is now established on request basis, use create(Endpoint) instead.

forRequestResponse

@Deprecated
public static EndpointRequestHandler forRequestResponse(Endpoint endpoint)

Deprecated.

The protocol mode is now established on request basis, use create(Endpoint) instead.

processorForRequest

@Deprecated
public RequestProcessor processorForRequest(String path,
 HeadersAccessor headersAccessor,
 EndpointRequestHandler.LoggingContextSetter loggingContextSetter,
 Executor coreExecutor)
                                     throws ProtocolException

Deprecated.

Use processorForRequest(String, HeadersAccessor, LoggingContextSetter, Executor, boolean) instead.

Throws:

ProtocolException

processorForRequest

public RequestProcessor processorForRequest(String path,
 HeadersAccessor headersAccessor,
 EndpointRequestHandler.LoggingContextSetter loggingContextSetter,
 Executor coreExecutor,
 boolean supportsBidirectionalStreaming)
                                     throws ProtocolException

Parameters:

coreExecutor - This executor MUST serialize the execution of all scheduled tasks. For example Executors.newSingleThreadExecutor() can be used.

supportsBidirectionalStreaming - true if the server supports bidirectional streaming.

Returns:

The request processor

Throws:

ProtocolException