Module v2 

Streaming v2: production-quality additions to the OxiGDAL 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

Re-exports

pub use backpressure::BackpressureConsumer;

pub use backpressure::BackpressureProducer;

pub use backpressure::CreditPool;

pub use backpressure::PendingItem;

pub use checkpoint::CheckpointId;

pub use checkpoint::CheckpointManager;

pub use checkpoint::CheckpointState;

pub use checkpoint::InMemoryCheckpointStore;

pub use session_window::SessionWindow;

pub use session_window::SessionWindowConfig;

pub use session_window::SessionWindowProcessor;

pub use session_window::StreamEvent;

pub use stream_join::JoinEvent;

pub use stream_join::JoinMode;

pub use stream_join::JoinedPair;

pub use stream_join::TemporalJoinConfig;

pub use stream_join::TemporalJoiner;

Modules

backpressure

Credit-based flow control for geospatial stream processing.

checkpoint

Checkpoint-based stream recovery for fault tolerance.

session_window

Session window processing for geospatial event streams.

stream_join

Stream-to-stream temporal joins for geospatial data.