Enum ProgressEvent 

pub enum ProgressEvent {
    StateTransition {
        from: ExecutionStateTag,
        to: ExecutionStateTag,
        at: i64,
    },
    PauseRequested {
        info: PauseInfo,
        at: i64,
    },
    ResumeAccepted {
        payload_kind: PauseKind,
        at: i64,
    },
    Note {
        title: Option<String>,
        content: String,
        at: i64,
    },
    LlmCallBegin {
        query_id: String,
        at: i64,
    },
    LlmCallEnd {
        query_id: String,
        usage: Option<TokenUsage>,
        at: i64,
    },
    Tick {
        phase: String,
        at: i64,
    },
}

An event emitted on the per-session broadcast channel.

All variants carry an at field (Unix timestamp in milliseconds). The channel is emitted from crate::execution::ExecutionService implementations inside the engine layer; multiple independent observers may subscribe via crate::execution::ExecutionService::observe without affecting one another (crux: Sink-free broadcast Progress fan-out).

Serde

Uses #[serde(tag = "kind", rename_all = "snake_case")] internally tagged representation, so JSON consumers see {"kind": "state_transition", ...}.

Variants

StateTransition

The session transitioned from one state to another.

Fields

from: ExecutionStateTag

The previous state tag.

to: ExecutionStateTag

The new state tag.

at: i64

Unix timestamp (milliseconds) of the transition.

PauseRequested

The session entered a paused state and is waiting for LLM responses.

Fields

info: PauseInfo

Details of the pause (pending prompts, kind, timestamp).

at: i64

Unix timestamp (milliseconds) when the pause was requested.

ResumeAccepted

A resume call was accepted and execution is continuing.

Fields

payload_kind: PauseKind

The pause kind (single or batch) that was resolved.

at: i64

Unix timestamp (milliseconds) when the resume was accepted.

Note

A free-form diagnostic note from the engine.

Fields

title: Option<String>

Optional short title for the note.

content: String

Note body.

at: i64

Unix timestamp (milliseconds) of the note.

LlmCallBegin

An LLM call was dispatched for the given query.

Fields

query_id: String

The query identifier.

at: i64

Unix timestamp (milliseconds) when the call began.

LlmCallEnd

An LLM call completed and a response was received.

Fields

query_id: String

The query identifier.

usage: Option<TokenUsage>

Token usage for this call, if reported.

at: i64

Unix timestamp (milliseconds) when the call ended.

Tick

A periodic heartbeat tick from the execution loop.

Fields

phase: String

A short label describing the current execution phase.

at: i64

Unix timestamp (milliseconds) of the tick.

Trait Implementations

impl Clone for ProgressEvent

fn clone(&self) -> ProgressEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProgressEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProgressEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ProgressEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.