Struct JournalEvent 

pub struct JournalEvent {
    pub schema_version: u32,
    pub seq: u64,
    pub ts: u64,
    pub idempotency_key: String,
    pub kind: EventKind,
}

One line of journal.jsonl: a schema-versioned, sequenced, timestamped envelope around an EventKind.

The kind payload is #[serde(flatten)]ed so the on-disk line is a single flat JSON object ({"schema_version":1,"seq":3,"ts":…,"idempotency_key":…, "kind":"target_published","target":"cargo","receipt":{…}}), keeping it jq/tail-friendly (AGENTS-AI-FIRST-CLI §2).

Fields

schema_version: u32

The durable schema version of this event (see JOURNAL_SCHEMA_VERSION).

seq: u64

Monotonic sequence number within the run, starting at 1. The reducer’s high-water mark: an event at or below the applied seq is a no-op on replay (append-then-apply crash recovery, ADR-0003 §2).

ts: u64

Event time as whole seconds since the Unix epoch, from the injected Clock (never wall-clock directly, so runs are deterministic under test).

idempotency_key: String

Stable semantic key identifying what subject this event records (e.g. published:cargo, phase_completed:build). It is metadata, not the append gate: it deliberately ignores the payload (a phase’s outcome, a receipt’s version), so it is safe for diagnostics and for a coordinator’s own “have I already acted on this subject?” lookups, but it must not be used to suppress an append — a phase that completed Failed and then, after a resume, completes Ok shares this key yet is a distinct fact that must be recorded. Replay idempotency is provided by Self::seq (the high-water mark), not by this key.

kind: EventKind

The event payload, flattened into this envelope.

Trait Implementations

impl Clone for JournalEvent

fn clone(&self) -> JournalEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JournalEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for JournalEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for JournalEvent

impl PartialEq for JournalEvent

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for JournalEvent

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 JournalEvent