Struct TelemetryEvent 

pub struct TelemetryEvent {
    pub session_id: Option<String>,
    pub node_id: String,
    pub packet: CustomPacketData,
}

A telemetry event emitted by a node.

This wraps CustomPacketData to maintain wire-compatibility with the packet system, enabling future “telemetry as track” patterns where events flow through the graph.

Field Locations

• session_id, node_id: Envelope fields (not duplicated in packet data)
• event_type, correlation_id, turn_id: Inside packet.data
• timestamp_us: Inside packet.metadata

Fields

session_id: Option<String>

Session this event belongs to (for future shared bus / cross-session sinks)

node_id: String

The node that emitted this event (canonical source, not in packet data)

packet: CustomPacketData

The telemetry payload wrapped as a Custom packet for wire compatibility

Implementations

impl TelemetryEvent

pub fn new( session_id: Option<String>, node_id: String, event_data: JsonValue, timestamp_us: u64, ) -> Self

Create a new telemetry event.

The event_data should contain at minimum event_type. Additional fields like correlation_id, turn_id, and event-specific data can be included.

pub fn event_type(&self) -> Option<&str>

Extract the event_type from the packet data.

pub fn correlation_id(&self) -> Option<&str>

Extract the correlation_id from the packet data.

pub fn turn_id(&self) -> Option<&str>

Extract the turn_id from the packet data.

pub fn timestamp_us(&self) -> Option<u64>

Get the timestamp in microseconds.

Trait Implementations

impl Clone for TelemetryEvent

fn clone(&self) -> TelemetryEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetryEvent

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

Formats the value using the given formatter.