Struct IngestionEvent 

pub struct IngestionEvent {
    pub id: String,
    pub kind: EventKind,
    pub timestamp: String,
    pub body: Value,
}

A single event envelope. type is the oneOf discriminator; body varies by type.

Uses a flat kind (mapped to "type") + generic body: serde_json::Value instead of an enum variant per type: the projector constructs the body JSON as needed, and the model layer only wraps the envelope. This way, adding new fields does not require changes to the model layer.

Fields

id: String

Envelope ID, unique per request — Langfuse uses it for deduplication.

kind: EventKind

A discriminant string for the event type, e.g. trace-create / generation-create.

timestamp: String

Timestamp when the event was produced (ISO-8601 / RFC3339).

body: Value

Type-specific payload. body.id is the trace or observation id being operated on.

Implementations

impl IngestionEvent

pub fn trace( envelope_id: String, timestamp: String, kind: EventKind, body: &TraceBody, ) -> Self

Wraps a trace event.

pub fn observation( envelope_id: String, timestamp: String, kind: EventKind, body: &ObservationBody, ) -> Self

Wrap an observation event (generation / span / event).

Trait Implementations

impl Clone for IngestionEvent

fn clone(&self) -> IngestionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for IngestionEvent

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

Formats the value using the given formatter.

impl Serialize for IngestionEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.