mz_storage::source::postgres::snapshot

Function report_snapshot_size

Source 
async fn report_snapshot_size(
    client: &Client,
    worker_table_info: &BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
    metrics: PgSnapshotMetrics,
    config: &RawSourceCreationConfig,
    export_statistics: &BTreeMap<(u32, usize), SourceStatistics>,
) -> Result<(), Error>
Expand description

Record the sizes of the tables being snapshotted in PgSnapshotMetrics and emit snapshot statistics for each export.