Module drain 

Draining sealed stash chunks against the persist feedback, one function per stash flavor.

Structs

DrainStats 🔒

Counts from a single call to drain_sealed_input_chunked or drain_sealed_input_paged, used to update metrics.

Enums

TimeClass 🔒

Where a stashed entry’s time falls relative to the feedback frontier.

Functions

classify_time 🔒

Classify ts against persist_upper: the single spelling of the drain’s eligibility test. The chunked drain’s probe-collection pass and its classification pass, and the paged drain’s cursor walk, all call this, so the probe set and the classification cannot disagree. Under the operator’s total order, Eligible means ts equals the frontier’s one element.

drain_sealed_input_chunked 🔒

Process sealed chunks from the batcher, classifying each entry by its timestamp relative to persist_upper:

drain_sealed_input_paged 🔒

drain_sealed_input_chunked’s counterpart for the paged flavor, classifying entries the same way but reading prior state through a trace cursor.