Enum KernelEvent 

pub enum KernelEvent {
    AgentCreated {
        id: AgentId,
        name: String,
    },
    AgentStarted {
        id: AgentId,
    },
    AgentStopped {
        id: AgentId,
        success: bool,
    },
    AgentFailed {
        id: AgentId,
        error: String,
    },
    MessageReceived {
        from: AgentId,
        content: String,
    },
    AgentOutput {
        session_id: String,
        agent_id: AgentId,
        output: String,
    },
    ApprovalRequested {
        id: Uuid,
        tool_name: String,
        action: String,
        resource: String,
        reason: String,
        session_id: Option<String>,
    },
    ApprovalResolved {
        id: Uuid,
        approved: bool,
    },
    MemoryStored {
        id: String,
        memory_type: String,
        source: String,
    },
    MemoryRecalled {
        query: String,
        count: usize,
    },
    AgentGroupCreated {
        group_id: Uuid,
        agent_count: usize,
    },
    AgentGroupMemberCompleted {
        group_id: Uuid,
        agent_id: Uuid,
        success: bool,
    },
    ProjectCreated {
        project_id: Uuid,
        name: String,
        source: String,
    },
    ProjectActivated {
        project_id: Uuid,
        name: String,
    },
    ToolExecutionStarted {
        session_id: String,
        tool_name: String,
        tool_call_id: String,
        tool_args: Value,
        context: Option<Value>,
    },
    ToolExecutionFinished {
        session_id: String,
        tool_call_id: String,
        tool_name: String,
        duration_ms: u64,
        is_error: bool,
        output_summary: String,
    },
    ToolExecutionProgress {
        session_id: String,
        tool_call_id: String,
        tool_name: String,
        progress: String,
        tab_id: Option<Uuid>,
        context: Option<Value>,
    },
    MemoryRecallUsed {
        session_id: String,
        query: String,
        count: usize,
        source: String,
    },
    TokenUsageUpdate {
        session_id: String,
        input_tokens: u64,
        output_tokens: u64,
    },
    ReasoningFragment {
        session_id: String,
        content: String,
        source: String,
    },
    CompactionTriggered {
        session_id: Option<String>,
        source: String,
    },
    PhaseStarted {
        session_id: String,
        phase: String,
        summary: Option<String>,
    },
    PhaseCompleted {
        session_id: String,
        phase: String,
    },
    CalendarEventCreated {
        uid: String,
        title: String,
        start: String,
        end: String,
    },
    CalendarEventUpdated {
        uid: String,
        title: String,
    },
    CalendarEventDeleted {
        uid: String,
        title: String,
    },
    EmailSent {
        subject: String,
        message_id: String,
        template_name: Option<String>,
    },
    KnowledgePersisted {
        session_id: String,
        message_index: usize,
        path: String,
        source: String,
    },
    KnowledgeRemoved {
        session_id: String,
        message_index: usize,
    },
    AskUserRequest {
        id: String,
        question: String,
        options: Vec<String>,
    },
    PersonaCreated {
        id: String,
        name: String,
        enabled: bool,
        source: String,
    },
    PersonaUpdated {
        id: String,
        name: String,
        source: String,
    },
}

Events that flow through the kernel event bus.

Variants

AgentCreated

A new agent has been created.

Fields

id: AgentId

The new agent’s ID.

name: String

The agent’s name/goal.

AgentStarted

An agent has started executing.

Fields

id: AgentId

The agent’s ID.

AgentStopped

An agent has been stopped.

Carries success so consumers can distinguish a normal completion (success: true) from an evaluation/assessment failure (success: false). Infrastructure errors (panic, timeout) emit AgentFailed instead.

Fields

id: AgentId

The agent’s ID.

success: bool

Whether the agent’s result passed evaluation. Mirrors ExecutionResult.success from the Ok path; false on the kill/terminate path (user-initiated stop).

AgentFailed

An agent has encountered a failure.

Fields

id: AgentId

The agent’s ID.

error: String

Description of the error.

MessageReceived

A message has been received from an agent.

Fields

from: AgentId

The sending agent’s ID.

content: String

Message content.

AgentOutput

An agent has produced output.

Fields

session_id: String

The session this output belongs to.

agent_id: AgentId

The agent’s ID.

output: String

The output content.

ApprovalRequested

A HitL approval request has been submitted.

Fields

id: Uuid

The approval request ID.

tool_name: String

The tool requesting approval.

action: String

The action requiring approval.

resource: String

The resource involved.

reason: String

Reason for the request.

session_id: Option<String>

The session ID that triggered this request.

ApprovalResolved

A HitL approval has been resolved (approved or rejected).

Fields

id: Uuid

The approval request ID.

approved: bool

Whether it was approved (true) or rejected (false).

MemoryStored

A memory entry was stored.

Fields

id: String

Memory entry ID.

memory_type: String

Memory type label.

source: String

Source of the memory.

MemoryRecalled

Memories were recalled for a new session.

Fields

query: String

The recall query.

count: usize

Number of memories returned.

AgentGroupCreated

Multi-agent group created.

Fields

group_id: Uuid

The group’s ID.

agent_count: usize

Number of agents in the group.

AgentGroupMemberCompleted

An agent in a group completed.

Fields

group_id: Uuid

The group’s ID.

agent_id: Uuid

The agent’s ID.

success: bool

Whether the agent succeeded.

ProjectCreated

A new Project has been created (RFC-011).

Fields

project_id: Uuid

The project’s ID.

name: String

The project’s name.

source: String

How it was created.

ProjectActivated

A Project has been activated (RFC-011).

Fields

project_id: Uuid

The project’s ID.

name: String

The project’s name.

ToolExecutionStarted

A tool execution has started (real-time, RFC-015).

Fields

session_id: String

Session this tool call belongs to.

tool_name: String

Name of the tool (e.g. “read_file”, “bash”, “memory_recall”).

tool_call_id: String

Provider-specific tool call ID used to correlate start/end.

tool_args: Value

Tool input arguments (JSON).

context: Option<Value>

Semantic context inferred by oxi-agent 0.32+ from tool name/args (e.g. WebSearch, PageVisit). None for tools without context mapping.

ToolExecutionFinished

A tool execution has finished (real-time, RFC-015).

Fields

session_id: String

Session this tool call belongs to.

tool_call_id: String

Provider-specific tool call ID.

tool_name: String

Name of the tool.

duration_ms: u64

Wall-clock duration in milliseconds.

is_error: bool

Whether the tool returned an error.

output_summary: String

Truncated output (max ~500 chars) for streaming.

ToolExecutionProgress

A tool execution emitted a progress update (real-time, RFC-015).

Fields

session_id: String

Session this tool call belongs to.

tool_call_id: String

Provider-specific tool call ID.

tool_name: String

Name of the tool.

progress: String

Human-readable progress text (already-formatted by the tool).

tab_id: Option<Uuid>

Tab that emitted this progress event, if the upstream tool tracks tabs. None for tools that don’t have a tab concept (e.g. legacy oxi-agent versions that don’t propagate tab_id).

context: Option<Value>

Semantic context from the tool call (e.g. PageVisit, WebSearch). Stored as serde_json::Value to decouple kernel events from oxi-sdk’s internal ToolCallContext enum. UI consumers that understand a context variant render it richly; older consumers simply ignore the field.

MemoryRecallUsed

Memory was recalled during agent execution (RFC-015).

Fields

session_id: String

Session this recall belongs to.

query: String

The recall query.

count: usize

Number of memories returned.

source: String

Memory tier source (“hot” | “warm” | “cold”).

TokenUsageUpdate

Token usage update (RFC-015).

Fields

session_id: String

Session this usage belongs to.

input_tokens: u64

Cumulative input tokens.

output_tokens: u64

Cumulative output tokens.

ReasoningFragment

Reasoning/compaction fragment (RFC-015).

Fields

session_id: String

Session this fragment belongs to.

content: String

The fragment text (chain-of-thought, compaction summary, etc).

source: String

Source label: “chain_of_thought” | “compaction” | “reflection”.

CompactionTriggered

Compaction was triggered (RFC-035 gap 2 observability).

Emitted when oxi_sdk::CompactionEvent::Triggered fires (0.53.0+). source is one of:

• "provider-reported" — provider-reported usage.input_tokens drove the trigger (ground truth; gap 2’s primary signal)
• "bytes/4 heuristic (cold start)" — legacy heuristic; only on turn 1 before any ProviderEvent::Done has been observed
• "empty" — empty context (no trigger source)

Fields

session_id: Option<String>

Session this compaction belongs to.

source: String

The trigger source label from CompactionEvent::Triggered::source.

PhaseStarted

A lifecycle phase has begun.

Fields

session_id: String

Session this phase belongs to.

phase: String

Phase name: "assess" | "plan" (crystallize) | "execute" | "review".

summary: Option<String>

Optional human-readable summary for the timeline header.

PhaseCompleted

A lifecycle phase has completed.

Fields

session_id: String

Session this phase belongs to.

phase: String

Phase name — same vocabulary as PhaseStarted::phase.

CalendarEventCreated

A calendar event was created.

Fields

uid: String

Event UID.

title: String

Event title.

start: String

Start time.

end: String

End time.

CalendarEventUpdated

A calendar event was updated.

Fields

uid: String

Event UID.

title: String

Event title.

CalendarEventDeleted

A calendar event was deleted.

Fields

uid: String

Event UID.

title: String

Event title.

EmailSent

An email has been sent.

Fields

subject: String

Email subject.

message_id: String

SMTP message ID.

template_name: Option<String>

Template name (if template was used/saved).

KnowledgePersisted

A knowledge note was persisted (hook, user, or tool).

Fields

session_id: String

message_index: usize

path: String

source: String

KnowledgeRemoved

A knowledge note was removed by user action.

Fields

session_id: String

message_index: usize

AskUserRequest

A question was posed to the user by the agent (RFC-027, ask_user). The frontend renders an input/option picker and resolves the pending oneshot via a separate response endpoint.

Fields

id: String

Unique request ID — used by the response handler to resolve the oneshot the tool is awaiting.

question: String

The question text the user sees.

options: Vec<String>

Optional structured options. Empty when the question is open-ended.

PersonaCreated

A persona was created (by an agent tool, the HTTP API, or the UI).

Fields

id: String

Persona ID.

name: String

Persona display name.

enabled: bool

Whether it was registered enabled.

source: String

Origin of the change: “agent” | “api” | “ui”.

PersonaUpdated

A persona was updated.

Fields

id: String

Persona ID.

name: String

Persona display name.

source: String

Origin of the change: “agent” | “api” | “ui”.

Trait Implementations

impl Clone for KernelEvent

fn clone(&self) -> KernelEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KernelEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for KernelEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for KernelEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.