Skip to main content

render

mz_storage::source::sql_server::progress

Function render 

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