Enum HiveEvent 

pub enum HiveEvent {
    AgentStarted {
        timestamp_ms: u64,
        agent_id: String,
        name: String,
        kind: AgentKindTag,
    },
    AgentCompleted {
        timestamp_ms: u64,
        agent_id: String,
        outcome: AgentOutcome,
    },
    LlmCallStarted {
        timestamp_ms: u64,
        agent_id: String,
        model: String,
        message_count: usize,
    },
    LlmCallCompleted {
        timestamp_ms: u64,
        agent_id: String,
        model: String,
        duration_ms: u64,
        input_tokens: u32,
        output_tokens: u32,
    },
    LlmTokenStreamed {
        timestamp_ms: u64,
        agent_id: String,
        token: String,
    },
    ToolCallStarted {
        timestamp_ms: u64,
        agent_id: String,
        tool_name: String,
        params: String,
    },
    ToolCallCompleted {
        timestamp_ms: u64,
        agent_id: String,
        tool_name: String,
        duration_ms: u64,
        result_preview: String,
    },
    ToolApprovalRequested {
        timestamp_ms: u64,
        agent_id: String,
        tool_name: String,
        description: String,
    },
    ExperienceRecorded {
        timestamp_ms: u64,
        experience_id: ExperienceId,
        agent_id: String,
        content_preview: String,
        experience_type: String,
        importance: f32,
    },
    RelationshipInferred {
        timestamp_ms: u64,
        relation_id: RelationId,
        agent_id: String,
    },
    InsightGenerated {
        timestamp_ms: u64,
        insight_id: InsightId,
        source_count: usize,
        agent_id: String,
    },
    SubstratePerceived {
        timestamp_ms: u64,
        agent_id: String,
        experience_count: usize,
        insight_count: usize,
    },
    EmbeddingComputed {
        timestamp_ms: u64,
        agent_id: String,
        dimensions: usize,
        duration_ms: u64,
    },
    WatchNotification {
        timestamp_ms: u64,
        experience_id: ExperienceId,
        collective_id: CollectiveId,
        event_type: String,
    },
}

Events emitted during agent execution.

Covers the full lifecycle: agent start/stop, LLM calls, tool execution, substrate operations, and perception. All variants include timestamp_ms (epoch milliseconds) and agent_id where applicable for correlation.

Serializes to tagged JSON: {"type": "llm_call_completed", "agent_id": "...", ...}

Must be Clone because EventEmitter uses tokio::sync::broadcast which requires cloneable values.

Variants

AgentStarted

An agent has started execution.

Fields

timestamp_ms: u64

agent_id: String

name: String

kind: AgentKindTag

AgentCompleted

An agent has completed execution.

Fields

timestamp_ms: u64

agent_id: String

outcome: AgentOutcome

LlmCallStarted

An LLM call has been initiated.

Fields

timestamp_ms: u64

agent_id: String

model: String

message_count: usize

LlmCallCompleted

An LLM call has completed.

Fields

timestamp_ms: u64

agent_id: String

model: String

duration_ms: u64

input_tokens: u32

Prompt tokens consumed (0 if not reported by provider).

output_tokens: u32

Completion tokens generated (0 if not reported by provider).

LlmTokenStreamed

A token was received from a streaming LLM response.

Fields

timestamp_ms: u64

agent_id: String

token: String

ToolCallStarted

A tool call has started.

Fields

timestamp_ms: u64

agent_id: String

tool_name: String

params: String

Tool arguments as a JSON string.

ToolCallCompleted

A tool call has completed.

Fields

timestamp_ms: u64

agent_id: String

tool_name: String

duration_ms: u64

result_preview: String

Tool result preview (truncated to 200 chars).

ToolApprovalRequested

A tool requires human approval before execution.

Fields

timestamp_ms: u64

agent_id: String

tool_name: String

description: String

ExperienceRecorded

An experience was recorded in the substrate.

Fields

timestamp_ms: u64

experience_id: ExperienceId

agent_id: String

content_preview: String

First 200 characters of the experience content.

experience_type: String

Experience type as a string (e.g., “Generic”, “Solution”).

importance: f32

Importance score (0.0-1.0).

RelationshipInferred

A relationship was inferred between experiences.

Fields

timestamp_ms: u64

relation_id: RelationId

agent_id: String

Agent that triggered the inference.

InsightGenerated

An insight was synthesized from an experience cluster.

Fields

timestamp_ms: u64

insight_id: InsightId

source_count: usize

agent_id: String

Agent that triggered the synthesis.

SubstratePerceived

An agent perceived the substrate through its lens.

Fields

timestamp_ms: u64

agent_id: String

experience_count: usize

insight_count: usize

EmbeddingComputed

An embedding was computed via the EmbeddingProvider.

Fields

timestamp_ms: u64

agent_id: String

dimensions: usize

duration_ms: u64

WatchNotification

A real-time Watch event from the substrate.

Emitted when experiences are created, updated, archived, or deleted by other agents in the same collective. Forwarded from PulseDB’s Watch system into the HiveEvent stream.

Fields

timestamp_ms: u64

experience_id: ExperienceId

collective_id: CollectiveId

event_type: String

The type of change: “Created”, “Updated”, “Archived”, or “Deleted”.

Trait Implementations

impl Clone for HiveEvent

fn clone(&self) -> HiveEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HiveEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HiveEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for HiveEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.