rangebar_streaming/
lib.rs

1//! Real-time streaming engine for range bar processing
2//!
3//! This module provides real-time streaming capabilities for processing
4//! range bars from live data sources with support for replay, statistics,
5//! and indicators.
6
7pub mod processor;
8pub mod replay_buffer;
9
10#[cfg(feature = "stats")]
11pub mod stats;
12
13#[cfg(feature = "indicators")]
14pub mod indicators;
15
16#[cfg(feature = "binance-integration")]
17pub mod universal;
18
19// Re-export commonly used types
20pub use processor::StreamingProcessor;
21pub use replay_buffer::{ReplayBuffer, ReplayBufferStats};
22
23#[cfg(feature = "stats")]
24pub use stats::{StatisticsSnapshot, StreamingConfig, StreamingStatsEngine};
25
26#[cfg(feature = "indicators")]
27pub use indicators::{
28    CCI, ExponentialMovingAverage, IndicatorError, MACD, MACDValue, RSI, SimpleMovingAverage,
29};
30
31#[cfg(feature = "binance-integration")]
32pub use universal::{StreamError, StreamMode, TradeStream, UniversalStream};