Skip to main content

register_websocket_source

laminar_connectors::websocket

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 ... FROM WEBSOCKET (...).

ยงErrors

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