Struct Event 

pub struct Event {
    pub id: Ulid,
    pub aggregator_id: String,
    pub aggregator_type: String,
    pub version: u16,
    pub name: String,
    pub routing_key: Option<String>,
    pub data: Vec<u8>,
    pub metadata: Metadata,
    pub timestamp: u64,
    pub timestamp_subsec: u32,
}

A stored event in the event store.

Events are immutable records of facts that occurred in your domain. They contain serialized data and metadata, along with positioning information for the aggregate they belong to.

Fields

• id - Unique event identifier (ULID format for time-ordering)
• aggregator_id - The aggregate instance this event belongs to
• aggregator_type - Type name like "myapp/BankAccount"
• version - Sequence number within the aggregate (for optimistic concurrency)
• name - Event type name like "AccountOpened"
• routing_key - Optional key for event distribution/partitioning
• data - Serialized event payload (bitcode format)
• metadata - Event metadata (see metadata::Metadata)
• timestamp - When the event occurred (Unix seconds)
• timestamp_subsec - Sub-second precision (milliseconds)

Serialization

Event data is serialized using bitcode for compact binary representation. Use metadata::Event to deserialize typed events.

Fields

id: Ulid

Unique event identifier (ULID)

aggregator_id: String

ID of the aggregate this event belongs to

aggregator_type: String

Type name of the aggregate (e.g., “myapp/User”)

version: u16

Version number of the aggregate after this event

name: String

Event type name

routing_key: Option<String>

Optional routing key for event distribution

data: Vec<u8>

Serialized event data (bitcode format)

metadata: Metadata

Event metadata

timestamp: u64

Unix timestamp when the event occurred (seconds)

timestamp_subsec: u32

Sub-second precision (milliseconds)

Trait Implementations

impl Bind for Event

type T = Event

The item type being paginated

fn sort_by(data: &mut Vec<Self::T>, is_order_desc: bool)

Sorts items in ascending or descending order.

fn retain( data: &mut Vec<Self::T>, cursor: <<Self as Bind>::T as Cursor>::T, is_order_desc: bool, )

Retains only items after/before the cursor position.

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Cursor for Event

type T = EventCursor

The cursor data type (e.g., EventCursor)

fn serialize(&self) -> Self::T

Extracts cursor data from this item.

fn serialize_cursor(&self) -> Result<Value, CursorError>

Serializes cursor data to a base64 Value.

fn deserialize_cursor(value: &Value) -> Result<Self::T, CursorError>

Deserializes cursor data from a base64 Value.

impl Debug for Event

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

Formats the value using the given formatter.

impl Default for Event

fn default() -> Event

Returns the “default value” for a type.

impl PartialEq for Event

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<D> TryFrom<&Event> for Event<D>

where D: DecodeOwned,

type Error = Error

The type returned in the event of a conversion error.

fn try_from(value: &Event) -> Result<Self, Self::Error>

Performs the conversion.

impl StructuralPartialEq for Event