Struct IndexReconciler 

pub struct IndexReconciler { /* private fields */ }

Implementations

impl IndexReconciler

pub fn new(interval: Duration, lanes: Vec<LaneId>) -> Self

pub fn with_filter( interval: Duration, lanes: Vec<LaneId>, filter: ScannerFilter, ) -> Self

Construct with a ScannerFilter applied per candidate (issue #122).

Trait Implementations

impl Scanner for IndexReconciler

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.