Enum NormalizedEvent 

pub enum NormalizedEvent {
    RunStart {
        run_id: String,
        agent_id: String,
    },
    ChatDelta {
        run_id: String,
        text_delta: String,
    },
    ThinkingDelta {
        run_id: String,
        text_delta: String,
    },
    ReasoningDelta {
        run_id: String,
        text_delta: String,
    },
    Citation {
        run_id: String,
        sources: Vec<CitationSource>,
    },
    RagCitations {
        run_id: String,
        citations: Vec<RagCitation>,
    },
    MemoryRecall {
        run_id: String,
        items: Vec<MemoryItem>,
    },
    SkillActivated {
        run_id: String,
        skill_id: String,
        title: String,
        selection_method: String,
    },
    McpServerStateChanged {
        run_id: Option<String>,
        lifecycle: McpServerLifecycle,
    },
    ToolStart {
        run_id: String,
        call_index: usize,
        tool_call_id: String,
        tool: String,
        input: Value,
    },
    ToolDelta {
        run_id: String,
        call_index: usize,
        tool_call_id: String,
        delta: Value,
    },
    ToolEnd {
        run_id: String,
        call_index: usize,
        tool_call_id: String,
        tool: String,
        output: Value,
        ok: bool,
    },
    Artifact {
        run_id: String,
        artifact: ArtifactPayload,
    },
    PresentationDiagnostic {
        run_id: String,
        code: String,
        message: String,
    },
    Error {
        run_id: String,
        code: String,
        message: String,
    },
    RunDone {
        run_id: String,
    },
    Cancelled {
        run_id: String,
    },
    SycophancyFlagged {
        run_id: String,
        sycophancy_score: f32,
        has_critical: bool,
        correction_mandatory: bool,
        classifications: Vec<SycophancyClassification>,
    },
    SycophancyCorrected {
        run_id: String,
        corrected_text: String,
    },
    GuardrailFlagged {
        run_id: Option<String>,
        category: String,
        reason: String,
    },
    RuntimeStep {
        run_id: String,
        step: u32,
        kind: String,
    },
    AgentThreadStarted {
        run_id: String,
        lifecycle: AgentLifecycle,
    },
    AgentThreadUpdated {
        run_id: String,
        lifecycle: AgentLifecycle,
    },
    AgentThreadFinished {
        run_id: String,
        lifecycle: AgentLifecycle,
    },
    AgentThreadError {
        run_id: String,
        lifecycle: AgentLifecycle,
    },
    StatePatch {
        run_id: String,
        patch: Vec<StatePatchOp>,
    },
    ContextAction(ContextAction),
    BudgetAlert {
        run_id: String,
        scope: String,
        scope_id: String,
        spent_usd: f64,
        limit_usd: f64,
        exceeded: bool,
    },
    MemoryMutation {
        run_id: String,
        operation: String,
        memory_id: String,
        content: String,
        scope: String,
        memory_type: String,
    },
    ArtifactDisplay {
        run_id: String,
        artifact: ArtifactPayload,
    },
    ArtifactInputRequest {
        run_id: String,
        artifact: ArtifactPayload,
    },
    ToolCallApprovalRequired {
        run_id: String,
        approval_id: Option<String>,
        call_index: usize,
        tool_call_id: String,
        name: String,
        arguments_json: String,
        risk_reason: String,
    },
    ToolCallDenied {
        run_id: String,
        call_index: usize,
        tool_call_id: String,
        name: String,
        reason: String,
    },
    RunDoneWithUsage {
        run_id: String,
        input_tokens: Option<u32>,
        output_tokens: Option<u32>,
        total_tokens: Option<u32>,
        cost_usd_estimate: Option<f64>,
        model: Option<String>,
    },
}

Variants

RunStart

Fields

run_id: String

agent_id: String

ChatDelta

Fields

run_id: String

text_delta: String

ThinkingDelta

Fields

run_id: String

text_delta: String

ReasoningDelta

Fields

run_id: String

text_delta: String

Citation

Fields

run_id: String

sources: Vec<CitationSource>

RagCitations

Numbered citation markers ([1], [2], …) for a RAG-augmented run, each referencing one retrieved knowledge chunk. Emitted once retrieval completes and before the assistant’s response streams, so the client can resolve [n] markers that appear in the response text to a hover-to-source panel. Built by crate::uar::rag::citation_stream::CitationStream. Distinct from Self::Citation, which carries LLM-native web citations (URL sources) rather than RAG chunk citations.

Fields

run_id: String

citations: Vec<RagCitation>

MemoryRecall

Fields

run_id: String

items: Vec<MemoryItem>

SkillActivated

Fields

run_id: String

skill_id: String

title: String

selection_method: String

McpServerStateChanged

Host-owned MCP binding state; a binding may outlive an individual run.

Fields

run_id: Option<String>

lifecycle: McpServerLifecycle

ToolStart

Fields

run_id: String

call_index: usize

tool_call_id: String

tool: String

input: Value

ToolDelta

Fields

run_id: String

call_index: usize

tool_call_id: String

delta: Value

ToolEnd

Fields

run_id: String

call_index: usize

tool_call_id: String

tool: String

output: Value

ok: bool

Artifact

Fields

run_id: String

artifact: ArtifactPayload

PresentationDiagnostic

A surface was rejected without terminating the readable-text run. This is a host diagnostic, not a successful publication receipt.

Fields

run_id: String

code: String

message: String

Error

Fields

run_id: String

code: String

message: String

RunDone

Fields

run_id: String

Cancelled

A run was cancelled — explicitly via the cancel endpoint, by the last SSE subscriber disconnecting, or by server shutdown. Terminal, distinct from RunDone (normal completion) and Error (failure).

Fields

run_id: String

SycophancyFlagged

The completed assistant response was flagged by sycophancy detection. Quality signal (not an error); emitted only when the score meets the configured threshold or a critical pattern was found. Carries the score and pattern classifications, never the full response text.

Fields

run_id: String

sycophancy_score: f32

0.0 (clean) – 1.0 (fully sycophantic).

has_critical: bool

correction_mandatory: bool

classifications: Vec<SycophancyClassification>

SycophancyCorrected

A sycophantic response was auto-corrected: carries the rewritten text, emitted as a follow-up after the original response. Opt-in (auto_correct).

Fields

run_id: String

corrected_text: String

GuardrailFlagged

Chat input was flagged by an input guardrail (prompt-injection or PII). run_id is absent when the input was blocked before a run started. Carries only the category and a short reason — never the raw input or the matched secret value.

Fields

run_id: Option<String>

category: String

injection | pii.

reason: String

Short, content-free reason label.

RuntimeStep

A tool-loop iteration boundary — per-step run progress for the Runtime Console. Emitted at the start and end of each orchestrator iteration.

Fields

run_id: String

step: u32

Monotonic per-run step index (the orchestrator iteration number).

kind: String

started | finished.

AgentThreadStarted

A persisted child turn started. Never contains its prompt or history.

Fields

run_id: String

lifecycle: AgentLifecycle

AgentThreadUpdated

A child was persisted pending execution or changed nonterminal state.

Fields

run_id: String

lifecycle: AgentLifecycle

AgentThreadFinished

A child turn completed successfully; its output is retrieved separately.

Fields

run_id: String

lifecycle: AgentLifecycle

AgentThreadError

A child failed or was cancelled, including before a child run started.

Fields

run_id: String

lifecycle: AgentLifecycle

StatePatch

Fields

run_id: String

patch: Vec<StatePatchOp>

ContextAction(ContextAction)

BudgetAlert

A cost-budget warning or hard-limit crossing (CH-06). Emitted when CostBudgetTracker::record returns Warning/Exceeded for any scope (run/task/session/agent/global) with a configured limit.

Fields

run_id: String

scope: String

run | task | session | agent | global.

scope_id: String

spent_usd: f64

limit_usd: f64

exceeded: bool

true for a hard-limit crossing, false for the warning threshold.

MemoryMutation

A memory was created, updated, or deleted — either by an LLM tool call or by auto-capture.

Fields

run_id: String

operation: String

“created” | “updated” | “deleted”

memory_id: String

The record ID of the affected memory (e.g. “memory:abc123”). Empty if unavailable.

content: String

Content of the memory at time of mutation (empty for deletions).

scope: String

Scope label: “session” | “user” | “agent” | “global” | “task”

memory_type: String

Cognitive type: “semantic” | “episodic” | “procedural” | “associative”

ArtifactDisplay

An agent produced a displayable artifact (code block, document, chart, etc.). This is also used for artifact_type = "display" UI surfaces. Emitted as agui.artifact on the SSE stream.

Fields

run_id: String

artifact: ArtifactPayload

ArtifactInputRequest

An agent needs structured input from the user before it can continue. The artifact field carries the JSON Schema of the input form. The agent run is paused until the user submits a response via POST /api/uar/runs/{run_id}/artifact-response. Emitted as agui.artifact_input_request on the SSE stream.

Fields

run_id: String

artifact: ArtifactPayload

ToolCallApprovalRequired

A tool call requires user approval before execution. The run is paused until the user responds via the approval endpoint.

Fields

run_id: String

approval_id: Option<String>

Host-issued request identity; required when resolving child approvals.

call_index: usize

tool_call_id: String

name: String

arguments_json: String

risk_reason: String

ToolCallDenied

A governance policy denied a tool call. This is terminal for the call and must never create a human approval request.

Fields

run_id: String

call_index: usize

tool_call_id: String

name: String

reason: String

RunDoneWithUsage

A run completed. Optionally carries token usage and cost estimates when the persistence layer or LLM provider reports them.

Fields

run_id: String

input_tokens: Option<u32>

output_tokens: Option<u32>

total_tokens: Option<u32>

cost_usd_estimate: Option<f64>

Estimated cost in USD based on model pricing.

model: Option<String>

Model used for this run.

Trait Implementations

impl Clone for NormalizedEvent

fn clone(&self) -> NormalizedEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NormalizedEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NormalizedEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for NormalizedEvent

fn eq(&self, other: &NormalizedEvent) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for NormalizedEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for NormalizedEvent