Struct ErrorHandlingStage 

pub struct ErrorHandlingStage { /* private fields */ }

Error handling stage - catches and handles errors

Implementations

impl ErrorHandlingStage

pub fn new(name: &str, handler: Box<dyn ErrorHandler>) -> Self

Trait Implementations

impl PipelineStage for ErrorHandlingStage

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

Execute the stage

fn name(&self) -> String

Get stage name

fn stage_type(&self) -> String

Get stage type

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

Check if stage can handle the input type