Index

A C D E F G H I J K M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values

A

abort(Throwable) - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkedProxyRequest

accept(List) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

append(byte[], boolean) - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkedProxyRequest

applyCorsHeaders(ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

asHttpRequest(SerializedMessage, URI, WebRequestSettings) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

asWebResponse(Throwable) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

asWebResponse(HttpResponse) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

C

cancel() - Method in class io.fluxzero.proxy.ProxyServer

ChunkAccumulator(int) - Constructor for class io.fluxzero.proxy.ProxyRequestHandler.ChunkAccumulator

ChunkedProxyRequest(WebRequest) - Constructor for class io.fluxzero.proxy.ProxyRequestHandler.ChunkedProxyRequest

clientId() - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Returns the value of the clientId record component.

clientId() - Method in record class io.fluxzero.proxy.ProxyWebsocketEndpoint.SessionContext

Returns the value of the clientId record component.

clone(Object) - Method in class io.fluxzero.proxy.ProxySerializer

close() - Method in class io.fluxzero.proxy.ProxyRequestHandler

completeChunkedResponse(ProxyRequestHandler.ChunkedProxyRequest, SerializedMessage, Throwable, ProxyRequestHandler.ProxyResponseContext) - Method in class io.fluxzero.proxy.ProxyRequestHandler

completeResponse(SerializedMessage, Throwable, ProxyRequestHandler.ProxyResponseContext) - Method in class io.fluxzero.proxy.ProxyRequestHandler

convert(Object, Type) - Method in class io.fluxzero.proxy.ProxySerializer

CORS_DOMAINS_PROPERTY - Static variable in class io.fluxzero.proxy.ProxyRequestHandler

corsOrigin(String) - Method in class io.fluxzero.proxy.ProxyRequestHandler

createChunkedRequestMessage(WebRequest, byte[], long, boolean, boolean) - Method in class io.fluxzero.proxy.ProxyRequestHandler

createForNamespace(String) - Method in class io.fluxzero.proxy.ProxyRequestHandler

createResponseContext(WebRequest, ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

createWebRequest(ProxyRequestHandler.JettyExchange, byte[]) - Method in class io.fluxzero.proxy.ProxyRequestHandler

D

DEFAULT_IDLE_TIMEOUT_MILLIS - Static variable in class io.fluxzero.proxy.ProxyServer

Default connector idle timeout: 60 seconds

DEFAULT_MAX_HEADER_SIZE - Static variable in class io.fluxzero.proxy.ProxyServer

Default maximum request and response header size: 1 MiB

DEFAULT_MAX_IN_FLIGHT_WEB_REQUESTS - Static variable in class io.fluxzero.proxy.ProxyServer

Default maximum in-flight web requests accepted by the proxy.

DEFAULT_MAX_MULTIPART_REQUEST_BODY_SIZE - Static variable in class io.fluxzero.proxy.ProxyServer

Default maximum multipart request body size: 1 GiB

DEFAULT_MAX_PENDING_WEBSOCKET_SENDS - Static variable in class io.fluxzero.proxy.ProxyServer

Default maximum queued outgoing websocket sends per session.

DEFAULT_MAX_REQUEST_BODY_SIZE - Static variable in class io.fluxzero.proxy.ProxyServer

Default maximum request body size: 256 MiB

DEFAULT_MAX_THREADS - Static variable in class io.fluxzero.proxy.ProxyServer

Default Jetty maximum platform thread count.

DEFAULT_MIN_THREADS - Static variable in class io.fluxzero.proxy.ProxyServer

Default Jetty minimum platform thread count.

defaultSettings - Static variable in class io.fluxzero.proxy.ForwardProxyConsumer

deserialize(SerializedObject) - Method in class io.fluxzero.proxy.ProxySerializer

deserialize(SerializedObject, Class) - Method in class io.fluxzero.proxy.ProxySerializer

deserialize(Stream, UnknownTypeStrategy) - Method in class io.fluxzero.proxy.ProxySerializer

deserializeFirstMessage(SerializedMessage, MessageType, String) - Method in class io.fluxzero.proxy.ProxySerializer

deserializeFirstMessageOrNull(SerializedMessage, MessageType, String) - Method in class io.fluxzero.proxy.ProxySerializer

deserializeMessage(SerializedMessage, MessageType) - Method in class io.fluxzero.proxy.ProxySerializer

deserializeMessages(Stream, MessageType) - Method in class io.fluxzero.proxy.ProxySerializer

deserializeMessages(Stream, MessageType, UnknownTypeStrategy) - Method in class io.fluxzero.proxy.ProxySerializer

deserializeMessages(Stream, MessageType, String) - Method in class io.fluxzero.proxy.ProxySerializer

deserializeMessages(Stream, MessageType, String, UnknownTypeStrategy) - Method in class io.fluxzero.proxy.ProxySerializer

dispatchFuture() - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkedProxyRequest

dispatchReadableChunks(WebRequest, ProxyRequestHandler.ChunkAccumulator, boolean, ProxyRequestHandler.ChunkedProxyRequest) - Method in class io.fluxzero.proxy.ProxyRequestHandler

doSendChunkedWebRequest(ProxyRequestHandler.JettyExchange, WebRequest) - Method in class io.fluxzero.proxy.ProxyRequestHandler

doSendWebRequest(ProxyRequestHandler.JettyExchange, WebRequest) - Method in class io.fluxzero.proxy.ProxyRequestHandler

downcast(Data, int) - Method in class io.fluxzero.proxy.ProxySerializer

downcast(Object, int) - Method in class io.fluxzero.proxy.ProxySerializer

E

ensureStarted() - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

equals(Object) - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class io.fluxzero.proxy.ProxyWebsocketEndpoint.SessionContext

Indicates whether some other object is "equal to" this one.

executeRequest(HttpRequest) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

F

filterContent(T, User) - Method in class io.fluxzero.proxy.ProxySerializer

FLUXZERO_NAMESPACE_HEADER - Static variable in class io.fluxzero.proxy.NamespaceSelector

forDefaultNamespace() - Method in class io.fluxzero.proxy.ProxyRequestHandler

formatType(SerializedMessage) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

forNamespace(String) - Method in class io.fluxzero.proxy.ProxyRequestHandler

ForwardProxyConsumer - Class in io.fluxzero.proxy

ForwardProxyConsumer() - Constructor for class io.fluxzero.proxy.ForwardProxyConsumer

G

getBodyPublisher(SerializedMessage) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

getContext(ProxyWebsocketSession) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

getSettings(SerializedMessage) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

getString(String) - Method in class io.fluxzero.proxy.JwtVerifier.JwtClaims

Retrieves the string value associated with the specified claim name from the JSON structure.

H

handle(SerializedMessage, URI, WebRequestSettings) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

handle(Request, Response, Callback) - Method in class io.fluxzero.proxy.ProxyRequestHandler

handleCorsPreflight(ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

handleDisconnects(List) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

handleResponse(SerializedMessage, ProxyRequestHandler.ProxyResponseContext) - Method in class io.fluxzero.proxy.ProxyRequestHandler

handleResultMessages(List) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

hasBytes() - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkAccumulator

hasDispatchedFinalChunk() - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkedProxyRequest

hashCode() - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Returns a hash code value for this object.

hashCode() - Method in record class io.fluxzero.proxy.ProxyWebsocketEndpoint.SessionContext

Returns a hash code value for this object.

I

intermediateResponses() - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkedProxyRequest

io.fluxzero.proxy - module io.fluxzero.proxy

io.fluxzero.proxy - package io.fluxzero.proxy

isFull() - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkAccumulator

isWebsocketUpgrade(ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

J

JettyProxyWebsocketAdapter - Class in io.fluxzero.proxy

Jetty listener that adapts a physical websocket connection to the proxy websocket endpoint contract.

JWKS_URL_PROPERTY - Static variable in class io.fluxzero.proxy.NamespaceSelector

JwtClaims() - Constructor for class io.fluxzero.proxy.JwtVerifier.JwtClaims

JwtVerifier - Class in io.fluxzero.proxy

JwtVerifier provides functionality to verify the cryptographic signature of a JSON Web Token (JWT) and validate its claims.

JwtVerifier() - Constructor for class io.fluxzero.proxy.JwtVerifier

JwtVerifier.JwtClaims - Class in io.fluxzero.proxy

Represents the claims contained in a decoded JWT (JSON Web Token).

K

knownRequestBodyTooLarge(ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

M

main(String[]) - Static method in class io.fluxzero.proxy.ProxyServer

Standalone process entry point.

maxPendingSends() - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Returns the value of the maxPendingSends record component.

merge(Registration) - Method in class io.fluxzero.proxy.ProxyServer

metadata() - Method in record class io.fluxzero.proxy.ProxyWebsocketEndpoint.SessionContext

Returns the value of the metadata record component.

metricsSerializer - Static variable in class io.fluxzero.proxy.ForwardProxyConsumer

N

namespace() - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Returns the value of the namespace record component.

NamespaceSelector - Class in io.fluxzero.proxy

The NamespaceSelector class is responsible for determining and decoding a namespace value from an HTTP web request.

NamespaceSelector() - Constructor for class io.fluxzero.proxy.NamespaceSelector

normalize(SerializedObject) - Method in class io.fluxzero.proxy.ProxySerializer

O

onBinary(ProxyWebsocketSession, byte[]) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

onClose(ProxyWebsocketSession, WebsocketCloseReason) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

onError(ProxyWebsocketSession, Throwable) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

onOpen(ProxyWebsocketSession) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

onPong(ProxyWebsocketSession, ByteBuffer) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

onText(ProxyWebsocketSession, String) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

onWebSocketBinary(ByteBuffer, Callback) - Method in class io.fluxzero.proxy.JettyProxyWebsocketAdapter

onWebSocketClose(int, String, Callback) - Method in class io.fluxzero.proxy.JettyProxyWebsocketAdapter

onWebSocketError(Throwable) - Method in class io.fluxzero.proxy.JettyProxyWebsocketAdapter

onWebSocketOpen(Session) - Method in class io.fluxzero.proxy.JettyProxyWebsocketAdapter

onWebSocketPong(ByteBuffer) - Method in class io.fluxzero.proxy.JettyProxyWebsocketAdapter

onWebSocketText(String) - Method in class io.fluxzero.proxy.JettyProxyWebsocketAdapter

P

pendingSends() - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Returns the value of the pendingSends record component.

prepareForSending(SerializedMessage, ProxyRequestHandler.JettyExchange, int) - Method in class io.fluxzero.proxy.ProxyRequestHandler

ProxyRequestHandler - Class in io.fluxzero.proxy

ProxyRequestHandler(Client) - Constructor for class io.fluxzero.proxy.ProxyRequestHandler

ProxyRequestHandler.ChunkAccumulator - Class in io.fluxzero.proxy

ProxyRequestHandler.ChunkedProxyRequest - Class in io.fluxzero.proxy

ProxyRequestHandler.JettyExchange - Class in io.fluxzero.proxy

ProxyRequestHandler.ProxyResponseContext - Class in io.fluxzero.proxy

ProxySerializer - Class in io.fluxzero.proxy

ProxySerializer() - Constructor for class io.fluxzero.proxy.ProxySerializer

ProxyServer - Class in io.fluxzero.proxy

ProxyServer(ProxyRequestHandler, Server, int, Registration, boolean) - Constructor for class io.fluxzero.proxy.ProxyServer

ProxyWebsocketBackpressureEvent - Record Class in io.fluxzero.proxy

Metric emitted when the proxy disconnects a websocket session because outgoing frames are not draining.

ProxyWebsocketBackpressureEvent(String, String, String, String, int, int) - Constructor for record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Creates an instance of a ProxyWebsocketBackpressureEvent record class.

ProxyWebsocketEndpoint - Class in io.fluxzero.proxy

ProxyWebsocketEndpoint(Client, RequestHandler) - Constructor for class io.fluxzero.proxy.ProxyWebsocketEndpoint

ProxyWebsocketEndpoint.SessionContext - Record Class in io.fluxzero.proxy

publishHandleMessageMetrics(SerializedMessage, boolean, Instant) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

publishProcessBatchMetrics(Instant) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

R

readChunkedWebRequest(ProxyRequestHandler.JettyExchange, WebRequest) - Method in class io.fluxzero.proxy.ProxyRequestHandler

readFrom(InputStream) - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkAccumulator

registerCasters(Object...) - Method in class io.fluxzero.proxy.ProxySerializer

registerDowncasters(Object...) - Method in class io.fluxzero.proxy.ProxySerializer

registerTypeCaster(String, String) - Method in class io.fluxzero.proxy.ProxySerializer

registerUpcasters(Object...) - Method in class io.fluxzero.proxy.ProxySerializer

REQUEST_CHUNK_SIZE_PROPERTY - Static variable in class io.fluxzero.proxy.ProxyRequestHandler

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

REQUEST_CHUNKING_ENABLED_PROPERTY - Static variable in class io.fluxzero.proxy.ProxyRequestHandler

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

REQUEST_TIMEOUT_SECONDS_PROPERTY - Static variable in class io.fluxzero.proxy.ProxyRequestHandler

resolveKey(String) - Method in class io.fluxzero.proxy.JwtVerifier

responseFuture() - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkedProxyRequest

runningConsumers - Variable in class io.fluxzero.proxy.ForwardProxyConsumer

S

select(WebRequest) - Method in class io.fluxzero.proxy.NamespaceSelector

Extracts and decodes the namespace value from the given web request.

sendCloseRequest(ProxyWebsocketSession, WebsocketCloseReason) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

sendGatewayTimeout(ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

sendRequest(ProxyWebsocketSession, String, byte[]) - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

sendRequestTimeout(ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

sendResolvedWebRequest(ProxyRequestHandler.JettyExchange, WebRequest, boolean) - Method in class io.fluxzero.proxy.ProxyRequestHandler

sendResponse(SerializedMessage, ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

sendResponse(WebResponse, SerializedMessage) - Method in class io.fluxzero.proxy.ForwardProxyConsumer

sendServerError(ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

sendWebRequest(ProxyRequestHandler.JettyExchange, WebRequest, boolean) - Method in class io.fluxzero.proxy.ProxyRequestHandler

serialize(Object) - Method in class io.fluxzero.proxy.ProxySerializer

serialize(Object, String) - Method in class io.fluxzero.proxy.ProxySerializer

serializer - Static variable in class io.fluxzero.proxy.ForwardProxyConsumer

SessionContext(Metadata, String, String) - Constructor for record class io.fluxzero.proxy.ProxyWebsocketEndpoint.SessionContext

Creates an instance of a SessionContext record class.

sessionId() - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Returns the value of the sessionId record component.

shouldChunkRequest(ProxyRequestHandler.JettyExchange) - Method in class io.fluxzero.proxy.ProxyRequestHandler

shutDown() - Method in class io.fluxzero.proxy.ProxyWebsocketEndpoint

start() - Method in class io.fluxzero.proxy.ForwardProxyConsumer

start() - Static method in class io.fluxzero.proxy.ProxyServer

Starts an embedded proxy server using the configured port and runtime base URL.

start(Client) - Static method in class io.fluxzero.proxy.ForwardProxyConsumer

T

takeBytes() - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkAccumulator

takeChunk() - Method in class io.fluxzero.proxy.ProxyRequestHandler.ChunkAccumulator

toString() - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Returns a string representation of this record class.

toString() - Method in record class io.fluxzero.proxy.ProxyWebsocketEndpoint.SessionContext

Returns a string representation of this record class.

trackerId() - Method in record class io.fluxzero.proxy.ProxyWebsocketBackpressureEvent

Returns the value of the trackerId record component.

trackerId() - Method in record class io.fluxzero.proxy.ProxyWebsocketEndpoint.SessionContext

Returns the value of the trackerId record component.

tryUpgrade(WebRequest) - Method in class io.fluxzero.proxy.ProxyRequestHandler

U

upcastType(String) - Method in class io.fluxzero.proxy.ProxySerializer

V

verify(String) - Method in class io.fluxzero.proxy.JwtVerifier

Verifies the provided JWT (JSON Web Token) for its signature, expiration, and not-before validity.

A C D E F G H I J K M N O P R S T U V
All Classes and Interfaces|All Packages|Constant Field Values