Struct EventRecord 

pub struct EventRecord {
    pub ts: String,
    pub iteration: u32,
    pub hat: String,
    pub topic: String,
    pub triggered: Option<String>,
    pub payload: String,
    pub blocked_count: Option<u32>,
    pub wave_id: Option<String>,
    pub wave_index: Option<u32>,
    pub wave_total: Option<u32>,
}

A logged event record for debugging.

Supports two schemas:

1. Rich internal format (logged by Ralph): {"ts":"2024-01-15T10:23:45Z","iteration":1,"hat":"loop","topic":"task.start","triggered":"planner","payload":"..."}
2. Simple agent format (written by agents): {"topic":"build.task","payload":"...","ts":"2024-01-15T10:24:12Z"}

Fields that don’t exist in the agent format default to sensible values.

Fields

ts: String

ISO 8601 timestamp.

iteration: u32

Loop iteration number (0 if not provided by agent-written events).

hat: String

Hat that was active when event was published (empty string if not provided).

topic: String

Event topic.

triggered: Option<String>

Hat that will be triggered by this event.

payload: String

Event content (truncated if large). Defaults to empty string for agent events without payload. Accepts both string and object payloads - objects are serialized to JSON strings.

blocked_count: Option<u32>

How many times this task has blocked (optional).

wave_id: Option<String>

Wave correlation ID.

wave_index: Option<u32>

Index of this event within the wave (0-based).

wave_total: Option<u32>

Total number of events in the wave.

Implementations

impl EventRecord

pub fn new( iteration: u32, hat: impl Into<String>, event: &Event, triggered: Option<&HatId>, ) -> Self

Creates a new event record.

pub fn with_blocked_count(self, count: u32) -> Self

Sets the blocked count for this record.

Trait Implementations

impl Clone for EventRecord

fn clone(&self) -> EventRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EventRecord

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

where __S: Serializer,

Serialize this value into the given Serde serializer.