Skip to main content

register_websocket_sink

Function register_websocket_sink 

Source
pub fn register_websocket_sink(registry: &ConnectorRegistry)
Expand description

Registers the WebSocket sink connector with the given registry.

After registration, the runtime can instantiate WebSocketSinkServer by name when processing CREATE SINK ... WITH (connector = 'websocket').