PipelineStage

Trait PipelineStage 

Source
pub trait PipelineStage: Send + Sync {
    // Required methods
    fn execute(
        &self,
        input: PipelineData<Box<dyn Any + Send + Sync>>,
    ) -> Result<PipelineData<Box<dyn Any + Send + Sync>>>;
    fn name(&self) -> String;

    // Provided methods
    fn stage_type(&self) -> String { ... }
    fn can_handle(&self, _inputtype: &str) -> bool { ... }
}
Expand description

Trait for pipeline stages

Required Methods§

Source

fn execute( &self, input: PipelineData<Box<dyn Any + Send + Sync>>, ) -> Result<PipelineData<Box<dyn Any + Send + Sync>>>

Execute the stage

Source

fn name(&self) -> String

Get stage name

Provided Methods§

Source

fn stage_type(&self) -> String

Get stage type

Source

fn can_handle(&self, _inputtype: &str) -> bool

Check if stage can handle the input type

Implementors§