Struct RuleBasedEventMapper 

pub struct RuleBasedEventMapper { /* private fields */ }

Implementations

impl RuleBasedEventMapper

pub fn new( rules: &[EventMapRule], ) -> Result<RuleBasedEventMapper, PipelineError>

Trait Implementations

impl Mapper for RuleBasedEventMapper

fn map<'life0, 'async_trait>( &'life0 self, input: Pin<Box<dyn Stream<Item = Result<Value, Error>> + Send>>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<StreamingEvent, Error>> + Send>>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, RuleBasedEventMapper: 'async_trait,

A mapper takes a stream of JSON values and returns a stream of unified events