Struct DistributedMatchCoordinator 

pub struct DistributedMatchCoordinator {
    pub completed: Vec<HashMap<String, String>>,
    pub pending: HashMap<u16, Vec<PatternContinuation>>,
    pub round: u32,
    pub max_rounds: u32,
}

Coordinator state for distributed MATCH execution.

Tracks pending continuations and completed results across rounds of scatter-gather until all continuations are resolved.

Fields

completed: Vec<HashMap<String, String>>

Completed result rows from all shards.

pending: HashMap<u16, Vec<PatternContinuation>>

Pending continuations grouped by target shard.

round: u32

Round counter (for debugging / max-round termination).

max_rounds: u32

Maximum rounds before forced termination (prevent infinite loops).

Implementations

impl DistributedMatchCoordinator

pub fn new(max_rounds: u32) -> Self

pub fn add_shard_result(&mut self, result: ShardMatchResult)

Ingest results from a shard.

pub fn has_pending(&self) -> bool

Check if there are pending continuations to dispatch.

pub fn take_pending(&mut self, shard_id: u16) -> Vec<PatternContinuation>

Take all pending continuations for a target shard.

pub fn take_all_pending(&mut self) -> HashMap<u16, Vec<PatternContinuation>>

Take all pending continuations, grouped by target shard.

pub fn advance(&mut self) -> bool

Advance to next round. Returns false if max rounds reached.

pub fn result_count(&self) -> usize

Total completed rows.

Trait Implementations

impl Debug for DistributedMatchCoordinator

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

Formats the value using the given formatter.