Struct LwwRegister 

pub struct LwwRegister<T> {
    pub value: T,
    pub stamp: Stamp,
    pub wall_ts: u64,
    pub agent_id: String,
    pub event_hash: String,
}

A Last-Writer-Wins register holding a value of type T.

Each write records the value along with metadata used for deterministic merge: an ITC stamp for causal ordering, a wall-clock timestamp, the writing agent’s ID, and the event hash.

Fields

value: T

The current value of the register.

stamp: Stamp

ITC stamp for causal ordering.

wall_ts: u64

Wall-clock timestamp in microseconds since Unix epoch.

agent_id: String

Agent identifier (e.g., “alice”, “bot-1”).

event_hash: String

BLAKE3 hash of the event that wrote this value.

Implementations

impl<T> LwwRegister<T>

pub const fn new( value: T, stamp: Stamp, wall_ts: u64, agent_id: String, event_hash: String, ) -> Self

Create a new LWW register with the given value and metadata.

impl<T: Clone> LwwRegister<T>

pub fn merge(&mut self, other: &Self)

Merge another register into this one, keeping the “winning” value.

The 4-step tie-breaking chain:

1. ITC causal dominance (non-concurrent: later wins)
2. Wall-clock timestamp (concurrent: higher wins)
3. Agent ID (lexicographic: greater wins)
4. Event hash (lexicographic: greater wins — guaranteed unique)

After merge, self contains the winning value.

pub fn merge_with_trace(&mut self, other: &Self, field: &str) -> MergeTrace

where T: Display,

Merge and optionally emit structured decision trace.

If tracing is disabled via environment toggles, returns a no-op trace payload and preserves the normal low-overhead merge path.

Trait Implementations

impl<T: Clone> Clone for LwwRegister<T>

fn clone(&self) -> LwwRegister<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for LwwRegister<T>

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for LwwRegister<T>

where T: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T: Display> Display for LwwRegister<T>

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

Formats the value using the given formatter.

impl<T: Clone> From<&LwwRegister<T>> for LwwSnapshot<T>

fn from(reg: &LwwRegister<T>) -> Self

Converts to this type from the input type.

impl<T: Clone> From<&LwwSnapshot<T>> for LwwRegister<T>

fn from(snap: &LwwSnapshot<T>) -> Self

Converts to this type from the input type.

impl<T: PartialEq> PartialEq for LwwRegister<T>

fn eq(&self, other: &LwwRegister<T>) -> 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<T> Serialize for LwwRegister<T>

where T: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T: Eq> Eq for LwwRegister<T>

impl<T> StructuralPartialEq for LwwRegister<T>