Struct PendingWaitpointExpiryScanner 

pub struct PendingWaitpointExpiryScanner { /* private fields */ }

Implementations

impl PendingWaitpointExpiryScanner

pub fn new(interval: Duration) -> Self

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

Construct with a ScannerFilter applied per candidate (issue #122). The filter is resolved to the waitpoint’s owning execution via the waitpoint hash’s execution_id field, then applied via should_skip_candidate.

Trait Implementations

impl Scanner for PendingWaitpointExpiryScanner

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.