Enum Event 

pub enum Event {
    Child(NodeId, AgentMsg),
    Reaped(Reaped),
    StepDone {
        run: String,
        step: String,
        output: Value,
        is_error: bool,
        error: Option<String>,
        tokens: u64,
    },
    ToolDone {
        node: NodeId,
        req: u64,
        result: Value,
        is_error: bool,
    },
    KnowledgeDone {
        job: u64,
        block: Option<String>,
    },
    Background {
        id: String,
        result: Value,
    },
    TimerFired {
        id: String,
        owner: Value,
        payload: Value,
    },
    Inbox(InboxEvent),
    SubscribeRead {
        server: String,
        uri: String,
        content: Option<Value>,
    },
    Tick,
}

One loop event.

Variants

Child(NodeId, AgentMsg)

A frame from a child (turn worker / subagent).

Reaped(Reaped)

A child exited (from the reaper).

StepDone

An executor thread finished a workflow step (mcp.tool, mapped tools…).

Fields

run: String

step: String

output: Value

is_error: bool

error: Option<String>

tokens: u64

ToolDone

An executor thread finished a mapped/MCP call made on behalf of a child’s tool request.

Fields

node: NodeId

req: u64

result: Value

is_error: bool

KnowledgeDone

Knowledge auto-context retrieval finished for a staged turn.

Fields

job: u64

block: Option<String>

Background

A background intelligence call finished. id names the caller (goal.judge, human.judge:<gate>) so the loop can route the result back to whoever asked without blocking on the call itself.

Fields

id: String

result: Value

TimerFired

A durable timer fired.

Fields

id: String

owner: Value

payload: Value

Inbox(InboxEvent)

A durable event was accepted (already in the inbox).

SubscribeRead

A subscribe start node’s notify-then-read finished off-loop.

Fields

server: String

uri: String

content: Option<Value>

Tick

The 200 ms tick.

Trait Implementations

impl Debug for Event

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

Formats the value using the given formatter.