digdigdig3 0.3.9

Unified async Rust API for 47 exchange connectors (REST + WebSocket). The core layer — pure ExchangeHub + connectors. Higher-level builder, persistence, replay, OB tracker live in `digdigdig3-station`.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! `MarketFeed` — high-level event-stream facade over `ExchangeHub`.
//!
//! Wraps `WebSocketConnector::subscribe` + `event_stream()` into a unified
//! per-subscription `tokio::sync::broadcast` channel so multiple consumers
//! (charting, indicators, persistence) can fan out from one upstream socket.
//!
//! Exchanges live in the hub. The feed never instantiates connectors —
//! it borrows `Arc<dyn WebSocketConnector>` via `hub.ws(id, account_type)`.
//!
//! Options are turned on/off through `FeedBuilder` (persistence, ws_multiplex,
//! reconnect backoff, orderbook tracker, symbol cache). v0 wires only the
//! subscribe API; storage/tracker/reconnect get scaffolded but disabled.

mod builder;
mod handle;
mod options;
mod feed;

pub use builder::FeedBuilder;
pub use feed::MarketFeed;
pub use handle::{FeedHandle, FeedEvent};
pub use options::{PersistenceOption, ReconnectPolicy, OrderbookTrackerOpt};