Struct Pipeline 

pub struct Pipeline { /* private fields */ }

Pipeline: linear, deterministic execution of stages. No distributed coordination, constant memory streaming.

Implementations

impl Pipeline

pub fn new() -> Self

pub fn add_stage(&mut self, stage: Box<dyn Stage>)

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

pub fn export_prometheus(&self) -> String

pub fn export_json_logs(&self) -> Vec<String>

Trait Implementations

impl Default for Pipeline

fn default() -> Self

Returns the “default value” for a type.