Starts a throttled, per-shard checkpoint writer for mutations to a
current cache. Each touched shard is written at least delayMs after
its first pending mutation and no more often than once per floorMs;
a burst of mutations to one feed coalesces into one write, and a quiet
feed's shard is never rewritten at all.
Parameters
identity: string
Canonical ChRIS identity string.
root: string = ...
Checkpoint directory override.
delayMs: number = 1000
Debounce interval in milliseconds.
floorMs: number = PROC_CHECKPOINT_FLOOR_MS
Minimum spacing between two writes of the same shard.
Returns ()=>void
Function that stops watching and cancels pending saves.
Starts a throttled, per-shard checkpoint writer for mutations to a current cache. Each touched shard is written at least
delayMsafter its first pending mutation and no more often than once perfloorMs; a burst of mutations to one feed coalesces into one write, and a quiet feed's shard is never rewritten at all.