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§
Sourcefn handle_event(&self, event: &PipelineEvent) -> Result<()>
fn handle_event(&self, event: &PipelineEvent) -> Result<()>
Handle a processed pipeline event
Sourcefn handle_error(&self, error: &Error, change_event: &ChangeEvent)
fn handle_error(&self, error: &Error, change_event: &ChangeEvent)
Handle pipeline errors