async fn snapshot_binary_inner(
read_handle: &mut ReadHandle<SourceData, (), Timestamp, Diff>,
as_of: Timestamp,
) -> impl Iterator<Item = StateUpdate<StateUpdateKindJson>> + DoubleEndedIterator
Expand description
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.