Enum Event 

pub enum Event {
    Decision {
        actor_id: Option<String>,
        workspace: String,
        op_type: Option<String>,
        accepted: bool,
        reject_reason: Option<String>,
        seq: Option<u64>,
        parent: Option<String>,
        decision_latency_us: u64,
    },
    QueueDepth {
        depth: usize,
    },
    WindowResize {
        from: usize,
        to: usize,
        cause: String,
    },
    CasFailure {
        workspace: String,
        expected: Option<String>,
        actual: Option<String>,
    },
}

One journalled event.

Every variant serializes to a flat JSON object carrying kind and format_version, so jq 'select(.kind == "decision")' works without a schema.

Variants

Decision

The writer accepted or refused one submission.

Fields

actor_id: Option<String>

Verified author, when the policy identified one. None for a submission refused before its signature was resolved, which is itself the interesting case.

workspace: String

The channel the op was signed on.

op_type: Option<String>

The op variant, when the policy decoded one.

accepted: bool

true if the op was ordered and appended.

reject_reason: Option<String>

The refusal, verbatim, when there was one.

seq: Option<u64>

Position assigned, on acceptance only.

parent: Option<String>

The entry this one chained onto, on acceptance only.

decision_latency_us: u64

Time from dequeue to decision, in microseconds.

QueueDepth

A sample of how many commands were waiting behind the writer.

Fields

depth: usize

Commands drained in one wake-up, the writer’s own view of backlog. Sampled rather than continuous: counting costs nothing but recording every value would dominate the file.

WindowResize

The speculative window changed size.

Fields

from: usize

Size before.

to: usize

Size after.

cause: String

Why it moved, so a shrinking window is attributable rather than merely visible.

CasFailure

A compare-and-swap precondition did not hold.

Recorded distinctly from the refusal it also produces, because “two writers raced this ref” is a fact about contention, and a rejection count alone cannot separate it from a client sending nonsense.

Fields

workspace: String

The channel the op was signed on.

expected: Option<String>

What the submitter believed the current value was.

actual: Option<String>

What it actually was at decision time.

Implementations

impl Event

pub fn to_line(&self) -> String

Renders one JSONL line, without its newline.

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 PartialEq for Event

fn eq(&self, other: &Event) -> 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 Eq for Event

impl StructuralPartialEq for Event