Struct JournalEventMessage 

pub struct JournalEventMessage {

    pub run_id: String,
    pub event_type: String,
    pub data: Vec<u8>,
    pub correlation_id: String,
    pub parent_correlation_id: String,
    pub tenant_id: Option<String>,
    pub source_timestamp_ns: i64,
    pub metadata: HashMap<String, String>,
    pub queued_at: Instant,
    pub is_streaming: bool,
    pub is_sse_only: bool,
    pub content_index: i32,
    pub sequence: i64,
}

Unified event message for all event types

Fields

run_id: String

Run ID for this event

event_type: String

Event type (e.g., “workflow.step.completed”, “output.delta”, “log”)

data: Vec<u8>

Event payload as JSON bytes

correlation_id: String

Correlation ID for pairing started↔completed events

parent_correlation_id: String

Parent correlation ID for hierarchy (tree view)

tenant_id: Option<String>

Optional tenant ID

source_timestamp_ns: i64

Source timestamp in nanoseconds (when event was created)

metadata: HashMap<String, String>

Additional metadata (display-friendly key-value pairs)

queued_at: Instant

When event was queued (for metrics)

is_streaming: bool

Whether this is a streaming request (affects delivery mode)

is_sse_only: bool

If true, forward to SSE only (no persist) - for deltas and logs

content_index: i32

Index for parallel content blocks

sequence: i64

Sequence number for ordering

Implementations

impl JournalEventMessage

pub fn is_sse_only_event_type(event_type: &str) -> bool

Check if this event type is an SSE-only event (delta, log, etc.)

pub fn is_checkpoint_event_type(event_type: &str) -> bool

Check if this event type is a checkpoint event that requires sync acknowledgement

Checkpoint events block until the platform acknowledges persistence. This ensures correct event ordering for lifecycle events that affect workflow state.

Checkpoint events include:

• *.started, *.completed, *.failed, *.paused
• approval.requested, approval.resolved

This is the inverse of is_sse_only_event_type() - if an event is NOT SSE-only, it’s a checkpoint event.

pub fn new(run_id: String, event_type: String, data: Vec<u8>) -> Self

Create with automatic is_sse_only detection based on event_type

Trait Implementations

impl Clone for JournalEventMessage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JournalEventMessage

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

Formats the value using the given formatter.

impl Default for JournalEventMessage

fn default() -> Self

Returns the “default value” for a type.