Struct ProcessorPipeline 

pub struct ProcessorPipeline { /* private fields */ }

Processor Pipeline - chains multiple processors

Implementations

impl ProcessorPipeline

pub fn new() -> Self

Create a new empty pipeline

pub fn add(self, processor: Arc<dyn OutputProcessor>) -> Self

Add a processor to the pipeline

pub async fn process( &self, event: StreamEvent, ctx: &ProtectionContext, ) -> Result<ProcessedEvent>

Run all processors in sequence

pub fn is_empty(&self) -> bool

Check if the pipeline is empty

pub fn len(&self) -> usize

Get the number of processors

Trait Implementations

impl Default for ProcessorPipeline

fn default() -> Self

Returns the “default value” for a type.