Struct PickHistory 

pub(crate) struct PickHistory {
    waiting: HashMap<PickKey, Instant>,
    selected_metrics: IntCounterVec,
}

Region-resident scheduling metadata. It owns no file handles or reservations. Planning works on a private snapshot; the accepted plan consumes one fairness turn per selected key. Execution success or failure does not rewrite ages.

Fields

waiting: HashMap<PickKey, Instant>

First observation or last fairness turn for each eligible key. Repeated picks preserve this timestamp until the key is selected.

selected_metrics: IntCounterVec

Implementations

impl PickHistory

fn observe(&mut self, keys: impl Iterator<Item = PickKey>, now: Instant)

Refreshes all eligible identities before selection limits hide any work. Preserves surviving ages and drops absent keys without changing selection.

fn priority(&self, key: PickKey, now: Instant) -> PickPriority

Returns an ascending sort key: promoted work first, oldest waiting first. Below PROMOTION_DELAY, age does not affect class/newest-window ordering. One shared now keeps the comparator consistent across the entire sort.

fn serve(&mut self, key: PickKey, now: Instant)

Consumes the fairness turn for key. Only an accepted plan installs the private snapshot, so rejected or stale plans never advance resident ages.

pub(crate) fn rank_candidates( &mut self, candidates: Vec<WindowCandidate>, now: Instant, ) -> Vec<WindowCandidate>

Observes all eligible work and ranks one alternative per window without consuming a fairness turn. The caller acknowledges only attempted work after applying its output budget and semantic closure policy.

pub(crate) fn acknowledge( &mut self, keys: impl Iterator<Item = PickKey>, now: Instant, )

Consumes turns for attempted seeds, including absorbed or rejected closure seeds, but not work left behind by the output budget. Only an accepted plan installs this private snapshot; execution never updates waiting ages.

Trait Implementations

impl Clone for PickHistory

fn clone(&self) -> PickHistory

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PickHistory

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PickHistory

fn default() -> Self

Returns the “default value” for a type.