Struct EventRecord 

pub struct EventRecord {

    pub event_id: EventId,
    pub session_id: SessionId,
    pub agent_id: AgentId,
    pub branch_id: BranchId,
    pub sequence: SeqNo,
    pub timestamp: DateTime<Utc>,
    pub actor: EventActor,
    pub schema: EventSchema,
    pub causation_id: Option<EventId>,
    pub correlation_id: Option<String>,
    pub trace_id: Option<String>,
    pub span_id: Option<String>,
    pub digest: Option<String>,
    pub kind: EventKind,
}

Convenience event record using chrono::DateTime<Utc> timestamps.

This is the type used by aiOS internal crates. It maps to EventEnvelope for storage/streaming but uses ergonomic Rust types for construction.

Fields

event_id: EventId

session_id: SessionId

agent_id: AgentId

branch_id: BranchId

sequence: SeqNo

timestamp: DateTime<Utc>

actor: EventActor

schema: EventSchema

causation_id: Option<EventId>

correlation_id: Option<String>

trace_id: Option<String>

span_id: Option<String>

digest: Option<String>

kind: EventKind

Implementations

impl EventRecord

pub fn new( session_id: SessionId, branch_id: BranchId, sequence: SeqNo, kind: EventKind, ) -> Self

Create a new event record with the current timestamp.

pub fn to_envelope(&self) -> EventEnvelope

Convert to the canonical EventEnvelope for storage/streaming.

Trait Implementations

impl Clone for EventRecord

fn clone(&self) -> EventRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EventRecord

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

where __S: Serializer,

Serialize this value into the given Serde serializer.