Skip to main content

render

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,
) -> (StreamVec<G, ReplicationError>, StreamVec<G, Probe<Lsn>>, PressOnDropButton)