Skip to main content

apply_changeset

Function apply_changeset 

Source
pub fn apply_changeset(
    db: &Db,
    space: &Space,
    cs: &Changeset,
    blob_source: Option<&Path>,
) -> Result<(ApplySummary, Vec<PeerCursor>)>
Expand description

Apply one changeset: rows (per the registry), tombstones, file blobs, and the embedded ack. Returns the summary plus the reply cursors — the receiver’s new pull cursors per table, to be acked back to the sender. blob_source, when given, is a directory whose legacy blobs/<space_id>/<name> or content-addressed blobs/by-hash/<hash> path holds the sender’s payloads; missing blobs are reported instead.