Enum Event 

pub enum Event {
    StrategyResolved {
        strategy: String,
        agent_id: Option<AgentId>,
        elapsed_ms: u64,
        tokens_used: u32,
    },
    ToolInvoked {
        tool_id: ToolId,
        args_hash: u64,
        elapsed_ms: u64,
        ok: bool,
    },
    ToolCallStreamed {
        agent_id: AgentId,
        tool_name: String,
        arguments_hash: u64,
        iteration: u32,
    },
    AgentTurn {
        agent_id: AgentId,
        input_tokens: u32,
        output_tokens: u32,
        reasoning_tokens: u32,
        cached_tokens: u32,
        finish_reason: Option<FinishReason>,
        elapsed_ms: u64,
    },
    WorkflowStep {
        workflow_id: WorkflowId,
        step_id: String,
        step_kind: String,
        elapsed_ms: u64,
        ok: bool,
    },
    HarnessIteration {
        harness_id: HarnessId,
        iteration: u64,
        outcome: String,
        budget_remaining_tokens: u32,
    },
    Backpressure {
        actor_path: String,
        queued: u32,
        dropped: u32,
    },
}

Structured event emitted by every observable boundary in the framework. Fed to atomr-telemetry, used by traces, metrics, and the eval-suite replay path.

Variants

StrategyResolved

Fields

strategy: String

agent_id: Option<AgentId>

elapsed_ms: u64

tokens_used: u32

ToolInvoked

Fields

tool_id: ToolId

args_hash: u64

elapsed_ms: u64

ok: bool

ToolCallStreamed

Emitted when an inference turn streams a tool call before it is dispatched. Lets tracers / UIs surface tool intent in real-time, distinct from ToolInvoked which fires post-call.

Fields

agent_id: AgentId

tool_name: String

arguments_hash: u64

iteration: u32

AgentTurn

Fields

agent_id: AgentId

input_tokens: u32

output_tokens: u32

reasoning_tokens: u32

Provider-reported reasoning tokens (e.g. o1-style). Defaults to 0 for runtimes that don’t surface them.

cached_tokens: u32

Cached prefix tokens (Anthropic prompt-cache, OpenAI cached input). Priced lower than input_tokens by most providers.

finish_reason: Option<FinishReason>

elapsed_ms: u64

WorkflowStep

Fields

workflow_id: WorkflowId

step_id: String

step_kind: String

elapsed_ms: u64

ok: bool

HarnessIteration

Fields

harness_id: HarnessId

iteration: u64

outcome: String

budget_remaining_tokens: u32

Backpressure

Fields

actor_path: String

queued: u32

dropped: u32

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Event

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Event

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Event

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

where __S: Serializer,

Serialize this value into the given Serde serializer.