Skip to main content

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// Issue #91: Live bar engine for real-time streaming sidecar
17#[cfg(feature = "binance-integration")]
18pub mod live_engine;
19
20#[cfg(feature = "binance-integration")]
21pub mod universal;
22
23// Re-export commonly used types
24pub use processor::StreamingProcessor;
25pub use replay_buffer::{ReplayBuffer, ReplayBufferStats};
26
27#[cfg(feature = "stats")]
28pub use stats::{StatisticsSnapshot, StreamingConfig, StreamingStatsEngine};
29
30#[cfg(feature = "indicators")]
31pub use indicators::{
32    CCI, ExponentialMovingAverage, IndicatorError, MACD, MACDValue, RSI, SimpleMovingAverage,
33};
34
35#[cfg(feature = "binance-integration")]
36pub use live_engine::{CompletedBar, LiveBarEngine, LiveEngineConfig, LiveEngineMetrics};
37
38#[cfg(feature = "binance-integration")]
39pub use universal::{StreamError, StreamMode, TradeStream, UniversalStream};