Skip to main content

Module websocket

Module websocket 

Source
Expand description

WebSocket source and sink connectors. WebSocket client source plus client/server sinks.

WebSocket is non-replayable. Sources and sinks are best-effort, and failures can produce gaps or duplicates.

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.