mz_storage::source::sql_server::progress

Function render

Source 
pub(crate) fn render<G: Scope<Timestamp = Lsn>>(
    scope: G,
    config: RawSourceCreationConfig,
    connection: SqlServerConnectionDetails,
    outputs: BTreeMap<GlobalId, SourceOutputInfo>,
    committed_uppers: impl Stream<Item = Antichain<Lsn>> + 'static,
    extras: SqlServerSourceExtras,
) -> (Stream<G, ProgressStatisticsUpdate>, Stream<G, ReplicationError>, Stream<G, Probe<Lsn>>, PressOnDropButton)