Enum AgentEvent

Source

#[non_exhaustive]pub enum AgentEvent {
Show 38 variants    Start {
        prompt: String,
    },
    TurnStart {
        turn: usize,
    },
    TextDelta {
        text: String,
    },
    ToolStart {
        id: String,
        name: String,
    },
    ToolInputDelta {
        delta: String,
    },
    ToolEnd {
        id: String,
        name: String,
        output: String,
        exit_code: i32,
    },
    ToolOutputDelta {
        id: String,
        name: String,
        delta: String,
    },
    TurnEnd {
        turn: usize,
        usage: TokenUsage,
    },
    End {
        text: String,
        usage: TokenUsage,
    },
    Error {
        message: String,
    },
    ConfirmationRequired {
        tool_id: String,
        tool_name: String,
        args: Value,
        timeout_ms: u64,
    },
    ConfirmationReceived {
        tool_id: String,
        approved: bool,
        reason: Option<String>,
    },
    ConfirmationTimeout {
        tool_id: String,
        action_taken: String,
    },
    ExternalTaskPending {
        task_id: String,
        session_id: String,
        lane: SessionLane,
        command_type: String,
        payload: Value,
        timeout_ms: u64,
    },
    ExternalTaskCompleted {
        task_id: String,
        session_id: String,
        success: bool,
    },
    PermissionDenied {
        tool_id: String,
        tool_name: String,
        args: Value,
        reason: String,
    },
    ContextResolving {
        providers: Vec<String>,
    },
    ContextResolved {
        total_items: usize,
        total_tokens: usize,
    },
    CommandDeadLettered {
        command_id: String,
        command_type: String,
        lane: String,
        error: String,
        attempts: u32,
    },
    CommandRetry {
        command_id: String,
        command_type: String,
        lane: String,
        attempt: u32,
        delay_ms: u64,
    },
    QueueAlert {
        level: String,
        alert_type: String,
        message: String,
    },
    TaskUpdated {
        session_id: String,
        tasks: Vec<Task>,
    },
    MemoryStored {
        memory_id: String,
        memory_type: String,
        importance: f32,
        tags: Vec<String>,
    },
    MemoryRecalled {
        memory_id: String,
        content: String,
        relevance: f32,
    },
    MemoriesSearched {
        query: Option<String>,
        tags: Vec<String>,
        result_count: usize,
    },
    MemoryCleared {
        tier: String,
        count: u64,
    },
    SubagentStart {
        task_id: String,
        session_id: String,
        parent_session_id: String,
        agent: String,
        description: String,
    },
    SubagentProgress {
        task_id: String,
        session_id: String,
        status: String,
        metadata: Value,
    },
    SubagentEnd {
        task_id: String,
        session_id: String,
        agent: String,
        output: String,
        success: bool,
    },
    PlanningStart {
        prompt: String,
    },
    PlanningEnd {
        plan: ExecutionPlan,
        estimated_steps: usize,
    },
    StepStart {
        step_id: String,
        description: String,
        step_number: usize,
        total_steps: usize,
    },
    StepEnd {
        step_id: String,
        status: TaskStatus,
        step_number: usize,
        total_steps: usize,
    },
    GoalExtracted {
        goal: AgentGoal,
    },
    GoalProgress {
        goal: String,
        progress: f32,
        completed_steps: usize,
        total_steps: usize,
    },
    GoalAchieved {
        goal: String,
        total_steps: usize,
        duration_ms: i64,
    },
    ContextCompacted {
        session_id: String,
        before_messages: usize,
        after_messages: usize,
        percent_before: f32,
    },
    PersistenceFailed {
        session_id: String,
        operation: String,
        error: String,
    },
}

Expand description

Events emitted during agent execution

Subscribe via Session::subscribe_events(). New variants may be added in minor releases — always include a wildcard arm (_ => {}) when matching.

Variants (Non-exhaustive)§

This enum is marked as non-exhaustive

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

§