Proposition
The reference DriftSweepCapable: a working sweep over any PropositionStore, and the executable statement of what the contract means.
It is correct for every backend, so a host can sweep on day one, and a durable store can be held to the same suite of tests once it implements DriftSweepCapable natively. It is honest about the cost: a plain PropositionStore can filter by context and nothing else, so this class reads one context's propositions and applies the mention-type filter, the ordering and the page bound in the JVM. The context bound is real — the read never leaves the context, so no other tenant's data is ever materialised — and the rest is the part a backend should push down.
Because it does its own paging over a store read, a context whose propositions change underneath a long sweep can shift between pages. That is inherent to paging a live store, and it is safe here: a proposition the sweep misses is caught by the next check, and one it sees twice comes back as already quarantined.
Parameters
Where candidates are read from and quarantined copies are saved back to. The base persistence port: a sweep reads by context and saves, so requiring vector search, graph traversal and temporal query alongside would shut a plain store-and-retrieve backend out of drift work over capabilities it never uses.
Told about each real status transition as a PropositionStatusChanged, so a consumer like ProjectionLineageStaleCascade hears about a quarantine, and about a release, without depending on whichever concrete propositions store happens to be wired in. Defaults to a no-op: everything else here holds with nobody listening.
Constructors
Functions
Persist one quarantine decision.
The same read from the beginning.
Reads the one context through PropositionStore.findByContextId, then filters, sorts and pages in the JVM.
Restores the status recorded under DriftQuarantineKeys.PREVIOUS_STATUS and drops both quarantine keys in one save.