Enum OrchestratorEvent 

pub enum OrchestratorEvent {
    SubAgentStarted {
        id: String,
        agent_type: String,
        description: String,
        parent_id: Option<String>,
        config: SubAgentConfig,
    },
    SubAgentCompleted {
        id: String,
        success: bool,
        output: String,
        duration_ms: u64,
        token_usage: Option<TokenUsage>,
    },
    SubAgentStateChanged {
        id: String,
        old_state: SubAgentState,
        new_state: SubAgentState,
    },
    SubAgentProgress {
        id: String,
        step: usize,
        total_steps: usize,
        message: String,
    },
    SubAgentInternalEvent {
        id: String,
        event: AgentEvent,
    },
    PlanningStarted {
        id: String,
        goal: String,
    },
    PlanningCompleted {
        id: String,
        plan: ExecutionPlan,
    },
    ToolExecutionStarted {
        id: String,
        tool_id: String,
        tool_name: String,
        args: Value,
    },
    ToolExecutionCompleted {
        id: String,
        tool_id: String,
        tool_name: String,
        result: String,
        exit_code: i32,
        duration_ms: u64,
    },
    ControlSignalReceived {
        id: String,
        signal: ControlSignal,
    },
    ControlSignalApplied {
        id: String,
        signal: ControlSignal,
        success: bool,
        error: Option<String>,
    },
    ExternalTaskPending {
        id: String,
        task_id: String,
        lane: SessionLane,
        command_type: String,
        payload: Value,
        timeout_ms: u64,
    },
    ExternalTaskCompleted {
        id: String,
        task_id: String,
        success: bool,
    },
}

Orchestrator 事件 - 统一的事件类型

Variants

SubAgentStarted

SubAgent 启动

Fields

id: String

agent_type: String

description: String

parent_id: Option<String>

config: SubAgentConfig

SubAgentCompleted

SubAgent 完成

Fields

id: String

success: bool

output: String

duration_ms: u64

token_usage: Option<TokenUsage>

SubAgentStateChanged

SubAgent 状态变更

Fields

id: String

old_state: SubAgentState

new_state: SubAgentState

SubAgentProgress

SubAgent 进度更新

Fields

id: String

step: usize

total_steps: usize

message: String

SubAgentInternalEvent

SubAgent 内部事件（来自 AgentLoop）

Fields

id: String

event: AgentEvent

PlanningStarted

规划开始

Fields

id: String

goal: String

PlanningCompleted

规划完成

Fields

id: String

plan: ExecutionPlan

ToolExecutionStarted

工具执行开始

Fields

id: String

tool_id: String

tool_name: String

args: Value

ToolExecutionCompleted

工具执行完成

Fields

id: String

tool_id: String

tool_name: String

result: String

exit_code: i32

duration_ms: u64

ControlSignalReceived

控制信号接收

Fields

id: String

signal: ControlSignal

ControlSignalApplied

控制信号应用

Fields

id: String

signal: ControlSignal

success: bool

error: Option<String>

ExternalTaskPending

A tool call inside a SubAgent is waiting for an external worker.

The consumer must call AgentOrchestrator::complete_external_task() with the matching task_id and a result to unblock the SubAgent.

Fields

id: String

SubAgent that owns this task.

task_id: String

lane: SessionLane

command_type: String

payload: Value

timeout_ms: u64

ExternalTaskCompleted

An external task was resolved (succeeded or failed).

Fields

id: String

SubAgent that owned this task.

task_id: String

success: bool

Implementations

impl OrchestratorEvent

pub fn subagent_id(&self) -> Option<&str>

获取 SubAgent ID

pub fn event_name(&self) -> &'static str

获取事件类型名称

Trait Implementations

impl Clone for OrchestratorEvent

fn clone(&self) -> OrchestratorEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OrchestratorEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OrchestratorEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OrchestratorEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.