fluxus-core 0.2.0

Core components for Fluxus stream processing engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

//! Fluxus Core - A Flink-like stream processing engine in Rust
//!
//! This module contains the core abstractions and data types for stream processing.

pub mod config;
pub mod error_handling;
pub mod metrics;
pub mod pipeline;

// Re-export commonly used items
pub use config::ParallelConfig;
pub use error_handling::{
    BackpressureController, BackpressureStrategy, ErrorHandler, RetryStrategy,
};
pub use metrics::{Counter, Gauge, MetricValue, Metrics, Timer};
pub use pipeline::Pipeline;