digdigdig3-station 0.3.21

//! 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;

// DiskStore: cfg-split between native (std::fs blocking I/O) and wasm32
// (OPFS via async createWritable). Both expose the same struct name so call
// sites compile against either platform without source changes.
#[cfg(not(target_arch = "wasm32"))]
pub mod store;

// The wasm implementation lives in store_wasm.rs; the #[path] alias exposes it
// as `store` so `pub use store::DiskStore` works unchanged on both targets.
#[cfg(target_arch = "wasm32")]
#[path = "store_wasm.rs"]
pub mod store;

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

// PollSpec is wasm-safe (pure Duration + u8).
pub use key::PollSpec;

// DiskStore is available on both targets now.
pub use store::DiskStore;