Struct EventRequest 

pub struct EventRequest {
    pub event_type: String,
    pub ts: DateTime<Utc>,
    pub session_id: SessionId,
    pub context: EventContext,
    pub data: EventData,
    pub metadata: Option<Value>,
    pub tags: Option<Vec<String>>,
}

Request to create a new event.

This is the input type for event ingestion. It contains all the data needed to create an event, but without the id and sequence fields which are assigned by the storage layer.

Fields

event_type: String

Event type in dot notation

ts: DateTime<Utc>

Event timestamp

session_id: SessionId

Session this event belongs to

context: EventContext

Correlation context

data: EventData

Event-specific payload

metadata: Option<Value>

Arbitrary metadata for the event

tags: Option<Vec<String>>

Tags for filtering and categorization

Implementations

impl EventRequest

pub fn new( session_id: SessionId, context: EventContext, data: impl Into<EventData>, ) -> Self

Create a new event request with the given session_id, context, and typed data

The event type is automatically inferred from the data type.

pub fn with_metadata(self, metadata: Value) -> Self

Set metadata

pub fn with_tags(self, tags: Vec<String>) -> Self

Set tags

pub fn is_ephemeral(&self) -> bool

Whether this event is ephemeral (high-frequency streaming deltas that don’t need durable storage). Delivery backends that support ephemeral routing can publish these events without inserting them into PostgreSQL.

The authoritative content lives in the corresponding “completed” event (e.g. output.message.completed has the full text), so missing a delta on reconnect is acceptable.

pub fn into_event(self, id: EventId, sequence: i32) -> Event

Convert to an Event with the given id and sequence

Trait Implementations

impl Clone for EventRequest

fn clone(&self) -> EventRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventRequest

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EventRequest

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

where __S: Serializer,

Serialize this value into the given Serde serializer.