Enum WorldEvent 

pub enum WorldEvent {
    Spawned {
        run_id: String,
        agent_id: String,
        blueprint: String,
    },
    Status {
        run_id: String,
        agent_id: String,
        status: String,
        stage: String,
        iteration: usize,
        tool_calls: usize,
        accepts_messages: bool,
    },
    Tokens {
        run_id: String,
        agent_id: String,
        prompt_tokens: usize,
        completion_tokens: usize,
        cached_tokens: usize,
        cache_write_tokens: usize,
    },
    Context {
        run_id: String,
        agent_id: String,
        total_tokens: usize,
        max_tokens: usize,
    },
    Interaction {
        run_id: String,
        agent_id: String,
        request: InteractionRequest,
    },
    Completed {
        run_id: String,
        agent_id: String,
        status: String,
    },
    Log {
        run_id: String,
        agent_id: String,
        line: String,
    },
}

A change in the world, broadcast to subscribers (the HTTP/WS gateway) so they get pushed updates instead of polling. Emitted by the host as it drives the world; streamed over the control transport via ControlRequest::Subscribe.

Variants

Spawned

A run first appeared in the world.

Fields

run_id: String

The run id.

agent_id: String

The agent id.

blueprint: String

The blueprint / agent name.

Status

A run’s status, stage, iteration, or tool-call count changed.

Fields

run_id: String

The run id.

agent_id: String

The agent id.

status: String

Short status label (active, waiting, complete, …).

stage: String

The current stage name.

iteration: usize

The current iteration.

tool_calls: usize

Cumulative tool calls.

accepts_messages: bool

Whether the current stage accepts messages.

Tokens

A run’s token totals changed.

Fields

run_id: String

The run id.

agent_id: String

The agent id.

prompt_tokens: usize

Cumulative prompt tokens.

completion_tokens: usize

Cumulative completion tokens.

cached_tokens: usize

Cumulative cached tokens.

cache_write_tokens: usize

Cumulative cache-write tokens.

Context

A run’s context-window token usage changed.

Fields

run_id: String

The run id.

agent_id: String

The agent id.

total_tokens: usize

Current context tokens.

max_tokens: usize

Max context tokens.

Interaction

A run raised a new interaction awaiting an answer.

Fields

run_id: String

The run id.

agent_id: String

The agent id.

request: InteractionRequest

The interaction request.

Completed

A run reached a terminal status.

Fields

run_id: String

The run id.

agent_id: String

The agent id.

status: String

The terminal status label.

Log

A run produced a per-agent log/output line (readable assistant output or an operational [Tokens: …] / [tool] … / [error] … line).

Fields

run_id: String

The run id.

agent_id: String

The agent id.

line: String

The log line text.

Trait Implementations

impl Clone for WorldEvent

fn clone(&self) -> WorldEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorldEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorldEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WorldEvent

fn eq(&self, other: &WorldEvent) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for WorldEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WorldEvent