Enum MemoryGraphEvent 

pub enum MemoryGraphEvent {
    NodeCreated {
        node_id: NodeId,
        node_type: NodeType,
        session_id: Option<SessionId>,
        timestamp: DateTime<Utc>,
        metadata: HashMap<String, String>,
    },
    EdgeCreated {
        edge_id: EdgeId,
        edge_type: EdgeType,
        from: NodeId,
        to: NodeId,
        timestamp: DateTime<Utc>,
    },
    PromptSubmitted {
        prompt_id: NodeId,
        session_id: SessionId,
        content_length: usize,
        model: String,
        timestamp: DateTime<Utc>,
    },
    ResponseGenerated {
        response_id: NodeId,
        prompt_id: NodeId,
        content_length: usize,
        tokens_used: TokenUsage,
        latency_ms: u64,
        timestamp: DateTime<Utc>,
    },
    ToolInvoked {
        tool_id: NodeId,
        tool_name: String,
        success: bool,
        duration_ms: u64,
        timestamp: DateTime<Utc>,
    },
    AgentHandoff {
        from_agent: AgentId,
        to_agent: AgentId,
        session_id: SessionId,
        reason: String,
        timestamp: DateTime<Utc>,
    },
    TemplateInstantiated {
        template_id: TemplateId,
        prompt_id: NodeId,
        version: String,
        variables: HashMap<String, String>,
        timestamp: DateTime<Utc>,
    },
    QueryExecuted {
        query_type: String,
        results_count: usize,
        duration_ms: u64,
        timestamp: DateTime<Utc>,
    },
}

Events emitted by the memory graph

Variants

NodeCreated

Node created event

Fields

node_id: NodeId

ID of the created node

node_type: NodeType

Type of node created

session_id: Option<SessionId>

Session ID (if applicable)

timestamp: DateTime<Utc>

Event timestamp

metadata: HashMap<String, String>

Additional metadata

EdgeCreated

Edge created event

Fields

edge_id: EdgeId

ID of the created edge

edge_type: EdgeType

Type of edge created

from: NodeId

Source node ID

to: NodeId

Target node ID

timestamp: DateTime<Utc>

Event timestamp

PromptSubmitted

Prompt submitted event

Fields

prompt_id: NodeId

ID of the prompt

session_id: SessionId

Session ID

content_length: usize

Length of prompt content

model: String

Model used for the prompt

timestamp: DateTime<Utc>

Event timestamp

ResponseGenerated

Response generated event

Fields

response_id: NodeId

ID of the response

prompt_id: NodeId

ID of the prompt this responds to

content_length: usize

Length of response content

tokens_used: TokenUsage

Token usage statistics

latency_ms: u64

Response generation latency in milliseconds

timestamp: DateTime<Utc>

Event timestamp

ToolInvoked

Tool invoked event

Fields

tool_id: NodeId

ID of the tool invocation

tool_name: String

Name of the tool

success: bool

Whether the tool invocation succeeded

duration_ms: u64

Tool execution duration in milliseconds

timestamp: DateTime<Utc>

Event timestamp

AgentHandoff

Agent handoff event

Fields

from_agent: AgentId

Agent transferring from

to_agent: AgentId

Agent transferring to

session_id: SessionId

Session ID

reason: String

Reason for handoff

timestamp: DateTime<Utc>

Event timestamp

TemplateInstantiated

Template instantiated event

Fields

template_id: TemplateId

Template ID

prompt_id: NodeId

Prompt ID created from template

version: String

Template version used

variables: HashMap<String, String>

Variable bindings used

timestamp: DateTime<Utc>

Event timestamp

QueryExecuted

Query executed event

Fields

query_type: String

Type of query executed

results_count: usize

Number of results returned

duration_ms: u64

Query execution duration in milliseconds

timestamp: DateTime<Utc>

Event timestamp

Implementations

impl MemoryGraphEvent

pub fn key(&self) -> String

Get a unique key for this event (for Kafka partitioning)

pub fn event_type(&self) -> &'static str

Get the event type name

pub fn timestamp(&self) -> DateTime<Utc>

Get the timestamp of this event

Trait Implementations

impl Clone for MemoryGraphEvent

fn clone(&self) -> MemoryGraphEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemoryGraphEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MemoryGraphEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MemoryGraphEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.