Struct Pipeline 

pub struct Pipeline {
    pub name: String,
    /* private fields */
}

Stream processing pipeline

Fields

name: String

Name of the pipeline

Implementations

impl Pipeline

pub fn start(&mut self) -> Result<(), CoreError>

Start the pipeline

pub fn stop(&mut self) -> Result<(), CoreError>

Stop the pipeline

pub fn state(&self) -> StreamState

Get the current state of the pipeline

pub fn stats(&self) -> PipelineStats

Get the statistics for the pipeline

pub fn lasterror(&self) -> Option<ErrorContext>

Get the last error from the pipeline

pub fn is_empty(&self) -> bool

Check if the pipeline is empty

pub fn stage(&self, index: usize) -> Option<&dyn AnyStage>

Get a stage by index

pub fn num_stages(&self) -> usize

Get the number of stages in the pipeline

Trait Implementations

impl Drop for Pipeline

fn drop(&mut self)

Executes the destructor for this type.