Trait mz_storage_client::types::sources::Generator

pub trait Generator {
    // Required method
    fn by_seed(
        &self,
        now: NowFn,
        seed: Option<u64>,
        resume_offset: MzOffset
    ) -> Box<dyn Iterator<Item = (usize, Event<Option<MzOffset>, (Row, i64)>)>>;
}

Required Methods

fn by_seed( &self, now: NowFn, seed: Option<u64>, resume_offset: MzOffset ) -> Box<dyn Iterator<Item = (usize, Event<Option<MzOffset>, (Row, i64)>)>>

Returns a function that produces rows and batch information.

Implementors