Enum AgentEvent 

pub enum AgentEvent {
    RunStarted {
        run_id: RunId,
        task: String,
        ts: DateTime<Utc>,
    },
    PhaseStarted {
        run_id: RunId,
        phase_id: PhaseId,
        label: String,
        planned: usize,
        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,
        ts: DateTime<Utc>,
    },
    AgentProgress {
        run_id: RunId,
        agent_id: AgentId,
        delta: ProgressDelta,
    },
    AcpRaw {
        run_id: RunId,
        agent_id: AgentId,
        kind: String,
        raw: Value,
    },
    AcpRequest {
        run_id: RunId,
        agent_id: AgentId,
        method: String,
        raw: Value,
    },
    AgentDone {
        run_id: RunId,
        agent_id: AgentId,
        status: AgentStatus,
        tokens: TokenUsage,
        elapsed_ms: u64,
        name: Option<String>,
        agent_seq: u32,
        ts: DateTime<Utc>,
        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,
    },
    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

Fields

run_id: RunId

task: String

ts: DateTime<Utc>

PhaseStarted

Fields

run_id: RunId

phase_id: PhaseId

label: String

planned: usize

description: Option<String>

role: Option<String>

ts: DateTime<Utc>

AgentStarted

Fields

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

ts: DateTime<Utc>

AgentProgress

Fields

run_id: RunId

agent_id: AgentId

delta: ProgressDelta

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

run_id: RunId

agent_id: AgentId

kind: String

SessionUpdate discriminator (the sessionUpdate tag), e.g. "agent_message_chunk", "plan" — lets consumers filter without parsing raw.

raw: Value

The ACP SessionUpdate, serialized verbatim.

AcpRequest

ACP client request sent to the agent, surfaced for protocol observability. Unlike [AcpRaw], this is a request-direction event and is persisted with the normal event stream.

Fields

run_id: RunId

agent_id: AgentId

method: String

ACP method name, for example session/resume or session/prompt.

raw: Value

Serialized ACP request parameters.

AgentDone

Fields

run_id: RunId

agent_id: AgentId

status: AgentStatus

tokens: TokenUsage

elapsed_ms: u64

name: Option<String>

agent_seq: u32

ts: DateTime<Utc>

output: Value

findings: Vec<Finding>

prompt: String

retry_count: u32

PhaseDone

Fields

run_id: RunId

phase_id: PhaseId

ok: usize

failed: usize

ts: DateTime<Utc>

RunDone

Fields

run_id: RunId

status: RunStatus

total_tokens: TokenUsage

report: Value

ts: DateTime<Utc>

Log

Fields

run_id: RunId

agent_id: Option<AgentId>

level: LogLevel

msg: String

BudgetSet

Fields

run_id: RunId

time_limit_ms: Option<u64>

max_rounds: Option<u32>

ReportEmitted

Fields

run_id: RunId

phase_id: PhaseId

report: Value

ParallelStarted

Fields

run_id: RunId

phase_id: PhaseId

span_id: u64

count: usize

ParallelDone

Fields

run_id: RunId

phase_id: PhaseId

span_id: u64

ok: usize

failed: usize

results: Value

elapsed_ms: u64

WorkflowStarted

Fields

run_id: RunId

span_id: u64

path: String

args: Value

WorkflowDone

Fields

run_id: RunId

span_id: u64

path: String

report: Value

elapsed_ms: u64

error: Option<String>

ConvergeStarted

Fields

run_id: RunId

phase_id: PhaseId

span_id: u64

items: usize

max_rounds: u32

ConvergeDone

Fields

run_id: RunId

phase_id: PhaseId

span_id: u64

rounds: u32

converged: bool

surviving: usize

result: Value

elapsed_ms: u64

error: Option<String>

PipelineStarted

Fields

run_id: RunId

total_stages: usize

items: usize

PipelineStageStarted

Fields

run_id: RunId

stage_index: usize

label: String

agents_in_stage: usize

PipelineItemDone

Fields

run_id: RunId

stage_index: usize

item_index: usize

status: AgentStatus

tokens: TokenUsage

elapsed_ms: u64

PipelineDone

Fields

run_id: RunId

stages_completed: usize

total_ok: usize

total_failed: usize

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.

Fields

run_id: RunId

agent_id: AgentId

attempt: u32

max: u32

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.

Fields

run_id: RunId

reasoning: String

phases: Vec<PlanPhase>

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].

Fields

run_id: Option<RunId>

signal: String

ts: DateTime<Utc>

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.