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§
Provided Methods§
Sourcefn stage_type(&self) -> String
fn stage_type(&self) -> String
Get stage type
Sourcefn can_handle(&self, _inputtype: &str) -> bool
fn can_handle(&self, _inputtype: &str) -> bool
Check if stage can handle the input type