Struct SyncEvent 

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

One line in a sync JSONL batch. Carries the full event so the remote projector can replay it. payload is the redacted payload (same redaction the projector applies at ingest).

Fields

event_id: String

run_id: String

ts: OffsetDateTime

kind: String

schema_version: u32

payload: Value

origin: Option<String>

v3.0 #3: who/where wrote this event (<machine_id>/<agent>). Carried so a replicated/team brain can attribute each event. #[serde(default)] keeps pre-v8 sync batches (no origin) importable.

hlc: Option<String>

v3.0 #3 Slice B: the event’s HLC (canonical string) for convergent total-order replay. #[serde(default)] keeps pre-v9 batches importable (the importer synthesizes a local HLC for those).

Trait Implementations

impl Clone for SyncEvent

fn clone(&self) -> SyncEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SyncEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&Event> for SyncEvent

fn from(e: &Event) -> Self

Converts to this type from the input type.

impl Serialize for SyncEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<SyncEvent> for Event

type Error = Box<dyn Error + Send + Sync>

The type returned in the event of a conversion error.

fn try_from(s: SyncEvent) -> Result<Self, Self::Error>

Performs the conversion.