Skip to main content

register_websocket_source

Function register_websocket_source 

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

Registers the WebSocket source connector with the given registry.

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