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|Constant Field Values

A

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

Terminates the connection without waiting for a close handshake.

abort(ServerWebsocketSession, String) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

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

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

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 class io.fluxzero.testserver.websocket.CommandIdempotencyStore

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.

CommandIdempotencyStore - Class in io.fluxzero.testserver.websocket

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

ConsumerEndpoint - Class in io.fluxzero.testserver.websocket

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

Creates a consumer endpoint backed by shared maintenance components for one message log.

ConsumerEndpoint(MessageLogMaintenance, MessageType, String, CommandIdempotencyStore) - Constructor for class io.fluxzero.testserver.websocket.ConsumerEndpoint

Creates a consumer endpoint backed by shared maintenance components for one message log.

ConsumerEndpoint(MessageLogMaintenance, MessageType, String, CommandIdempotencyStore, Consumer) - Constructor for class io.fluxzero.testserver.websocket.ConsumerEndpoint

Creates a consumer endpoint that reports each read after it has been registered with the tracking strategy.

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

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

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

Creates a consumer endpoint for a topic-specific message log.

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

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

Creates a consumer endpoint from explicit tracking components.

ConsumerEndpoint(TrackingStrategy, MessageStore, PositionStore, MessageType, String, CommandIdempotencyStore) - Constructor for class io.fluxzero.testserver.websocket.ConsumerEndpoint

Creates a consumer endpoint from explicit tracking components.

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

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

D

DEFAULT_MAX_BINARY_FRAGMENT_BYTES - Static variable in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Default upper bound for one physical WebSocket binary frame when a message is sent as fragments.

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

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

dispatchRequest(ServerWebsocketSession, JsonType, long) - 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(EventStoreClient, CommandIdempotencyStore) - 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

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

getBatch(Long, int, long) - 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

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

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

handleMessage(ServerWebsocketSession, JsonType, long) - 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(KeyValueClient, CommandIdempotencyStore) - Constructor for class io.fluxzero.testserver.websocket.KeyValueEndPoint

M

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

Standalone process entry point.

merge(Registration) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint.PingRegistration

MetricsLog - Interface in io.fluxzero.testserver.metrics

monitor(BiConsumer) - Static method in class io.fluxzero.testserver.metrics.TestServerMetricsMonitor

N

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

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

onPong(ByteBuffer, ServerWebsocketSession) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

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

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

onWebSocketPong(ByteBuffer) - Method in class io.fluxzero.testserver.websocket.JettyWebsocketAdapter

P

pingDelay - Static variable in class io.fluxzero.testserver.websocket.WebsocketEndpoint

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

pingTimeout - Static variable in class io.fluxzero.testserver.websocket.WebsocketEndpoint

ProducerEndpoint - Class in io.fluxzero.testserver.websocket

ProducerEndpoint(MessageLogMaintenance, MessageType, String) - Constructor for class io.fluxzero.testserver.websocket.ProducerEndpoint

Creates a producer endpoint backed by the shared maintenance components for one message log.

ProducerEndpoint(MessageLogMaintenance, MessageType, String, CommandIdempotencyStore) - Constructor for class io.fluxzero.testserver.websocket.ProducerEndpoint

Creates a producer endpoint backed by the shared maintenance components for one message log.

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

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

ProducerEndpoint(MessageStore, MessageType, String, CommandIdempotencyStore) - Constructor for class io.fluxzero.testserver.websocket.ProducerEndpoint

R

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

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

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

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

registerMetrics(Object, 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

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

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

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

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

SchedulingEndpoint - Class in io.fluxzero.testserver.websocket

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

SearchEndpoint - Class in io.fluxzero.testserver.websocket

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

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

SELECTED_TRANSPORT_FORMAT_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.

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

Sends a complete binary message asynchronously.

sendBinaryAsync(ByteBuffer, int) - Method in interface io.fluxzero.testserver.websocket.ServerWebsocketSession

Sends one complete binary WebSocket message asynchronously, allowing implementations to split the message into WebSocket continuation frames.

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

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

sendResultBatchAsync(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

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

shouldHandleIdempotently(Command) - Method in class io.fluxzero.testserver.websocket.ProducerEndpoint

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

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

Starts an embedded test server on the given port without registering a JVM shutdown hook.

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

Starts Jetty on the given port.

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

Starts an embedded test server using the configured port.

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

Starts an embedded test server on the given port.

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

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

T

TestServer - Class in io.fluxzero.testserver

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

TestServer.StoreIdentifier - Class in io.fluxzero.testserver

TestServerMetricsMonitor - Class in io.fluxzero.testserver.metrics

Lightweight observation hook for embedded test-server users.

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

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

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

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

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(CommandIdempotencyStore) - Constructor for class io.fluxzero.testserver.websocket.WebsocketEndpoint

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

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

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

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

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

webSocketSendTimeout - Static variable in class io.fluxzero.testserver.websocket.WebsocketEndpoint

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|Constant Field Values