Skip to main content

Module checkpoint

Module checkpoint 

Source
Expand description

Checkpoints (spec/sync/README.md §4.1): one checkpoints row per batch observed through the filesystem fast path or the adapter driver, then the pool sweep — the row and the sweep in one transaction, so a batch never leaves a checkpoint whose sweep did not run (or the reverse). Each member’s commit is still its own transaction (spec/store §5.4).

Structs§

CheckpointResult
What a checkpoint produced, in batch order.

Functions§

files_json
The files column of a checkpoint: [[path, old_hash | null, new_hash | null], …] in batch order.
finish_checkpoint
§4.1: bucket the outcomes, mint cp, insert the row and sweep the pool at ts (spec/store §5.5) in one transaction: a failing sweep rolls the row back.
process_checkpoint
§4.1 process_checkpoint: read each path under root (None when absent), observe_batch, record the checkpoint.