Struct StreamProcessor 

pub struct StreamProcessor { /* private fields */ }

Processes events in a stream.

Implementations

impl StreamProcessor

pub fn new() -> Self

Create a new stream processor.

pub fn add_step(self, step: impl ProcessingStep + Send + Sync + 'static) -> Self

Add a processing step.

pub fn filter(self, filter: EventFilter) -> Self

Add a filter step.

pub fn map( self, mapper: impl Fn(Event) -> Event + Send + Sync + 'static, ) -> Self

Add a map step.

pub fn transform_data( self, transformer: impl Fn(EventData) -> EventData + Send + Sync + 'static, ) -> Self

Add a transform step on event data.

pub fn process(&self, event: Event) -> Option<Event>

Process an event through the pipeline.

pub fn process_batch(&self, events: Vec<Event>) -> Vec<Event>

Process a batch of events.

Trait Implementations

impl Default for StreamProcessor

fn default() -> Self

Returns the “default value” for a type.