Function mz_storage::source::postgres::snapshot::render

source ยท 
pub(crate) fn render<G: Scope<Timestamp = MzOffset>>(
    scope: G,
    config: RawSourceCreationConfig,
    connection: PostgresSourceConnection,
    table_info: BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
    metrics: PgSnapshotMetrics,
) -> (StackedCollection<G, (usize, Result<SourceMessage, DataflowError>)>, Stream<G, RewindRequest>, Stream<G, Infallible>, Stream<G, ProgressStatisticsUpdate>, Stream<G, ReplicationError>, PressOnDropButton)
Expand description

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