Expand description
Real-time streaming engine for open deviation bar processing
This module provides real-time streaming capabilities for processing open deviation bars from live data sources with support for replay.
Re-exports§
pub use processor::StreamingProcessor;pub use replay_buffer::ReplayBuffer;pub use replay_buffer::ReplayBufferStats;
Modules§
- processor
- replay_
buffer - Replay buffer for storing and replaying recent trade data
- ring_
buffer - Fixed-size ring buffer for streaming open deviation bars (Issue #96 Task #9)