Enum AgentEvent 

pub enum AgentEvent {
    AgentMessageChunk {
        session_id: String,
        content: String,
    },
    AgentThoughtChunk {
        session_id: String,
        content: String,
    },
    ToolCall {
        session_id: String,
        tool_call_id: String,
        tool_name: String,
        kind: Option<ToolKind>,
        status: ToolCallStatus,
        raw_input: Value,
    },
    ToolCallUpdate {
        session_id: String,
        tool_call_id: String,
        tool_name: String,
        status: ToolCallStatus,
        raw_output: Option<Value>,
        error: Option<String>,
    },
    Plan {
        session_id: String,
        plan: Value,
    },
    TurnStart {
        session_id: String,
        iteration: usize,
    },
    TurnEnd {
        session_id: String,
        iteration: usize,
        turn_info: Value,
    },
    FeedbackInjected {
        session_id: String,
        kind: String,
        content: String,
    },
    BudgetExhausted {
        session_id: String,
        max_iterations: usize,
    },
    LoopStuck {
        session_id: String,
        max_nudges: usize,
        last_iteration: usize,
        tail_excerpt: String,
    },
    DaemonWatchdogTripped {
        session_id: String,
        attempts: usize,
        elapsed_ms: u64,
    },
    SkillActivated {
        session_id: String,
        skill_name: String,
        iteration: usize,
        reason: String,
    },
    SkillDeactivated {
        session_id: String,
        skill_name: String,
        iteration: usize,
    },
    SkillScopeTools {
        session_id: String,
        skill_name: String,
        allowed_tools: Vec<String>,
    },
    ToolSearchQuery {
        session_id: String,
        tool_use_id: String,
        name: String,
        query: Value,
        strategy: String,
        mode: String,
    },
    ToolSearchResult {
        session_id: String,
        tool_use_id: String,
        promoted: Vec<String>,
        strategy: String,
        mode: String,
    },
    TranscriptCompacted {
        session_id: String,
        mode: String,
        strategy: String,
        archived_messages: usize,
        estimated_tokens_before: usize,
        estimated_tokens_after: usize,
        snapshot_asset_id: Option<String>,
    },
    Handoff {
        session_id: String,
        artifact_id: String,
        handoff: Box<HandoffArtifact>,
    },
}

Events emitted by the agent loop. The first five variants map 1:1 to ACP sessionUpdate variants; the last three are harn-internal.

Variants

AgentMessageChunk

Fields

session_id: String

content: String

AgentThoughtChunk

Fields

session_id: String

content: String

ToolCall

Fields

session_id: String

tool_call_id: String

tool_name: String

kind: Option<ToolKind>

status: ToolCallStatus

raw_input: Value

ToolCallUpdate

Fields

session_id: String

tool_call_id: String

tool_name: String

status: ToolCallStatus

raw_output: Option<Value>

error: Option<String>

Plan

Fields

session_id: String

plan: Value

TurnStart

Fields

session_id: String

iteration: usize

TurnEnd

Fields

session_id: String

iteration: usize

turn_info: Value

FeedbackInjected

Fields

session_id: String

kind: String

content: String

BudgetExhausted

Emitted when the agent loop exhausts max_iterations without any explicit break condition firing. Distinct from a natural “done” or a “stuck” nudge-exhaustion: this is strictly a budget cap.

Fields

session_id: String

max_iterations: usize

LoopStuck

Emitted when the loop breaks because consecutive text-only turns hit max_nudges. Parity with BudgetExhausted / TurnEnd for hosts that key off agent-terminal events.

Fields

session_id: String

max_nudges: usize

last_iteration: usize

tail_excerpt: String

DaemonWatchdogTripped

Emitted when the daemon idle-wait loop trips its watchdog because every configured wake source returned None for N consecutive attempts. Exists so a broken daemon doesn’t hang the session silently.

Fields

session_id: String

attempts: usize

elapsed_ms: u64

SkillActivated

Emitted when a skill is activated. Carries the match reason so replayers can reconstruct why a given skill took effect at this iteration.

Fields

session_id: String

skill_name: String

iteration: usize

reason: String

SkillDeactivated

Emitted when a previously-active skill is deactivated because the reassess phase no longer matches it.

Fields

session_id: String

skill_name: String

iteration: usize

SkillScopeTools

Emitted once per activation when the skill’s allowed_tools filter narrows the effective tool surface exposed to the model.

Fields

session_id: String

skill_name: String

allowed_tools: Vec<String>

ToolSearchQuery

Emitted when a tool_search query is issued by the model. Carries the raw query args, the configured strategy, and a mode tag distinguishing the client-executed fallback ("client") from provider-native paths ("anthropic" / "openai"). Mirrors the transcript event shape so IDEs can render a search-in-progress chip in real time — the replay path walks the transcript after the turn, which is too late for live UX.

Fields

session_id: String

tool_use_id: String

name: String

query: Value

strategy: String

mode: String

ToolSearchResult

Emitted when tool_search resolves — carries the list of tool names newly promoted into the model’s effective surface for the next turn. Pair-emitted with ToolSearchQuery on every search.

Fields

session_id: String

tool_use_id: String

promoted: Vec<String>

strategy: String

mode: String

TranscriptCompacted

Fields

session_id: String

mode: String

strategy: String

archived_messages: usize

estimated_tokens_before: usize

estimated_tokens_after: usize

snapshot_asset_id: Option<String>

Handoff

Fields

session_id: String

artifact_id: String

handoff: Box<HandoffArtifact>

Implementations

impl AgentEvent

pub fn session_id(&self) -> &str

Trait Implementations

impl Clone for AgentEvent

fn clone(&self) -> AgentEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AgentEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.