Trait PipelineEventHandler

Source
pub trait PipelineEventHandler: Send + Sync {
    // Required methods
    fn handle_event(&self, event: &PipelineEvent) -> Result<()>;
    fn handle_error(&self, error: &Error, change_event: &ChangeEvent);
}
Expand description

Event handler trait for processing pipeline events

Required Methods§

Source

fn handle_event(&self, event: &PipelineEvent) -> Result<()>

Handle a processed pipeline event

Source

fn handle_error(&self, error: &Error, change_event: &ChangeEvent)

Handle pipeline errors

Implementors§