Struct OutboxRecord 

pub struct OutboxRecord {
    pub id: Uuid,
    pub event_type: String,
    pub aggregate_type: String,
    pub aggregate_id: String,
    pub company_id: Uuid,
    pub payload: Value,
    pub occurred_at: DateTime<Utc>,
    pub correlation_id: Option<String>,
    pub causation_id: Option<String>,
    pub version: i32,
}

A serialized domain event staged in the outbox and carried to consumers.

The id is the single end-to-end dedup key (the backbone-messaging envelope id): the producer stages it, the relay carries it, the consumer dedups on it via crate::inbox::once.

Fields

id: Uuid

The event id — the dedup key. Take it from the messaging EventEnvelope::id.

event_type: String

The event type name, e.g. "PaymentSettled".

aggregate_type: String

The aggregate type the event belongs to, e.g. "Payment".

aggregate_id: String

The aggregate id (as a string — aggregates key on uuid, code, or number).

company_id: Uuid

The owning tenant — the outbox_events table is fenced by this (ADR-0011). Every staged event carries the company it belongs to so the RLS policy can isolate tenant event streams.

payload: Value

The serialized domain event payload.

occurred_at: DateTime<Utc>

When the event occurred in the domain.

correlation_id: Option<String>

Correlation id for tracing a business flow across events.

causation_id: Option<String>

Causation id (the parent event that caused this one).

version: i32

Event schema version (see extension-contract.md §4).

Implementations

impl OutboxRecord

pub fn new( event_type: impl Into<String>, aggregate_type: impl Into<String>, aggregate_id: impl Into<String>, company_id: Uuid, payload: Value, occurred_at: DateTime<Utc>, ) -> Self

Build a record with a fresh id, no correlation/causation, version 1, occurred_at = now. (now is passed in so callers stay deterministic under test.) company_id is the owning tenant — required, since the outbox_events table is fenced by it (ADR-0011).

pub fn with_id(self, id: Uuid) -> Self

Set the event id explicitly (e.g. reuse the messaging envelope id).

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

Set the correlation id.

Trait Implementations

impl Clone for OutboxRecord

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutboxRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OutboxRecord

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for OutboxRecord

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for OutboxRecord

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 OutboxRecord