Struct BudgetTracker 

pub struct BudgetTracker { /* private fields */ }

In-memory per-task budget tracker.

Reconstructed from WAL events at bootstrap via BudgetTracker::allocate and BudgetTracker::consume calls. The dispatch loop updates the tracker each tick as WorkerResults arrive.

Implementations

impl BudgetTracker

pub fn new() -> Self

Creates an empty tracker.

pub fn allocate( &mut self, task_id: TaskId, dimension: BudgetDimension, limit: u64, )

Registers a budget allocation for a task/dimension pair.

If an allocation already exists for this pair, it is replaced (re-allocation).

pub fn consume( &mut self, task_id: TaskId, dimension: BudgetDimension, amount: u64, ) -> ConsumeResult

Records consumption and returns whether the budget was exhausted by this call.

No-ops if no allocation exists for the (task, dimension) pair.

pub fn replenish( &mut self, task_id: TaskId, dimension: BudgetDimension, new_limit: u64, )

Replenishes a budget: sets new limit and clears the exhausted flag.

pub fn is_exhausted(&self, task_id: TaskId, dimension: BudgetDimension) -> bool

Returns true if the given dimension budget is exhausted for this task.

pub fn is_any_exhausted(&self, task_id: TaskId) -> bool

Returns true if ANY dimension budget is exhausted for this task.

pub fn remaining( &self, task_id: TaskId, dimension: BudgetDimension, ) -> Option<u64>

Returns the remaining budget for a (task, dimension) pair.

Returns None if no allocation exists.

pub fn threshold_pct( &self, task_id: TaskId, dimension: BudgetDimension, ) -> Option<u8>

Returns consumed amount as a percentage of the limit (0-100).

Returns None if no allocation exists.

pub fn get( &self, task_id: TaskId, dimension: BudgetDimension, ) -> Option<&BudgetState>

Returns the state for a (task, dimension) pair.

pub fn gc_task(&mut self, task_id: TaskId)

Removes all budget state for a fully-terminal task.

Called by the dispatch loop after a task reaches terminal state. Safe to call because terminal tasks no longer dispatch runs that would consume budget or check exhaustion.

Trait Implementations

impl Debug for BudgetTracker

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

Formats the value using the given formatter.

impl Default for BudgetTracker

fn default() -> BudgetTracker

Returns the “default value” for a type.