Skip to main content

Module coordination

Module coordination 

Source
Expand description

Coordination primitives — multi-agent work distribution and consensus.

Re-exports oxi-sdk 0.23.0’s coordination primitives for use by the orchestrator and other kernel components.

§Available Primitives

  • WorkQueue: Priority-based atomic task queue with claim/complete lifecycle. Use for distributing independent subtasks across agents.
  • SharedMemory: Versioned KV store with optimistic locking. Use for sharing state between agents in a group.
  • Consensus: Simple majority/unanimity voting. Use for evaluation, approval, and decision-making.
  • CoordinatedGroup: Fan-out, vote, and map-reduce over AgentHandles. Use for structured multi-agent workflows.

§Usage

use oxi_sdk::coordination::{WorkQueue, WorkQueueConfig};

let queue = WorkQueue::new(WorkQueueConfig::default());
// queue.submit(WorkItem { id: "task-1".into(), .. });
// let item = queue.claim("agent-1");
// queue.complete("task-1", WorkResult { output: "...".into(), success: true });