Skip to main content

opendeviationbar_streaming/
lib.rs

1//! Real-time streaming engine for open deviation bar processing
2//!
3//! This module provides real-time streaming capabilities for processing
4//! open deviation bars from live data sources with support for replay, statistics,
5//! and indicators.
6
7pub mod processor;
8pub mod replay_buffer;
9pub mod ring_buffer;  // Issue #96 Task #9: Fixed-size ring buffer for streaming
10
11#[cfg(feature = "stats")]
12pub mod stats;
13
14#[cfg(feature = "indicators")]
15pub mod indicators;
16
17// Issue #91: Live bar engine for real-time streaming sidecar
18#[cfg(feature = "binance-integration")]
19pub mod live_engine;
20
21#[cfg(feature = "binance-integration")]
22pub mod universal;
23
24// Re-export commonly used types
25pub use processor::StreamingProcessor;
26pub use replay_buffer::{ReplayBuffer, ReplayBufferStats};
27
28#[cfg(feature = "stats")]
29pub use stats::{StatisticsSnapshot, StreamingConfig, StreamingStatsEngine};
30
31#[cfg(feature = "indicators")]
32pub use indicators::{
33    CCI, ExponentialMovingAverage, IndicatorError, MACD, MACDValue, RSI, SimpleMovingAverage,
34};
35
36#[cfg(feature = "binance-integration")]
37pub use live_engine::{CompletedBar, LiveBarEngine, LiveEngineConfig, LiveEngineMetrics};
38
39#[cfg(feature = "binance-integration")]
40pub use universal::{StreamError, StreamMode, TradeStream, UniversalStream};