faucet_source_websocket/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2
3//! # faucet-source-websocket
4//!
5//! A WebSocket streaming source connector. Connects to a `ws://` or `wss://`
6//! endpoint, optionally sends one or more subscription frames, and streams
7//! each incoming message as a record until `max_messages`, `idle_timeout`, or
8//! Ctrl-C terminates the run.
9
10pub mod config;
11pub mod stream;
12
13pub use faucet_core::{FaucetError, Source};
14
15pub use config::{OnParseError, WebsocketAuth, WebsocketSourceConfig, WsMessageFormat};
16pub use stream::WebsocketSource;