Struct EventEnvelope 

pub struct EventEnvelope<E: DomainEvent> {
    pub id: String,
    pub event_type: &'static str,
    pub aggregate_id: String,
    pub aggregate_type: &'static str,
    pub occurred_at: DateTime<Utc>,
    pub published_at: DateTime<Utc>,
    pub correlation_id: Option<String>,
    pub causation_id: Option<String>,
    pub version: u32,
    pub metadata: HashMap<String, String>,
    /* private fields */
}

Wrapper for domain events with metadata

EventEnvelope adds infrastructure concerns (IDs, timestamps, tracing) around domain events without polluting the domain model.

Fields

id: String

Unique event ID

event_type: &'static str

Event type name

aggregate_id: String

Aggregate ID this event belongs to

aggregate_type: &'static str

Aggregate type name

occurred_at: DateTime<Utc>

When the event occurred in the domain

published_at: DateTime<Utc>

When the event was published to the bus

correlation_id: Option<String>

Correlation ID for distributed tracing

causation_id: Option<String>

Causation ID (parent event that caused this one)

version: u32

Event schema version

metadata: HashMap<String, String>

Additional metadata

Implementations

impl<E: DomainEvent> EventEnvelope<E>

pub fn new(event: E) -> Self

Create a new event envelope from a domain event

pub fn event(&self) -> Option<&E>

Get the wrapped event

pub fn into_event(self) -> Option<E>

Take ownership of the wrapped event

pub fn with_correlation_id(self, id: impl Into<String>) -> Self

Set correlation ID for distributed tracing

pub fn with_causation_id(self, id: impl Into<String>) -> Self

Set causation ID (parent event)

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Add metadata

pub fn is_correlated_with(&self, other: &Self) -> bool

Check if this event is correlated with another

pub fn was_caused_by(&self, other: &Self) -> bool

Check if this event was caused by another

Trait Implementations

impl<E: Clone + DomainEvent> Clone for EventEnvelope<E>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug + DomainEvent> Debug for EventEnvelope<E>

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

Formats the value using the given formatter.

impl<E> Deserialize<'static> for EventEnvelope<E>

where E: Default + DomainEvent,

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

where __D: Deserializer<'static>,

Deserialize this value from the given Serde deserializer.

impl<E: DomainEvent> Serialize for EventEnvelope<E>

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

where __S: Serializer,

Serialize this value into the given Serde serializer.