Struct TimeSplitter 

pub struct TimeSplitter<E, F> { /* private fields */ }

Splits a stream by time.

Implementations

impl<E, F> TimeSplitter<E, F>

where F: Fn(Date, Option<Metadata>) -> Result<E>,

pub fn new(build_encoder: F, split_duration: SplitDuration) -> Self

Creates a new splitter that will split the input stream according to split_duration, creating a separate sub-encoder for each split using build_encoder.

Trait Implementations

impl<E: Debug, F: Debug> Debug for TimeSplitter<E, F>

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

Formats the value using the given formatter.

impl<E, F> Splitter<E> for TimeSplitter<E, F>

where F: Fn(Date, Option<Metadata>) -> Result<E>,

fn sub_encoder<R>( &mut self, metadata: Option<&Metadata>, record: &R, ) -> Result<Option<&mut E>>

where R: Record,

Returns the encoder for the given record, or None if the record should be ignored.

fn sub_encoders<'a>(&'a mut self) -> impl Iterator<Item = &'a mut E>

where E: 'a,

Returns an iterator over all active sub-encoders.