Skip to main content

oxicode_sdk/coordination/
mod.rs

1//! Inter-agent coordination primitives.
2//!
3//! Provides work distribution, shared state, and consensus:
4//! - **WorkQueue**: priority-based atomic task queue with claim/complete lifecycle
5//! - **SharedMemory**: versioned KV store with optimistic locking
6//! - **Consensus**: simple majority/unanimity voting
7//! - **CoordinatedGroup**: fan-out, vote, and map-reduce over AgentHandles
8
9pub mod consensus;
10pub mod group_ext;
11pub mod shared_memory;
12pub mod work_queue;
13
14pub use consensus::{Consensus, VoteResult};
15pub use group_ext::{CoordinatedGroup, CoordinatedGroupBuilder};
16pub use shared_memory::{MemoryEntry, MemoryEvent, MemoryKey, SharedMemory};
17pub use work_queue::{
18    WorkEvent, WorkItem, WorkQueue, WorkQueueConfig, WorkQueueStats, WorkResult, WorkStatus,
19};