Trait IntegrationEvent

Source

pub trait IntegrationEvent:
    Clone
    + Send
    + Sync
    + Serialize
    + for<'de> Deserialize<'de>
    + 'static {
    // Required methods
    fn event_type(&self) -> &'static str;
    fn source_context(&self) -> &'static str;
    fn aggregate_id(&self) -> &str;
    fn occurred_at(&self) -> DateTime<Utc>;

    // Provided methods
    fn version(&self) -> u32 { ... }
    fn correlation_id(&self) -> Option<&str> { ... }
}

Expand description

Trait for integration events that cross bounded context boundaries

Integration events are serializable and contain only primitive/common types to avoid coupling between modules. They follow a naming convention: {source_context}.{aggregate}.{action} (e.g., “sapiens.user.created”)

§Implementation Requirements

Must be Clone + Send + Sync + 'static for async handling
Must implement Serialize + Deserialize for JSON transport
Should only use primitive types (String, numbers, booleans)
Event type should follow dot-notation naming

§Example

impl IntegrationEvent for UserCreatedEvent {
    fn event_type(&self) -> &'static str { "sapiens.user.created" }
    fn source_context(&self) -> &'static str { "sapiens" }
    fn aggregate_id(&self) -> &str { &self.user_id }
    fn occurred_at(&self) -> DateTime<Utc> { self.occurred_at }
}