Enum StreamEvent 

pub enum StreamEvent {
    TaskDiscovered {
        task_id: TaskId,
        task_name: String,
        depends_on: Vec<String>,
    },
    TaskTransition {
        task_id: TaskId,
        task_name: String,
        from: TaskState,
        to: TaskState,
        elapsed: Option<Duration>,
        exit_code: Option<i32>,
        detail: Option<String>,
        at: DateTime<Utc>,
    },
    RunTransition {
        run_id: Uuid,
        from: RunState,
        to: RunState,
        reason: Option<String>,
        at: DateTime<Utc>,
    },
    CommandOutput {
        task_id: TaskId,
        task_name: String,
        line: String,
    },
    TransientStatus {
        message: String,
    },
    ExplainUpdate {
        summary: String,
    },
    TaskWorker {
        task_id: TaskId,
        worker_id: String,
    },
    RunStarted {
        run_id: Uuid,
        objective: String,
        at: DateTime<Utc>,
    },
    RunExited {
        payload: ContinuationPayload,
    },
    Tick,
}

Events the stream renderer can consume.

Variants

TaskDiscovered

A task is known/planned for this run before transitions are emitted.

Fields

task_id: TaskId

task_name: String

depends_on: Vec<String>

TaskTransition

A task changed state (Section 33: single structured line per transition).

Fields

task_id: TaskId

task_name: String

from: TaskState

to: TaskState

elapsed: Option<Duration>

exit_code: Option<i32>

detail: Option<String>

at: DateTime<Utc>

RunTransition

A run changed state.

Fields

run_id: Uuid

from: RunState

to: RunState

reason: Option<String>

at: DateTime<Utc>

CommandOutput

Live command output from an executing task.

Fields

task_id: TaskId

task_name: String

line: String

TransientStatus

A transient status message (e.g. “connecting to postgres…”). Shows only in inline viewport, never pushed to scrollback.

Fields

message: String

ExplainUpdate

A “Why Not Done?” summary update.

Fields

summary: String

TaskWorker

A task’s worker assignment for display.

Fields

task_id: TaskId

worker_id: String

RunStarted

Run started — emitted once at the beginning so operators know the run ID.

Fields

run_id: Uuid

objective: String

at: DateTime<Utc>

RunExited

Run exited — structured continuation payload for downstream tooling.

Fields

payload: ContinuationPayload

Tick

Tick event — advance spinners and refresh viewport.

Trait Implementations

impl Clone for StreamEvent

fn clone(&self) -> StreamEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamEvent

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

Formats the value using the given formatter.