Skip to main content

oxigdal_streaming/core/
mod.rs

1//! Core streaming abstractions and traits.
2
3mod backpressure;
4mod flow_control;
5mod operators;
6mod recovery;
7pub mod stream;
8
9pub use backpressure::{
10    BackpressureConfig, BackpressureManager, BackpressureStrategy, LoadMetrics,
11};
12pub use flow_control::{FlowControlConfig, FlowControlMetrics, FlowController};
13pub use operators::{
14    FilterOperator, FlatMapOperator, LoggingSink, MapOperator, SinkOperator, SourceOperator,
15    StreamOperator, TransformOperator,
16};
17pub use recovery::{FailureRecord, RecoveryConfig, RecoveryManager, RecoveryStrategy};
18pub use stream::{
19    Stream, StreamConfig, StreamElement, StreamMessage, StreamMetadata, StreamSink, StreamSource,
20};