Enum AgentEvent

Source

pub enum AgentEvent {
Show 27 variants    AgentStarted {
        session_id: SessionId,
        agent_name: String,
        model_id: ModelId,
    },
    AgentEnded {
        session_id: SessionId,
        finish_reason: AgentFinishReason,
        total_usage: Option<Usage>,
        steps: u32,
    },
    StepStarted {
        step_index: u32,
        model_id: ModelId,
        agent_name: String,
    },
    StepEnded {
        step_index: u32,
        finish_reason: FinishReason,
        usage: Option<Usage>,
    },
    StepFailed {
        step_index: u32,
        error: String,
    },
    TextStarted {
        content_index: usize,
    },
    TextDelta {
        content_index: usize,
        delta: String,
    },
    TextEnded {
        content_index: usize,
        text: String,
    },
    ReasoningStarted {
        content_index: usize,
    },
    ReasoningDelta {
        content_index: usize,
        delta: String,
    },
    ReasoningEnded {
        content_index: usize,
        text: String,
    },
    ToolInputStarted {
        call_id: ToolCallId,
        tool_name: String,
    },
    ToolInputDelta {
        call_id: ToolCallId,
        delta: String,
    },
    ToolInputEnded {
        call_id: ToolCallId,
        arguments: Value,
    },
    ToolCalled {
        call_id: ToolCallId,
        tool_name: String,
        arguments: Value,
    },
    ToolProgress {
        call_id: ToolCallId,
        message: String,
        data: Option<Value>,
    },
    ToolSucceeded {
        call_id: ToolCallId,
        tool_name: String,
        output: ToolOutput,
    },
    ToolFailed {
        call_id: ToolCallId,
        tool_name: String,
        error: String,
        is_retryable: bool,
    },
    Retried {
        attempt: u32,
        error: String,
        delay_ms: u64,
    },
    PruneCompleted {
        tokens_freed: u64,
        parts_pruned: usize,
    },
    CompactionStarted {
        trigger: CompactTrigger,
        strategy: CompactionStrategy,
        tokens_before: u64,
    },
    CompactionDelta {
        delta: String,
    },
    CompactionEnded {
        result: CompactionResult,
    },
    TokenBudgetChanged {
        used_tokens: u64,
        context_window: u64,
        state: TokenBudgetState,
    },
    ModelSwitched {
        from: Option<ModelId>,
        to: ModelId,
    },
    AgentSwitched {
        from_agent: Option<AgentId>,
        to_agent: AgentId,
        agent_name: String,
    },
    UserPrompted {
        content_preview: String,
    },
}

Expand description

Agent 语义层事件 — Agent loop 在执行过程中产出的已发生事实。

事件是 不可变的已发生事实，消费者只能观察，不能拦截或修改。如需拦截/修改 Agent 行为，请使用 Hook 系统（future）。

§事件分层

AgentStarted
├── StepStarted
│   ├── TextStarted → TextDelta* → TextEnded
│   ├── ReasoningStarted → ReasoningDelta* → ReasoningEnded
│   ├── ToolInputStarted → ToolInputDelta* → ToolInputEnded
│   │   └── ToolCalled → ToolProgress* → ToolSucceeded / ToolFailed
│   └── StepEnded / StepFailed
├── Retried
├── PruneCompleted
├── CompactionStarted → CompactionDelta* → CompactionEnded
├── TokenBudgetChanged
├── ModelSwitched / AgentSwitched / UserPrompted
└── AgentEnded

§Serde 格式

所有事件序列化为 {"type": "snake_case_variant", ...fields} 格式，与 StreamEvent 保持风格一致。

§Examples

use katu_core::agent_event::AgentEvent;
use katu_core::{SessionId, ModelId};

let event = AgentEvent::AgentStarted {
    session_id: SessionId::new(),
    agent_name: "coder".into(),
    model_id: ModelId::new("gpt-4o"),
};
let json = serde_json::to_string(&event).unwrap();
assert!(json.contains(r#""type":"agent_started""#));