Expand description
Fluxus Core - A Flink-like stream processing engine in Rust
This module contains the core abstractions and data types for stream processing.
Re-exports§
pub use config::ParallelConfig;pub use error_handling::BackpressureController;pub use error_handling::BackpressureStrategy;pub use error_handling::ErrorHandler;pub use error_handling::RetryStrategy;pub use metrics::Counter;pub use metrics::Gauge;pub use metrics::MetricValue;pub use metrics::Metrics;pub use metrics::Timer;pub use pipeline::Pipeline;