Struct AgentState 

pub struct AgentState {
    pub session_id: SessionId,
    pub vector_clock: VectorClock,
    pub counters: HashMap<String, GCounter>,
    pub sets: HashMap<String, GSet>,
    pub registers: HashMap<String, LWWRegister<String>>,
    pub maps: HashMap<String, ORMap>,
}

The full CRDT-backed shared state for a sync session.

Each field is a named map of CRDTs, allowing arbitrary named slots without requiring schema changes.

Fields

session_id: SessionId

Unique session identifier.

vector_clock: VectorClock

Vector clock tracking causal history across agents.

counters: HashMap<String, GCounter>

Named grow-only counters.

sets: HashMap<String, GSet>

Named grow-only sets.

registers: HashMap<String, LWWRegister<String>>

Named last-write-wins string registers.

maps: HashMap<String, ORMap>

Named observed-remove maps.

Implementations

impl AgentState

pub fn new() -> Self

Create a new AgentState with a fresh random session id.

pub fn with_session(self, id: SessionId) -> Self

Override the session id (builder pattern).

pub fn merge(&self, other: &AgentState) -> AgentState

Merge another agent’s state into this one.

All merges are CRDT-compliant: commutative, associative, idempotent.

Returns

A new AgentState representing the merged view.

pub fn to_json(&self) -> Result<String, SyncError>

Serialize this state to JSON.

Returns

• Ok(String) — JSON representation.
• Err(SyncError::Serialization) — on failure.

pub fn from_json(s: &str) -> Result<Self, SyncError>

Deserialize state from JSON.

Returns

• Ok(AgentState) on success.
• Err(SyncError::Serialization) on parse failure.

Trait Implementations

impl Clone for AgentState

fn clone(&self) -> AgentState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AgentState

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

Formats the value using the given formatter.

impl Default for AgentState

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for AgentState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AgentState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.