Struct FlowProjector 

pub struct FlowProjector { /* private fields */ }

Implementations

impl FlowProjector

pub fn new(interval: Duration, partition_config: PartitionConfig) -> Self

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

Accepts a ScannerFilter for uniform construction across all scanners (issue #122) but does not apply it. This scanner projects flow summaries by aggregating the public states of many member executions per flow; per-member filtering would add an HGET per member per flow (N×M), which does not fit the “no extra HGET to filter” budget set in the issue #122 design. The flow summary remains a cross-tenant aggregate in shared-Valkey deployments — consumers that need per-instance summaries should read exec_core directly with the filter applied.

Trait Implementations

impl Scanner for FlowProjector

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.