Index

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

A

abort(WebsocketCloseReason) - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Terminates the connection without waiting for a close handshake.

addRoute(String, Function) - Method in class io.fluxzero.testserver.websocket.JettyWebsocketRouter

Registers a WebSocket route.

append(SerializedMessage...) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

append(List) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

C

cancelSchedule(String) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

cancelSchedule(String, Guarantee) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

ClientMessage() - Constructor for class io.fluxzero.testserver.websocket.WebsocketEndpoint.ClientMessage

close() - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

close() - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

close() - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Closes the session normally.

close(WebsocketCloseReason) - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Closes the session with the provided WebSocket close code and reason.

ConsumerEndpoint - Class in io.fluxzero.testserver.websocket

ConsumerEndpoint(MessageStore, MessageType) - Constructor for class io.fluxzero.testserver.websocket.ConsumerEndpoint

createTasks(RequestBatch, ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

D

DefaultMetricsLog - Class in io.fluxzero.testserver.metrics

DefaultMetricsLog(MessageStore) - Constructor for class io.fluxzero.testserver.metrics.DefaultMetricsLog

DefaultMetricsLog(MessageStore, ExecutorService) - Constructor for class io.fluxzero.testserver.metrics.DefaultMetricsLog

deploy(Function, String, JettyWebsocketRouter) - Static method in class io.fluxzero.testserver.websocket.WebsocketDeploymentUtils

Registers a namespace-aware endpoint route.

deployFromSession(MemoizingFunction, String, JettyWebsocketRouter) - Static method in class io.fluxzero.testserver.websocket.WebsocketDeploymentUtils

Registers a route whose endpoint can be resolved from the complete WebSocket session.

deserializeRequest(ServerWebsocketSession, byte[]) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

doSendResult(ServerWebsocketSession, RequestResult) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

E

EventSourcingEndpoint - Class in io.fluxzero.testserver.websocket

EventSourcingEndpoint() - Constructor for class io.fluxzero.testserver.websocket.EventSourcingEndpoint

F

findAlternativeBacklog(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

G

getBatch(Long, int) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

getBatch(Long, int, boolean) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

getClientId(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

getClientName(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

getClientSdkVersion(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

getCompressionAlgorithm(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

getMessageStore() - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

getNamespace(ServerWebsocketSession) - Static method in class io.fluxzero.testserver.websocket.WebsocketDeploymentUtils

Resolves the test-server namespace from modern namespace or legacy projectId query parameters.

getNamespace(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

getNegotiatedSessionId(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

getRequestHeaders() - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Returns the headers from the WebSocket upgrade request.

getRequestHeaders(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

getRequestParameterMap() - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Returns the decoded query parameters from the WebSocket upgrade request.

getRequestURI() - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Returns the URI that was used for the WebSocket upgrade request.

getRuntimeVersion() - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

getSchedule(String) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

getUserProperties() - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Returns per-session attributes derived during the WebSocket handshake.

H

handle(StoreValues) - Method in class io.fluxzero.testserver.websocket.KeyValueEndPoint

handle(GetSearchHistogram) - Method in class io.fluxzero.testserver.websocket.SearchEndpoint

handle(SearchDocuments) - Method in class io.fluxzero.testserver.websocket.SearchEndpoint

Handle - Annotation Interface in io.fluxzero.testserver.websocket

handleMessage(ServerWebsocketSession, JsonType) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

HANDSHAKE_HEADERS_USER_PROPERTY - Static variable in class io.fluxzero.testserver.websocket.WebsocketDeploymentUtils

hasSchedule(String) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

I

io.fluxzero.testserver - module io.fluxzero.testserver

io.fluxzero.testserver - package io.fluxzero.testserver

io.fluxzero.testserver.metrics - package io.fluxzero.testserver.metrics

io.fluxzero.testserver.scheduling - package io.fluxzero.testserver.scheduling

io.fluxzero.testserver.websocket - package io.fluxzero.testserver.websocket

isOpen() - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Returns whether the underlying transport still accepts frames.

J

JettyWebsocketAdapter - Class in io.fluxzero.testserver.websocket

Jetty listener that adapts a physical WebSocket connection to the test server endpoint contract.

JettyWebsocketRouter - Class in io.fluxzero.testserver.websocket

Embedded Jetty router for the test server's WebSocket endpoints and health check.

JettyWebsocketRouter() - Constructor for class io.fluxzero.testserver.websocket.JettyWebsocketRouter

K

KeyValueEndPoint - Class in io.fluxzero.testserver.websocket

KeyValueEndPoint() - Constructor for class io.fluxzero.testserver.websocket.KeyValueEndPoint

M

main(String[]) - Static method in class io.fluxzero.testserver.TestServer

MetricsLog - Interface in io.fluxzero.testserver.metrics

N

NoOpMetricsLog - Class in io.fluxzero.testserver.metrics

NoOpMetricsLog() - Constructor for class io.fluxzero.testserver.metrics.NoOpMetricsLog

O

onClose(ServerWebsocketSession, WebsocketCloseReason) - Method in class io.fluxzero.testserver.websocket.ConsumerEndpoint

onClose(ServerWebsocketSession, WebsocketCloseReason) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

onError(ServerWebsocketSession, Throwable) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

onMessage(byte[], ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

onOpen(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

onWebSocketBinary(ByteBuffer, Callback) - Method in class io.fluxzero.testserver.websocket.JettyWebsocketAdapter

onWebSocketClose(int, String, Callback) - Method in class io.fluxzero.testserver.websocket.JettyWebsocketAdapter

onWebSocketError(Throwable) - Method in class io.fluxzero.testserver.websocket.JettyWebsocketAdapter

onWebSocketOpen(Session) - Method in class io.fluxzero.testserver.websocket.JettyWebsocketAdapter

P

ProducerEndpoint - Class in io.fluxzero.testserver.websocket

ProducerEndpoint() - Constructor for class io.fluxzero.testserver.websocket.ProducerEndpoint

R

registerMetrics(JsonType) - Method in interface io.fluxzero.testserver.metrics.MetricsLog

registerMetrics(JsonType, Metadata) - Method in class io.fluxzero.testserver.metrics.DefaultMetricsLog

registerMetrics(JsonType, Metadata) - Method in interface io.fluxzero.testserver.metrics.MetricsLog

registerMetrics(JsonType, Metadata) - Method in class io.fluxzero.testserver.metrics.NoOpMetricsLog

registerMetrics(JsonType, ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

registerMonitor(Consumer) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

rescheduleNextDeadline(long) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

RUNTIME_SESSION_ID_USER_PROPERTY - Static variable in class io.fluxzero.testserver.websocket.WebsocketDeploymentUtils

S

schedule(SerializedSchedule...) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

schedule(Guarantee, SerializedSchedule...) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

SchedulingEndpoint - Class in io.fluxzero.testserver.websocket

SchedulingEndpoint() - Constructor for class io.fluxzero.testserver.websocket.SchedulingEndpoint

SearchEndpoint - Class in io.fluxzero.testserver.websocket

SearchEndpoint() - Constructor for class io.fluxzero.testserver.websocket.SearchEndpoint

SELECTED_COMPRESSION_ALGORITHM_USER_PROPERTY - Static variable in class io.fluxzero.testserver.websocket.WebsocketDeploymentUtils

sendBinary(ByteBuffer) - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Sends a complete binary message.

sendPing(ByteBuffer) - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Sends a ping frame with optional application data.

sendResultBatch(ServerWebsocketSession, List) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

ServerWebsocketSession - Interface in io.fluxzero.testserver.websocket

Minimal server-side WebSocket session contract used by the in-memory Fluxzero test server.

SessionBacklog() - Constructor for class io.fluxzero.testserver.websocket.WebsocketEndpoint.SessionBacklog

sessionMetadata(ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

setRetentionTime(Duration) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

shutDown - Variable in class io.fluxzero.testserver.websocket.WebsocketEndpoint

shutDown() - Method in class io.fluxzero.testserver.websocket.ConsumerEndpoint

shutDown() - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

Close all sessions on the websocket after an optional delay.

shuttingDown - Variable in class io.fluxzero.testserver.websocket.WebsocketEndpoint

start(int) - Static method in class io.fluxzero.testserver.TestServer

start(int) - Method in class io.fluxzero.testserver.websocket.JettyWebsocketRouter

Starts Jetty on the given port.

StoreIdentifier() - Constructor for class io.fluxzero.testserver.TestServer.StoreIdentifier

T

TestServer - Class in io.fluxzero.testserver

TestServer() - Constructor for class io.fluxzero.testserver.TestServer

TestServer.StoreIdentifier - Class in io.fluxzero.testserver

TestServerScheduleStore - Class in io.fluxzero.testserver.scheduling

TestServerScheduleStore(InMemoryScheduleStore) - Constructor for class io.fluxzero.testserver.scheduling.TestServerScheduleStore

TestServerVersion - Class in io.fluxzero.testserver

toString() - Method in class io.fluxzero.testserver.websocket.ConsumerEndpoint

U

unwrap(Class) - Method in class io.fluxzero.testserver.scheduling.TestServerScheduleStore

V

version() - Static method in class io.fluxzero.testserver.TestServerVersion

W

WebsocketDeploymentUtils - Class in io.fluxzero.testserver.websocket

Utility methods for mapping Fluxzero test-server WebSocket endpoints onto the embedded Jetty transport.

WebsocketDeploymentUtils() - Constructor for class io.fluxzero.testserver.websocket.WebsocketDeploymentUtils

WebsocketEndpoint - Class in io.fluxzero.testserver.websocket

WebsocketEndpoint() - Constructor for class io.fluxzero.testserver.websocket.WebsocketEndpoint

WebsocketEndpoint(Executor) - Constructor for class io.fluxzero.testserver.websocket.WebsocketEndpoint

WebsocketEndpoint.ClientMessage - Class in io.fluxzero.testserver.websocket

WebsocketEndpoint.SessionBacklog - Class in io.fluxzero.testserver.websocket

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