Struct Event 

pub struct Event {
    pub event_id: EventId,
    pub run_id: RunId,
    pub ts: OffsetDateTime,
    pub parent_event_id: Option<EventId>,
    pub kind: String,
    pub schema_version: u32,
    pub payload: Value,
    pub origin: Option<String>,
    pub hlc: Option<String>,
}

Fields

event_id: EventId

run_id: RunId

ts: OffsetDateTime

parent_event_id: Option<EventId>

kind: String

schema_version: u32

payload: Value

origin: Option<String>

Who/where wrote this event: <machine_id>/<agent>, or None for events created before origin tracking (schema < v8) or when unconfigured. Auto-stamped from process_origin by Event::new; preserved verbatim across rebuild and sync replication.

hlc: Option<String>

v2.6 #3 Slice B: Hybrid Logical Clock timestamp (canonical string) giving a globally-deterministic, causal total order for convergent team sync. None for events created before HLC tracking (schema < v9); the v9 migration backfills those from (ts, rowid). Auto-stamped by Event::new; preserved verbatim across rebuild and replication.

Implementations

impl Event

pub fn new(run_id: RunId, kind: impl Into<String>, payload: Value) -> Self

pub fn with_parent(self, parent_event_id: EventId) -> Self

pub fn with_origin(self, origin: Option<String>) -> Self

Override the origin (used by the sync import path to preserve a remote event’s origin instead of stamping the local process origin).

pub fn with_hlc(self, hlc: Option<String>) -> Self

Override the HLC (used by the sync import path to preserve a remote event’s HLC instead of stamping the local clock).

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Event

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Event

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Event

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

where __S: Serializer,

Serialize this value into the given Serde serializer.