Crate faucet_source_websocket 

faucet-source-websocket

A WebSocket streaming source connector. Connects to a ws:// or wss:// endpoint, optionally sends one or more subscription frames, and streams each incoming message as a record until max_messages, idle_timeout, or Ctrl-C terminates the run.

Re-exports

pub use config::OnParseError;

pub use config::WebsocketAuth;

pub use config::WebsocketSourceConfig;

pub use config::WsMessageFormat;

pub use stream::WebsocketSource;

Modules

config

Configuration types for the WebSocket source.

stream

WebSocket source stream executor.

Enums

FaucetError

All possible errors returned by faucet-stream.

Traits

Source

A source fetches records from an external system.