Function render 

pub(crate) fn render<G: Scope<Timestamp = MzOffset>>(
    scope: G,
    config: RawSourceCreationConfig,
    connection: PostgresSourceConnection,
    table_info: BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
    rewind_stream: StreamVec<G, RewindRequest>,
    slot_ready_stream: StreamVec<G, Infallible>,
    committed_uppers: impl Stream<Item = Antichain<MzOffset>> + 'static,
    metrics: PgSourceMetrics,
) -> (StackedCollection<G, (usize, Result<SourceMessage, DataflowError>)>, StreamVec<G, Probe<MzOffset>>, StreamVec<G, ReplicationError>, PressOnDropButton)

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