Crate llm_sync 

llm-sync

CRDT and vector clock primitives for distributed LLM agent state synchronization. Every merge operation is commutative, associative, and idempotent.

Example

use llm_sync::{AgentState, GCounter};

let mut s1 = AgentState::new();
let mut g = GCounter::new();
g.increment("agent-1", 10);
s1.counters.insert("requests".into(), g);

let s2 = AgentState::new();
let merged = s1.merge(&s2);
assert_eq!(merged.counters["requests"].value(), 10);

Re-exports

pub use error::SyncError;

pub use vclock::VectorClock;

pub use crdt::GCounter;

pub use crdt::GSet;

pub use crdt::LWWRegister;

pub use crdt::ORMap;

pub use crdt::PNCounter;

pub use session::AgentState;

pub use session::SessionId;

Modules

crdt

CRDT implementations: GCounter, PNCounter, GSet, LWWRegister, ORMap.

error

session

Sync session management for agent-to-agent state exchange.

vclock

Vector clock for causal ordering in distributed agent systems.