Stage

Trait Stage 

Source
pub trait Stage {
    // Required methods
    fn execute(&mut self, event: Event) -> Result<Option<Event>, PipelineError>;
    fn name(&self) -> &str;

    // Provided method
    fn is_output(&self) -> bool { ... }
}
Expand description

Stage contract: ownership-based execution. Takes Event, returns Option<Event>, with explicit drop semantics.

Required Methods§

Source

fn execute(&mut self, event: Event) -> Result<Option<Event>, PipelineError>

Source

fn name(&self) -> &str

Provided Methods§

Source

fn is_output(&self) -> bool

Implementors§