Struct CoordinatedGroup 

pub struct CoordinatedGroup { /* private fields */ }

A group of agent handles with coordination primitives.

Supports fan-out (parallel work), voting, and map-reduce patterns.

Implementations

impl CoordinatedGroup

pub fn builder() -> CoordinatedGroupBuilder

Create a new builder.

pub fn len(&self) -> usize

Number of agents in the group.

pub fn is_empty(&self) -> bool

Whether the group is empty.

pub async fn fan_out( &self, work_type: &str, payloads: Vec<Value>, ) -> Vec<WorkResult>

Fan-out: distribute payloads across agents via the work queue.

Each agent claims and executes one item in parallel.

pub async fn vote(&self, question: &str, options: &[&str]) -> Option<VoteResult>

Vote: each agent casts a vote on a question.

Uses the consensus module. Returns None if no consensus is configured.

pub async fn map_reduce( &self, work_type: &str, payloads: Vec<Value>, reduce_key: &MemoryKey, ) -> Result<Vec<WorkResult>>

Map-reduce: each agent processes a payload, results stored in shared memory.