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

/// Status of a pipeline execution
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum PipelineStatus {
    /// Pipeline is initialized but not running
    Ready,
    /// Pipeline is currently running
    Running,
    /// Pipeline has completed successfully
    Completed,
    /// Pipeline has failed
    Failed,
}