oxigdal-streaming 0.1.4

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

//! Core streaming abstractions and traits.

mod backpressure;
mod flow_control;
mod operators;
mod recovery;
pub mod stream;

pub use backpressure::{
    BackpressureConfig, BackpressureManager, BackpressureStrategy, LoadMetrics,
};
pub use flow_control::{FlowControlConfig, FlowControlMetrics, FlowController};
pub use operators::{
    FilterOperator, FlatMapOperator, LoggingSink, MapOperator, SinkOperator, SourceOperator,
    StreamOperator, TransformOperator,
};
pub use recovery::{FailureRecord, RecoveryConfig, RecoveryManager, RecoveryStrategy};
pub use stream::{
    Stream, StreamConfig, StreamElement, StreamMessage, StreamMetadata, StreamSink, StreamSource,
};