Struct TimestampNormalizer 

pub struct TimestampNormalizer {}

Implementations

impl TimestampNormalizer

pub fn new() -> Self

Trait Implementations

impl Analyzer for TimestampNormalizer

fn process<'life0, 'async_trait>( &'life0 mut self, stream: Pin<Box<dyn Stream<Item = Event> + Send>>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Event> + Send>>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process an event stream and return a processed stream

impl Debug for TimestampNormalizer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TimestampNormalizer

fn default() -> Self

Returns the “default value” for a type.