opendeviationbar-client 13.76.0

Client library for consuming open deviation bar data via SSE
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

// Issue #170: opendeviationbar-client crate
//! Client library for consuming open deviation bar data via SSE.
//!
//! Provides a typed Rust API for connecting to the ODB sidecar's SSE endpoint
//! and receiving completed bars as a stream.
//!
//! # Example
//!
//! ```ignore
//! use opendeviationbar_client::{OdbSseClient, OdbSseConfig, OdbSseEvent};
//! use futures::StreamExt;
//!
//! let client = OdbSseClient::new(OdbSseConfig {
//!     host: "127.0.0.1".into(),
//!     port: 8081,
//!     symbols: vec!["BTCUSDT".into()],
//!     thresholds: vec![250],
//! });
//!
//! let mut stream = std::pin::pin!(client.connect());
//! while let Some(event) = stream.next().await {
//!     match event {
//!         OdbSseEvent::Bar(bar) => println!("{} @{}: {}", bar.symbol, bar.threshold, bar.close),
//!         OdbSseEvent::Connected => println!("connected"),
//!         OdbSseEvent::Heartbeat => {},
//!         OdbSseEvent::DeserializationError { error, .. } => eprintln!("bad bar: {error}"),
//!         OdbSseEvent::Disconnected(reason) => println!("disconnected: {reason}"),
//!     }
//! }
//! ```

mod sse;
mod transport;

pub use sse::{OdbBar, OdbSseClient, OdbSseConfig, OdbSseEvent};