Skip to main content

register_websocket_source

Function register_websocket_source 

Source
pub fn register_websocket_source(
    registry: &ConnectorRegistry,
) -> Result<(), ConnectorError>
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').

ยงErrors

Returns an error when the source name is already registered or the connector registry is frozen.