Skip to main content

Module watcher

Module watcher 

Source
Expand description

Minimal watcher-side collection primitives.

Watcher threads may invalidate paths and collect a stable byte snapshot, but never hash, store, or publish artifacts. Those operations belong to plane workers so a burst of watcher events cannot mutate a view directly.

Structs§

FileStamp
The metadata fields that make a read safe to hand to a plane worker.
StableRead
A value whose bytes were bracketed by equal filesystem stamps.
WatcherCollector
The watcher-owned queue of invalidations. It deliberately has no hashing, blob-store, or publication API; plane workers consume its collected paths.

Enums§

StableReadError

Constants§

MAX_STABLE_READ_ATTEMPTS
Includes the first read plus every permitted retry.
MAX_STABLE_READ_RETRIES
A changed stat may trigger this many additional reads after the first read.

Functions§

read_stable
Performs the stable-read algorithm with injectable stat and read operations.
read_stable_file
Reads path only when an identical stat surrounds the read.