Struct VectorClock 

pub struct VectorClock {
    pub entries: BTreeMap<String, String>,
}

Phase 3 foundation (issue #224): vector clock tracking the latest updated_at this peer has seen from each known remote peer.

Entries are populated lazily — both on HTTP /sync/push (receiver records the sender’s latest updated_at) and on HTTP /sync/since (sender advances last_pulled_at). Full CRDT-lite merge rules using the clock are not in the v0.6.0 GA foundation; they land in a follow-up PR under issue #224 Task 3a.1. The foundation ships the wire format so adding the merge semantics later does not force a schema migration.

Fields

entries: BTreeMap<String, String>

Map of peer agent_id -> latest RFC3339 updated_at seen from that peer. A peer absent from the map is equivalent to “never-seen-anything.” Encoded as a JSON object on the wire.

Implementations

impl VectorClock

pub fn observe(&mut self, peer_id: &str, at: &str)

Advance this clock to include peer_id’s latest seen timestamp. Monotonic — an older timestamp never overwrites a newer one.

pub fn latest_from(&self, peer_id: &str) -> Option<&str>

Look up the latest timestamp this clock has from peer_id.

Trait Implementations

impl Clone for VectorClock

fn clone(&self) -> VectorClock

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for VectorClock

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

Formats the value using the given formatter.

impl Default for VectorClock

fn default() -> VectorClock

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for VectorClock

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for VectorClock

impl PartialEq for VectorClock

fn eq(&self, other: &VectorClock) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for VectorClock

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for VectorClock