Module websocket 

WebSocket source and sink connectors. WebSocket source/sink connectors. Four modes: source-client (connect to a WS server), source-server (listen for clients), sink-server (fan out results to subscribers), sink-client (push to an external server).

WebSocket is non-replayable — source connectors are at-most-once / best-effort; sinks have a bounded, best-effort replay buffer.

Re-exports

pub use backpressure::WsBackpressure;

pub use checkpoint::WebSocketSourceCheckpoint;

pub use metrics::WebSocketSourceMetrics;

pub use protocol::ClientMessage;

pub use protocol::ServerMessage;

pub use sink::WebSocketSinkServer;

pub use sink_client::WebSocketSinkClient;

pub use sink_config::SinkFormat;

pub use sink_config::SinkMode;

pub use sink_config::SlowClientPolicy;

pub use sink_config::WebSocketSinkConfig;

pub use sink_metrics::WebSocketSinkMetrics;

pub use source::WebSocketSource;

pub use source_config::EventTimeFormat;

pub use source_config::MessageFormat;

pub use source_config::ReconnectConfig;

pub use source_config::SourceMode;

pub use source_config::WebSocketSourceConfig;

pub use source_config::WsAuthConfig;

pub use source_server::WebSocketSourceServer;

Modules

backpressure

Backpressure strategies for WebSocket connectors.

checkpoint

WebSocket source checkpoint types.

connection

WebSocket connection management: reconnection, failover, heartbeat.

fanout

Per-client fan-out manager for WebSocket sink server mode.

metrics

WebSocket source connector metrics.

parser

Message parsing: WebSocket frames → Arrow RecordBatch.

protocol

Subscription wire protocol for WebSocket sink server mode.

serializer

Arrow RecordBatch → WebSocket message serialization.

sink

WebSocket sink connector — server mode.

sink_client

WebSocket sink connector — client mode.

sink_config

WebSocket sink connector configuration.

sink_metrics

WebSocket sink connector metrics.

source

WebSocket source connector — client mode.

source_config

WebSocket source connector configuration.

source_server

WebSocket source connector — server mode.

Functions

register_websocket_sink

Registers the WebSocket sink connector with the given registry.

register_websocket_source

Registers the WebSocket source connector with the given registry.