Class ProxyRequestHandler

java.lang.Object

io.fluxzero.sdk.common.AbstractNamespaced<ProxyRequestHandler>

io.fluxzero.proxy.ProxyRequestHandler

All Implemented Interfaces:

Namespaced<ProxyRequestHandler>

public class ProxyRequestHandler
extends AbstractNamespaced<ProxyRequestHandler>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	ProxyRequestHandler.ChunkAccumulator
protected class	ProxyRequestHandler.ChunkedProxyRequest
protected static class	ProxyRequestHandler.JettyExchange
protected static class	ProxyRequestHandler.ProxyResponseContext

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BENCHMARK_TRACE_HEADERS_ENABLED_PROPERTY	Enables returning proxy benchmark trace headers when a request also includes BENCHMARK_TRACE_ID_HEADER.
static final String	CORS_DOMAINS_PROPERTY
static final String	REQUEST_CHUNK_SIZE_PROPERTY	Maximum payload bytes per web request chunk when REQUEST_CHUNKING_ENABLED_PROPERTY is enabled.
static final String	REQUEST_CHUNKING_ENABLED_PROPERTY	Enables publishing large or unknown-length request bodies as chunked web request messages.
static final String	REQUEST_TIMEOUT_SECONDS_PROPERTY

Constructor Summary

Constructors

Constructor	Description
ProxyRequestHandler(Client client)

Method Summary

Modifier and Type	Method	Description
protected void	applyBenchmarkTraceHeaders(SerializedMessage responseMessage, ProxyRequestHandler.ProxyResponseContext responseContext, Instant proxyWebResponseReceived)
protected boolean	applyCorsHeaders(ProxyRequestHandler.JettyExchange exchange)
void	close()
protected void	completeChunkedResponse(ProxyRequestHandler.ChunkedProxyRequest chunkedRequest, SerializedMessage response, Throwable error, ProxyRequestHandler.ProxyResponseContext responseContext)
protected void	completeResponse(SerializedMessage response, Throwable error, ProxyRequestHandler.ProxyResponseContext responseContext)
protected boolean	corsOrigin(String origin)
protected SerializedMessage	createChunkedRequestMessage(WebRequest webRequest, byte[] chunk, long chunkIndex, boolean firstChunk, boolean finalChunk)
protected ProxyRequestHandler	createForNamespace(String namespace)
protected ProxyRequestHandler.ProxyResponseContext	createResponseContext(WebRequest webRequest, ProxyRequestHandler.JettyExchange exchange)
protected WebRequest	createWebRequest(ProxyRequestHandler.JettyExchange exchange, byte[] payload)
protected ProxyRequestHandler.ChunkedProxyRequest	dispatchReadableChunks(WebRequest webRequest, ProxyRequestHandler.ChunkAccumulator pending, boolean last, ProxyRequestHandler.ChunkedProxyRequest chunkedRequest)
protected void	doSendChunkedWebRequest(ProxyRequestHandler.JettyExchange exchange, WebRequest webRequest)
protected void	doSendWebRequest(ProxyRequestHandler.JettyExchange exchange, WebRequest webRequest)
boolean	handle(org.eclipse.jetty.server.Request request, org.eclipse.jetty.server.Response response, org.eclipse.jetty.util.Callback callback)
protected boolean	handleCorsPreflight(ProxyRequestHandler.JettyExchange exchange)
protected void	handleResponse(SerializedMessage responseMessage, ProxyRequestHandler.ProxyResponseContext responseContext)
protected boolean	isWebsocketUpgrade(ProxyRequestHandler.JettyExchange exchange)
protected boolean	knownRequestBodyTooLarge(ProxyRequestHandler.JettyExchange exchange)
protected void	prepareForSending(SerializedMessage responseMessage, ProxyRequestHandler.JettyExchange exchange, int statusCode)
protected void	readChunkedWebRequest(ProxyRequestHandler.JettyExchange exchange, WebRequest webRequest)
protected void	sendGatewayTimeout(ProxyRequestHandler.JettyExchange exchange)
protected void	sendRequestTimeout(ProxyRequestHandler.JettyExchange exchange)
protected void	sendResolvedWebRequest(ProxyRequestHandler.JettyExchange exchange, WebRequest webRequest, boolean chunked)
protected void	sendResponse(SerializedMessage responseMessage, ProxyRequestHandler.JettyExchange exchange)
protected void	sendServerError(ProxyRequestHandler.JettyExchange exchange)
protected void	sendWebRequest(ProxyRequestHandler.JettyExchange exchange, WebRequest webRequest, boolean chunked)
protected boolean	shouldChunkRequest(ProxyRequestHandler.JettyExchange exchange)
protected WebRequest	tryUpgrade(WebRequest webRequest)

Methods inherited from class AbstractNamespaced

forNamespace

Methods inherited from class Object

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

Methods inherited from interface Namespaced

forDefaultNamespace

Field Details

CORS_DOMAINS_PROPERTY

public static final String CORS_DOMAINS_PROPERTY

See Also:

• Constant Field Values

REQUEST_TIMEOUT_SECONDS_PROPERTY

public static final String REQUEST_TIMEOUT_SECONDS_PROPERTY

See Also:

• Constant Field Values

REQUEST_CHUNKING_ENABLED_PROPERTY

public static final String REQUEST_CHUNKING_ENABLED_PROPERTY

Enables publishing large or unknown-length request bodies as chunked web request messages.

Defaults to false for backward compatibility with applications that still run older SDK clients.

See Also:

• Constant Field Values

REQUEST_CHUNK_SIZE_PROPERTY

public static final String REQUEST_CHUNK_SIZE_PROPERTY

Maximum payload bytes per web request chunk when REQUEST_CHUNKING_ENABLED_PROPERTY is enabled.

See Also:

• Constant Field Values

BENCHMARK_TRACE_HEADERS_ENABLED_PROPERTY

public static final String BENCHMARK_TRACE_HEADERS_ENABLED_PROPERTY

Enables returning proxy benchmark trace headers when a request also includes BENCHMARK_TRACE_ID_HEADER.

Use system property fluxzero.proxy.benchmark.trace.headers.enabled=true or environment variable FLUXZERO_PROXY_BENCHMARK_TRACE_HEADERS_ENABLED=true.

See Also:

• Constant Field Values

Constructor Details

ProxyRequestHandler

public ProxyRequestHandler(Client client)

Method Details

createForNamespace

protected ProxyRequestHandler createForNamespace(String namespace)

Specified by:

createForNamespace in class AbstractNamespaced<ProxyRequestHandler>

handle

public boolean handle(org.eclipse.jetty.server.Request request,
 org.eclipse.jetty.server.Response response,
 org.eclipse.jetty.util.Callback callback)

createWebRequest

protected WebRequest createWebRequest(ProxyRequestHandler.JettyExchange exchange,
 byte[] payload)

tryUpgrade

protected WebRequest tryUpgrade(WebRequest webRequest)

knownRequestBodyTooLarge

protected boolean knownRequestBodyTooLarge(ProxyRequestHandler.JettyExchange exchange)

shouldChunkRequest

protected boolean shouldChunkRequest(ProxyRequestHandler.JettyExchange exchange)

isWebsocketUpgrade

protected boolean isWebsocketUpgrade(ProxyRequestHandler.JettyExchange exchange)

handleCorsPreflight

protected boolean handleCorsPreflight(ProxyRequestHandler.JettyExchange exchange)

applyCorsHeaders

protected boolean applyCorsHeaders(ProxyRequestHandler.JettyExchange exchange)

corsOrigin

protected boolean corsOrigin(String origin)

sendWebRequest

protected void sendWebRequest(ProxyRequestHandler.JettyExchange exchange,
 WebRequest webRequest,
 boolean chunked)

sendResolvedWebRequest

protected void sendResolvedWebRequest(ProxyRequestHandler.JettyExchange exchange,
 WebRequest webRequest,
 boolean chunked)

doSendWebRequest

protected void doSendWebRequest(ProxyRequestHandler.JettyExchange exchange,
 WebRequest webRequest)

createResponseContext

protected ProxyRequestHandler.ProxyResponseContext createResponseContext(WebRequest webRequest,
 ProxyRequestHandler.JettyExchange exchange)

doSendChunkedWebRequest

protected void doSendChunkedWebRequest(ProxyRequestHandler.JettyExchange exchange,
 WebRequest webRequest)

readChunkedWebRequest

protected void readChunkedWebRequest(ProxyRequestHandler.JettyExchange exchange,
 WebRequest webRequest)

dispatchReadableChunks

protected ProxyRequestHandler.ChunkedProxyRequest dispatchReadableChunks(WebRequest webRequest,
 ProxyRequestHandler.ChunkAccumulator pending,
 boolean last,
 ProxyRequestHandler.ChunkedProxyRequest chunkedRequest)

createChunkedRequestMessage

protected SerializedMessage createChunkedRequestMessage(WebRequest webRequest,
 byte[] chunk,
 long chunkIndex,
 boolean firstChunk,
 boolean finalChunk)

completeChunkedResponse

protected void completeChunkedResponse(ProxyRequestHandler.ChunkedProxyRequest chunkedRequest,
 SerializedMessage response,
 Throwable error,
 ProxyRequestHandler.ProxyResponseContext responseContext)

completeResponse

protected void completeResponse(SerializedMessage response,
 Throwable error,
 ProxyRequestHandler.ProxyResponseContext responseContext)

handleResponse

protected void handleResponse(SerializedMessage responseMessage,
 ProxyRequestHandler.ProxyResponseContext responseContext)

applyBenchmarkTraceHeaders

protected void applyBenchmarkTraceHeaders(SerializedMessage responseMessage,
 ProxyRequestHandler.ProxyResponseContext responseContext,
 Instant proxyWebResponseReceived)

prepareForSending

protected void prepareForSending(SerializedMessage responseMessage,
 ProxyRequestHandler.JettyExchange exchange,
 int statusCode)

sendResponse

protected void sendResponse(SerializedMessage responseMessage,
 ProxyRequestHandler.JettyExchange exchange)

sendServerError

protected void sendServerError(ProxyRequestHandler.JettyExchange exchange)

sendGatewayTimeout

protected void sendGatewayTimeout(ProxyRequestHandler.JettyExchange exchange)

sendRequestTimeout

protected void sendRequestTimeout(ProxyRequestHandler.JettyExchange exchange)

close

public void close()

Overrides:

close in class AbstractNamespaced<ProxyRequestHandler>