Trait SideOutputPlugin 

pub trait SideOutputPlugin: Send + Sync {
    // Required methods
    fn process_batch(&self, batch: &RecordBatch) -> Result<(), String>;
    fn shutdown(&self);
}

Trait for plugins to implement side output support. Side outputs observe data from all sources without modifying the pipeline. Unlike other plugin types, side outputs use direct FFI invocation (no channels). One instance is created per source via new(source_name, schema, options, metrics_recorder).

Required Methods

fn process_batch(&self, batch: &RecordBatch) -> Result<(), String>

fn shutdown(&self)

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors