faucet-source-websocket 1.0.0

WebSocket streaming source connector for the faucet-stream ecosystem
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

#![cfg_attr(docsrs, feature(doc_cfg))]

//! # 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.

pub mod config;
pub mod stream;

pub use faucet_core::{FaucetError, Source};

pub use config::{OnParseError, WebsocketAuth, WebsocketSourceConfig, WsMessageFormat};
pub use stream::WebsocketSource;