oxigeo-streaming 0.2.2

Real-time data processing and streaming pipelines for OxiGeo
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! Streaming v2: production-quality additions to the OxiGeo streaming framework.
//!
//! # Modules
//!
//! | Module | Purpose |
//! |---|---|
//! | [`backpressure`] | Credit-based flow control (producer/consumer credit pools) |
//! | [`session_window`] | Gap-detection session windows with configurable min-events and max-duration |
//! | [`stream_join`] | Temporal stream-to-stream joins (inner / left-outer / interval) |
//! | [`checkpoint`] | Serialisable checkpoint state with in-memory store and manager |

pub mod backpressure;
pub mod checkpoint;
pub mod session_window;
pub mod stream_join;

pub use backpressure::{BackpressureConsumer, BackpressureProducer, CreditPool, PendingItem};
pub use checkpoint::{
    CheckpointId, CheckpointManager, CheckpointState, CheckpointStore, FileCheckpointStore,
    InMemoryCheckpointStore,
};
pub use session_window::{SessionWindow, SessionWindowConfig, SessionWindowProcessor, StreamEvent};
pub use stream_join::{JoinEvent, JoinMode, JoinedPair, TemporalJoinConfig, TemporalJoiner};