opendeviationbar-streaming 13.78.0

Real-time streaming engine for open deviation bar processing
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

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

pub mod processor;
pub mod replay_buffer;
pub mod ring_buffer; // Issue #96 Task #9: Fixed-size ring buffer for streaming

// Issue #318: ClickHouse native writer (Rust-native CH write path)
#[cfg(feature = "clickhouse-sink")]
pub mod clickhouse_writer;

// Issue #178: Unified hot-path/cold-path engine (three-trait architecture)
#[cfg(feature = "binance-integration")]
pub mod engine;

// Issue #91: Live bar engine for real-time streaming sidecar
#[cfg(feature = "binance-integration")]
pub mod live_engine;

// Issue #257: Gap detection and fill infrastructure
#[cfg(feature = "binance-integration")]
pub mod gap;

// Issue #161: StreamManager with rate-limited gap-fill and trade-ID continuity
#[cfg(feature = "binance-integration")]
pub mod stream_manager;

// Issue #313: Arrow export for CompletedBar drain (v7.2 memory efficiency)
#[cfg(all(feature = "binance-integration", feature = "arrow"))]
pub mod arrow_export;

#[cfg(feature = "binance-integration")]
pub mod universal;

// Re-export commonly used types
pub use processor::StreamingProcessor;
pub use replay_buffer::{ReplayBuffer, ReplayBufferStats};

#[cfg(feature = "binance-integration")]
pub use live_engine::{
    CompletedBar, FormingBar, FormingBarWatches, LiveBarEngine, LiveEngineConfig,
    LiveEngineMetrics, OuroborosMode, WsMode,
};

// Issue #257: Gap detection and fill re-exports
#[cfg(feature = "binance-integration")]
pub use gap::{
    GapEvent, GapFillCommand, GapFillReceiver, GapFillResult, GapFillSender, TradeIdGapDetector,
    gap_fill_channel,
};

// Issue #161: StreamManager re-exports
#[cfg(feature = "binance-integration")]
pub use stream_manager::{StreamManager, StreamManagerConfig, StreamManagerMetrics};

#[cfg(feature = "binance-integration")]
pub use universal::{StreamError, StreamMode, TradeStream, UniversalStream};

// Issue #178: Unified engine re-exports
#[cfg(feature = "binance-integration")]
pub use engine::{
    BarSink, BarSource, ChannelSink, EngineClock, HistoricalClock, LiveBarSource, LiveClock,
    OdbEngine, SinkError, SourceCheckpoint,
};