Skip to main content

render

mz_storage::source::postgres::snapshot

Function render 

Source 
pub(crate) fn render<'scope>(
    scope: Scope<'scope, MzOffset>,
    config: RawSourceCreationConfig,
    connection: PostgresSourceConnection,
    table_info: BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
    metrics: PgSnapshotMetrics,
) -> (StackedCollection<'scope, MzOffset, (usize, Result<SourceMessage, DataflowError>)>, StreamVec<'scope, MzOffset, RewindRequest>, StreamVec<'scope, MzOffset, Infallible>, StreamVec<'scope, MzOffset, ReplicationError>, PressOnDropButton)
Expand description

Renders the snapshot dataflow. See the module documentation for more information.