opendeviationbar-streaming 13.79.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

//! Unified hot-path/cold-path engine (Issue #178)
//!
//! Three-trait architecture for swappable source/sink composition:
//! - `BarSource`: async bar producer (live WS, replay, Vision)
//! - `BarSink`: synchronous bar consumer (channel, SSE, strategy)
//! - `EngineClock`: time abstraction (live wall clock, historical event time)

pub mod clock;
pub mod odb_engine;
pub mod sink_channel;
pub mod source_live;
pub mod traits;

pub use clock::{HistoricalClock, LiveClock};
pub use odb_engine::OdbEngine;
pub use sink_channel::ChannelSink;
pub use source_live::LiveBarSource;
pub use traits::{BarSink, BarSource, EngineClock, SinkError, SourceCheckpoint};

// Issue #318: Re-export ClickHouseWriterSink when feature is enabled
#[cfg(feature = "clickhouse-sink")]
pub use super::clickhouse_writer::sink::ClickHouseWriterSink;