pub enum AgentEvent {
Show 26 variants
RunStarted {
run_id: RunId,
task: String,
ts: DateTime<Utc>,
},
PhaseStarted {
run_id: RunId,
phase_id: PhaseId,
label: String,
planned: usize,
parent_span_id: Option<u32>,
description: Option<String>,
role: Option<String>,
ts: DateTime<Utc>,
},
AgentStarted {
run_id: RunId,
phase_id: PhaseId,
agent_id: AgentId,
prompt_preview: String,
model: Option<String>,
description: Option<String>,
role: Option<String>,
name: Option<String>,
agent_seq: u32,
},
AgentProgress {
run_id: RunId,
agent_id: AgentId,
delta: ProgressDelta,
},
AcpRaw {
run_id: RunId,
agent_id: AgentId,
kind: String,
raw: Value,
},
AgentDone {
run_id: RunId,
agent_id: AgentId,
status: AgentStatus,
tokens: TokenUsage,
elapsed_ms: u64,
name: Option<String>,
agent_seq: u32,
output: Value,
findings: Vec<Finding>,
prompt: String,
retry_count: u32,
},
PhaseDone {
run_id: RunId,
phase_id: PhaseId,
ok: usize,
failed: usize,
ts: DateTime<Utc>,
},
RunDone {
run_id: RunId,
status: RunStatus,
total_tokens: TokenUsage,
report: Value,
ts: DateTime<Utc>,
},
Log {
run_id: RunId,
agent_id: Option<AgentId>,
level: LogLevel,
msg: String,
},
BudgetSet {
run_id: RunId,
time_limit_ms: Option<u64>,
max_rounds: Option<u32>,
},
ReportEmitted {
run_id: RunId,
phase_id: PhaseId,
report: Value,
},
ParallelStarted {
run_id: RunId,
phase_id: PhaseId,
span_id: u64,
count: usize,
},
ParallelDone {
run_id: RunId,
phase_id: PhaseId,
span_id: u64,
ok: usize,
failed: usize,
results: Value,
elapsed_ms: u64,
},
WorkflowStarted {
run_id: RunId,
span_id: u64,
path: String,
args: Value,
},
WorkflowDone {
run_id: RunId,
span_id: u64,
path: String,
report: Value,
elapsed_ms: u64,
error: Option<String>,
},
ConvergeStarted {
run_id: RunId,
phase_id: PhaseId,
span_id: u64,
items: usize,
max_rounds: u32,
},
ConvergeDone {
run_id: RunId,
phase_id: PhaseId,
span_id: u64,
rounds: u32,
converged: bool,
surviving: usize,
result: Value,
elapsed_ms: u64,
error: Option<String>,
},
PipelineStarted {
run_id: RunId,
total_stages: usize,
items: usize,
},
PipelineStageStarted {
run_id: RunId,
stage_index: usize,
label: String,
agents_in_stage: usize,
},
PipelineItemDone {
run_id: RunId,
stage_index: usize,
item_index: usize,
status: AgentStatus,
tokens: TokenUsage,
elapsed_ms: u64,
},
PipelineDone {
run_id: RunId,
stages_completed: usize,
total_ok: usize,
total_failed: usize,
},
PhaseSpanStarted {
run_id: RunId,
span_id: u32,
name: String,
parent_id: Option<u32>,
depth: u32,
planned: usize,
},
PhaseSpanDone {
run_id: RunId,
span_id: u32,
name: String,
parent_id: Option<u32>,
depth: u32,
elapsed_ms: u64,
status: String,
},
SchemaRetry {
run_id: RunId,
agent_id: AgentId,
attempt: u32,
max: u32,
},
PlanPreview {
run_id: RunId,
reasoning: String,
phases: Vec<PlanPhase>,
},
SignalReceived {
run_id: Option<RunId>,
signal: String,
ts: DateTime<Utc>,
},
}Variants§
RunStarted
PhaseStarted
Fields
AgentStarted
Fields
AgentProgress
AcpRaw
Raw ACP session/update passthrough — the verbatim notification, surfaced
for observability. Produced only when the ACP backend has raw events
enabled. Not persisted to
the journal (see acp-raw-events.md).
Fields
AgentDone
PhaseDone
RunDone
Log
BudgetSet
ReportEmitted
ParallelStarted
ParallelDone
Fields
WorkflowStarted
WorkflowDone
ConvergeStarted
ConvergeDone
Fields
PipelineStarted
PipelineStageStarted
PipelineItemDone
PipelineDone
PhaseSpanStarted
Structural phase span started — emitted by phase_begin().
PhaseSpanDone
Structural phase span done — emitted by phase_end().
Fields
SchemaRetry
Agent output failed schema validation and is being retried with corrective feedback injected into the prompt. Consumers (CLI, event log) can use this to inform users that an extra LLM round-trip is underway.
PlanPreview
Plan preview — emitted before execution starts, from the meta table.
Lists the declared phases so the CLI can render a plan overview before
real-time execution output begins.
SignalReceived
OS signal received (SIGINT / SIGTERM / Ctrl+C). run_id is None if
the signal arrived before a run had started. Emitted by the process-
level signal handler in [crate::signal].
Trait Implementations§
Source§impl Clone for AgentEvent
impl Clone for AgentEvent
Source§fn clone(&self) -> AgentEvent
fn clone(&self) -> AgentEvent
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for AgentEvent
impl Debug for AgentEvent
Source§impl<'de> Deserialize<'de> for AgentEvent
impl<'de> Deserialize<'de> for AgentEvent
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for AgentEvent
impl RefUnwindSafe for AgentEvent
impl Send for AgentEvent
impl Sync for AgentEvent
impl Unpin for AgentEvent
impl UnsafeUnpin for AgentEvent
impl UnwindSafe for AgentEvent
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more