Struct BudgetResetScanner 

pub struct BudgetResetScanner { /* private fields */ }

Implementations

impl BudgetResetScanner

pub fn new(interval: Duration) -> Self

pub fn with_filter(interval: Duration, filter: ScannerFilter) -> Self

Accepts a ScannerFilter for uniform construction across all scanners (issue #122) but does not apply it. This scanner iterates budget IDs — not executions — and the namespace / instance_tag filter dimensions do not map onto budget partitions.

Trait Implementations

impl Scanner for BudgetResetScanner

fn name(&self) -> &'static str

Human-readable name for logging.

fn interval(&self) -> Duration

How often to run a full scan across all partitions.

fn filter(&self) -> &ScannerFilter

Per-consumer filter applied by execution-shaped scanners to restrict the set of candidates they act on (issue #122).

async fn scan_partition(&self, client: &Client, partition: u16) -> ScanResult

Scan a single partition. Called once per partition per cycle.

fn sample_backlog_depth( &self, _client: &Client, _partition: u16, ) -> impl Future<Output = Option<u64>> + Send

PR-94: per-cycle gauge sample. Returns Some(depth) summed across all partitions by the scanner runner to produce a single gauge value (today only cancel_reconciler exports one, feeding ff_cancel_backlog_depth). Default: None so scanners that don’t export a gauge compile unchanged.