oxigdal_streaming/v2/mod.rs
1//! Streaming v2: production-quality additions to the OxiGDAL streaming framework.
2//!
3//! # Modules
4//!
5//! | Module | Purpose |
6//! |---|---|
7//! | [`backpressure`] | Credit-based flow control (producer/consumer credit pools) |
8//! | [`session_window`] | Gap-detection session windows with configurable min-events and max-duration |
9//! | [`stream_join`] | Temporal stream-to-stream joins (inner / left-outer / interval) |
10//! | [`checkpoint`] | Serialisable checkpoint state with in-memory store and manager |
11
12pub mod backpressure;
13pub mod checkpoint;
14pub mod session_window;
15pub mod stream_join;
16
17pub use backpressure::{BackpressureConsumer, BackpressureProducer, CreditPool, PendingItem};
18pub use checkpoint::{CheckpointId, CheckpointManager, CheckpointState, InMemoryCheckpointStore};
19pub use session_window::{SessionWindow, SessionWindowConfig, SessionWindowProcessor, StreamEvent};
20pub use stream_join::{JoinEvent, JoinMode, JoinedPair, TemporalJoinConfig, TemporalJoiner};