Index

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

A

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

ConsumerEndpoint - Class in io.fluxzero.testserver.websocket

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

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

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

Creates and configures a WebSocketDeploymentInfo instance, setting up the buffer pool and worker for handling WebSocket connections.

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, PathHandler) - Static method in class io.fluxzero.testserver.websocket.WebsocketDeploymentUtils

Deploys a WebSocket server endpoint for the specified path using an endpoint supplier and a path handler.

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

Deploys a WebSocket server endpoint using a specified session-to-endpoint mapping function, path, and handler.

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

doSendResult(Session, 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(Session) - 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(Session) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

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

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

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

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

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

Extracts the namespace from the given WebSocket session, using the namespace parameter.

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

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

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

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

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

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(Session, 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

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

MultiClientEndpoint - Class in io.fluxzero.testserver.websocket

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

N

NoOpMetricsLog - Class in io.fluxzero.testserver.metrics

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

O

onClose(Session, CloseReason) - Method in class io.fluxzero.testserver.websocket.ConsumerEndpoint

onClose(Session, CloseReason) - Method in class io.fluxzero.testserver.websocket.MultiClientEndpoint

onClose(Session, CloseReason) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

onError(Session, Throwable) - Method in class io.fluxzero.testserver.websocket.MultiClientEndpoint

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

onOpen(Session, EndpointConfig) - Method in class io.fluxzero.testserver.websocket.MultiClientEndpoint

onOpen(Session, EndpointConfig) - Method in class io.fluxzero.testserver.websocket.WebsocketEndpoint

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, Session) - 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

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

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

sessionMetadata(Session) - 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

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 class for deploying WebSocket server endpoints using Undertow or similar frameworks.

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 K M N O P R S T U V W
All Classes and Interfaces|All Packages