Function mz_storage::source::generator::render_simple_generator

source ยท
fn render_simple_generator<G: Scope<Timestamp = MzOffset>>(
    generator: Box<dyn Generator>,
    tick_micros: Option<u64>,
    as_of: MzOffset,
    up_to: MzOffset,
    scope: &G,
    config: RawSourceCreationConfig,
    committed_uppers: impl Stream<Item = Antichain<MzOffset>> + 'static,
    output_map: BTreeMap<LoadGeneratorOutput, Vec<usize>>,
) -> (StackedCollection<G, (usize, Result<SourceMessage, DataflowError>)>, Option<Stream<G, Infallible>>, Stream<G, HealthStatusMessage>, Stream<G, ProgressStatisticsUpdate>, Vec<PressOnDropButton>)