Function mz_catalog::durable::persist::snapshot_binary

async fn snapshot_binary(
    read_handle: &mut ReadHandle<SourceData, (), Timestamp, Diff>,
    as_of: Timestamp,
    metrics: &Arc<Metrics>,
) -> impl Iterator<Item = StateUpdate<StateUpdateKindJson>> + DoubleEndedIterator

Generates an iterator of StateUpdate that contain all updates to the catalog state up to, and including, as_of.

The output is consolidated and sorted by timestamp in ascending order.