Enum StreamFrame 

pub enum StreamFrame {
    LlmChunk {
        text: String,
        model: String,
        run_id: Option<String>,
    },
    ThinkingChunk {
        text: String,
        run_id: Option<String>,
    },
    LlmDone {
        total_tokens: u64,
        run_id: Option<String>,
    },
    LlmRetry,
    LlmCallStats {
        model: String,
        input_tokens: u64,
        output_tokens: u64,
        cache_read: u64,
        cache_write: u64,
        ttft_ms: u64,
        tokens_per_second: f64,
        wallclock_ms: u64,
        run_id: Option<String>,
        node_id: Option<String>,
    },
    ToolUseStart {
        tool: String,
        args_preview: String,
        id: String,
    },
    ToolUseDone {
        tool: String,
        ok: bool,
        preview: String,
        id: String,
    },
    Note(String),
    Notification(NotificationFrame),
    FlowGraph {
        run_id: String,
        graph: FlowGraph,
    },
    FlowStart {
        run_id: String,
        flow_name: String,
        parent_run_id: Option<String>,
        parent_node_id: Option<String>,
    },
    FlowNodeStart {
        run_id: String,
        node_id: String,
        kind: NodeKind,
        label: String,
        parent_node_id: Option<String>,
    },
    FlowNodeEnd {
        run_id: String,
        node_id: String,
        status: FlowNodeStatus,
        output_preview: Option<String>,
        parent_node_id: Option<String>,
    },
    FlowDone {
        run_id: String,
        flow_name: String,
        ok: bool,
        cancelled: bool,
    },
    ToolNode {
        run_id: String,
        parent_node_id: String,
        tool_use_id: String,
        tool: String,
        args_preview: String,
    },
    AssistantMsg {
        flow_run_id: Option<String>,
        message: Message,
    },
    ToolResultMsg {
        flow_run_id: Option<String>,
        message: Message,
    },
    ToolPendingApproval {
        run_id: String,
        tool_use_id: String,
        tool_name: String,
        args_preview: String,
        level: String,
        preview: Option<String>,
    },
    ToolApproved {
        run_id: String,
        tool_use_id: String,
        decided_by: String,
    },
    ToolDenied {
        run_id: String,
        tool_use_id: String,
        reason: String,
    },
    TerminalChunk {
        handle: String,
        bytes: Vec<u8>,
        screen: Option<TerminalScreen>,
        state: TermStateSnapshot,
        run_id: Option<String>,
    },
    TerminalExited {
        handle: String,
        exit_code: Option<i32>,
        run_id: Option<String>,
    },
    BashChunk {
        handle: String,
        kind: String,
        line: String,
        run_id: Option<String>,
    },
    BashExited {
        handle: String,
        exit_code: Option<i32>,
        error: Option<String>,
        run_id: Option<String>,
    },
    DiffPreview {
        title: String,
        old_content: Option<String>,
        new_content: Option<String>,
        unified_diff: Option<String>,
        run_id: Option<String>,
    },
    CompactionSummary {
        phase: CompactionPhase,
        range_start: usize,
        range_end: usize,
        summary: String,
        before_tokens: u64,
        after_tokens: u64,
        compacted_count: usize,
    },
    MermaidDiagram {
        source: String,
    },
    SubAgentStarted {
        handle: String,
        goal: String,
        child_run_id: String,
        model: String,
    },
    SubAgentDone {
        handle: String,
        status: String,
        final_text: String,
    },
    Unknown,
}

Variants

LlmChunk

Fields

text: String

model: String

run_id: Option<String>

ThinkingChunk

Fields

text: String

run_id: Option<String>

LlmDone

Fields

total_tokens: u64

run_id: Option<String>

LlmRetry

Discard streaming output from the previous attempt before retrying.

LlmCallStats

Fields

model: String

input_tokens: u64

output_tokens: u64

cache_read: u64

cache_write: u64

ttft_ms: u64

tokens_per_second: f64

wallclock_ms: u64

run_id: Option<String>

node_id: Option<String>

ToolUseStart

Fields

tool: String

args_preview: String

id: String

ToolUseDone

Fields

tool: String

ok: bool

preview: String

id: String

Note(String)

Notification(NotificationFrame)

Rich notification with level/location/lifecycle/stack.

FlowGraph

Fields

run_id: String

graph: FlowGraph

FlowStart

Fields

run_id: String

flow_name: String

parent_run_id: Option<String>

parent_node_id: Option<String>

FlowNodeStart

Fields

run_id: String

node_id: String

kind: NodeKind

label: String

parent_node_id: Option<String>

FlowNodeEnd

Fields

run_id: String

node_id: String

status: FlowNodeStatus

output_preview: Option<String>

parent_node_id: Option<String>

FlowDone

Fields

run_id: String

flow_name: String

ok: bool

cancelled: bool

ToolNode

Fields

run_id: String

parent_node_id: String

tool_use_id: String

tool: String

args_preview: String

AssistantMsg

Fields

flow_run_id: Option<String>

message: Message

ToolResultMsg

Fields

flow_run_id: Option<String>

message: Message

ToolPendingApproval

Fields

run_id: String

tool_use_id: String

tool_name: String

args_preview: String

level: String

preview: Option<String>

ToolApproved

Fields

run_id: String

tool_use_id: String

decided_by: String

ToolDenied

Fields

run_id: String

tool_use_id: String

reason: String

TerminalChunk

Fields

handle: String

bytes: Vec<u8>

screen: Option<TerminalScreen>

state: TermStateSnapshot

run_id: Option<String>

TerminalExited

Fields

handle: String

exit_code: Option<i32>

run_id: Option<String>

BashChunk

Fields

handle: String

kind: String

line: String

run_id: Option<String>

BashExited

Fields

handle: String

exit_code: Option<i32>

error: Option<String>

run_id: Option<String>

DiffPreview

Fields

title: String

old_content: Option<String>

new_content: Option<String>

unified_diff: Option<String>

run_id: Option<String>

CompactionSummary

Fields

phase: CompactionPhase

range_start: usize

range_end: usize

summary: String

before_tokens: u64

after_tokens: u64

compacted_count: usize

MermaidDiagram

Fields

source: String

SubAgentStarted

Fields

handle: String

goal: String

child_run_id: String

model: String

SubAgentDone

Fields

handle: String

status: String

final_text: String

Unknown

Trait Implementations

impl Clone for StreamFrame

fn clone(&self) -> StreamFrame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamFrame

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamFrame

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for StreamFrame

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

where __S: Serializer,

Serialize this value into the given Serde serializer.