Struct Event 

pub struct Event<PT> {
    pub id: EventId,
    pub idempotency_token: Option<IdempotencyToken>,
    pub event_type: EventType,
    pub payload: Payload<PT>,
    pub created_at: OffsetDateTime,
    pub locked_until: OffsetDateTime,
    pub status: EventStatus,
}

A single outbox row representing one domain event to be published.

An event starts out with status set to EventStatus::Pending and travels through the worker loop: a worker flips the row to EventStatus::Processing with a lock until locked_until, publishes via the transport, and finally marks it EventStatus::Sent. If a worker crashes, the lock expires and the row becomes eligible again.

Generic over the user’s payload type PT; see Payload.

Fields

id: EventId

Randomly generated primary key (UUID v4). Used to identify the row across status transitions.

idempotency_token: Option<IdempotencyToken>

Deduplication token produced according to the configured IdempotencyStrategy. May be None when no token is produced.

event_type: EventType

Domain-level event name used for routing on the transport side.

payload: Payload<PT>

The user payload, serialized as JSON when the sqlx feature is on.

created_at: OffsetDateTime

Wall-clock time the row was constructed, in UTC.

locked_until: OffsetDateTime

Expiration of the current processing lock. Fresh rows start with OffsetDateTime::UNIX_EPOCH (i.e. “not locked”); storage adapters update this when they claim the row for processing.

status: EventStatus

Current lifecycle stage. See EventStatus.

Implementations

impl<PT> Event<PT>

where PT: Debug + Clone + Serialize,

pub fn new( event_type: EventType, payload: Payload<PT>, idempotency_token: Option<IdempotencyToken>, ) -> Self

Constructs a new Event ready to be inserted by the storage layer.

The caller supplies the domain-level fields (event_type, payload, idempotency_token); the remaining fields are initialised with sensible defaults:

• id — a fresh random EventId
• created_at — OffsetDateTime::now_utc()
• locked_until — OffsetDateTime::UNIX_EPOCH (unlocked)
• status — EventStatus::Pending

Trait Implementations

impl<PT: Clone> Clone for Event<PT>

fn clone(&self) -> Event<PT>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<PT: Debug> Debug for Event<PT>

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

Formats the value using the given formatter.

impl<'a, R: Row, PT> FromRow<'a, R> for Event<PT>

where &'a str: ColumnIndex<R>, EventId: Decode<'a, R::Database> + Type<R::Database>, Option<IdempotencyToken>: Decode<'a, R::Database> + Type<R::Database>, EventType: Decode<'a, R::Database> + Type<R::Database>, Json<Payload<PT>>: Decode<'a, R::Database> + Type<R::Database>, OffsetDateTime: Decode<'a, R::Database> + Type<R::Database>, EventStatus: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(__row: &'a R) -> Result<Self>