Struct CommittedEvent 

pub struct CommittedEvent<E> {
    pub event_id: EventId,
    pub event_type: String,
    pub occurred_at: DateTime<Utc>,
    pub payload: E,
}

One committed domain event (spec §17.1).

Fields

event_id: EventId

Identifier in the ledger.

event_type: String

Stable event type label (e.g. "trip.extra_added").

occurred_at: DateTime<Utc>

When it was committed.

payload: E

Domain payload.

Implementations

impl<E> CommittedEvent<E>

pub fn event_ref(&self) -> EventRef

Reference without payload.

pub fn try_map_payload<F, Err>( self, f: impl FnOnce(E) -> Result<F, Err>, ) -> Result<CommittedEvent<F>, Err>

Transforms the payload.

pub fn try_map_payload_ref<F, Err>( &self, f: impl FnOnce(&E) -> Result<F, Err>, ) -> Result<CommittedEvent<F>, Err>

Transforms the payload by reference, keeping identity and timestamp.

Used at the erasure boundary, where the payload is deserialized from the borrowed JSON instead of being cloned into the typed side.

Trait Implementations

impl<E: Clone> Clone for CommittedEvent<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> Debug for CommittedEvent<E>

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

Formats the value using the given formatter.

impl<'de, E> Deserialize<'de> for CommittedEvent<E>

where E: Deserialize<'de>,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<E: Eq> Eq for CommittedEvent<E>

impl<E> From<CommittedEvent<E>> for ReceiptEvent<E>

fn from(event: CommittedEvent<E>) -> Self

Converts to this type from the input type.

impl<E: PartialEq> PartialEq for CommittedEvent<E>

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

Equality operator ==.

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

Inequality operator !=.

impl<E> Serialize for CommittedEvent<E>

where E: Serialize,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<E: PartialEq> StructuralPartialEq for CommittedEvent<E>