fluxus_core/
lib.rs

1//! Fluxus Core - A Flink-like stream processing engine in Rust
2//!
3//! This module contains the core abstractions and data types for stream processing.
4
5pub mod config;
6pub mod error_handling;
7pub mod metrics;
8pub mod pipeline;
9
10// Re-export commonly used items
11pub use config::ParallelConfig;
12pub use error_handling::{
13    BackpressureController, BackpressureStrategy, ErrorHandler, RetryStrategy,
14};
15pub use metrics::{Counter, Gauge, MetricValue, Metrics, Timer};
16pub use pipeline::Pipeline;