digdigdig3-station 0.3.2

Consumer-facing builder over digdigdig3 ExchangeHub. Persistence, cache, replay, cure, orderbook tracker, multiplex, reconnect.
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

//! Unified time-series infrastructure for Station data-classes.
//!
//! All Station-managed market data — trades, bars, orderbook snapshots,
//! tickers, mark prices, funding rates, open interest, liquidations, agg
//! trades — flows through the same plumbing:
//!
//! ```text
//!   WS event ──► forwarder ──► Series<T>.push(memory ring)
//!                          ├─► DiskStore<T>.append (fixed-record binary)
//!                          └─► broadcast::Sender ──► consumer
//!
//!   subscribe ──► Series<T>.seed_from_disk() ──► emit LastN immediately
//!             └─► then attach to live stream
//! ```
//!
//! The key abstraction is [`DataPoint`] — each market data type provides a
//! fixed-size on-disk encoding + an extractor from `StreamEvent`. Series and
//! DiskStore are generic over `DataPoint`.
//!
//! Pattern borrowed from `mylittlechart::bar-service` (SharedSeriesMap +
//! seed_from_disk + flush_dirty), generalized over data-class.

pub mod data_point;
pub mod key;
pub mod map;
pub mod series;
pub mod store;

pub use data_point::DataPoint;
pub use key::{Kind, SeriesKey};
pub use map::SharedSeriesMap;
pub use series::Series;
pub use store::DiskStore;