Struct EventMetadata 

pub struct EventMetadata {
    pub batch_id: Uuid,
    pub pipeline_id: String,
    pub source_time: Option<SystemTime>,
    pub ingestion_time: SystemTime,
    pub source_id: ComponentId,
    pub upstream_id: Option<OutputId>,
    pub tenant_profile: Option<String>,
}

Core metadata attached to every batch of events flowing through the pipeline.

This is wrapped in an Arc when attached to an EventBatch to ensure cheap cloning during fanout operations.

Fields

batch_id: Uuid

A globally unique identifier for this specific batch. Used for end-to-end tracing of data flow.

pipeline_id: String

The ID of the pipeline this batch belongs to.

source_time: Option<SystemTime>

The time the data was originally generated at the source (if known). For example, the S3 object last-modified time, or Kafka message timestamp.

ingestion_time: SystemTime

The time the data was ingested by Kinetic’s source component.

source_id: ComponentId

The component that originally produced this batch.

upstream_id: Option<OutputId>

The specific output of the component that produced this batch. This is None until the batch actually leaves a source or transform.

tenant_profile: Option<String>

Optional tenant profile name. Used primarily by multi-tenant sources like the OTLP source to tag which tenant generated the data.

Implementations

impl EventMetadata

pub fn new(pipeline_id: impl Into<String>, source_id: ComponentId) -> Self

Creates a new EventMetadata with a random UUID and current ingestion time.

pub fn with_source_time(self, time: SystemTime) -> Self

Sets the source time (e.g., from external metadata).

pub fn with_tenant_profile(self, profile: impl Into<String>) -> Self

Sets the tenant profile.

pub fn with_upstream_id(self, upstream_id: OutputId) -> Self

Sets the upstream output ID. This is typically called by a component just before sending the batch to the next component.

Trait Implementations

impl Clone for EventMetadata

fn clone(&self) -> EventMetadata

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventMetadata

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EventMetadata

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for EventMetadata

fn eq(&self, other: &EventMetadata) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for EventMetadata

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for EventMetadata