Struct SubscriptionEvent 

pub struct SubscriptionEvent {
    pub event_id: String,
    pub entity_type: String,
    pub entity_id: String,
    pub operation: SubscriptionOperation,
    pub timestamp: DateTime<Utc>,
    pub sequence_number: u64,
    pub data: Value,
    pub old_data: Option<Value>,
    pub tenant_id: Option<String>,
    pub change_spine: Option<ChangeSpineEnvelope>,
}

An event from the database that may trigger subscriptions.

This is the internal event format, captured from LISTEN/NOTIFY or CDC.

Fields

event_id: String

Unique event identifier.

entity_type: String

Entity type name (e.g., “Order”, “User”).

entity_id: String

Entity primary key.

operation: SubscriptionOperation

Database operation that created this event.

timestamp: DateTime<Utc>

Event timestamp (from database).

sequence_number: u64

Monotonic sequence number for ordering.

data: Value

Event payload data (the row data as JSON).

old_data: Option<Value>

Optional old data (for UPDATE operations).

tenant_id: Option<String>

Tenant identifier for multi-tenant isolation (from fk_customer_org).

change_spine: Option<ChangeSpineEnvelope>

Change-Spine envelope metadata for client delivery (#425). Carried for the subscription next payload’s extensions.changeSpine; not used for server-side filtering.

Implementations

impl SubscriptionEvent

pub fn new( entity_type: impl Into<String>, entity_id: impl Into<String>, operation: SubscriptionOperation, data: Value, ) -> Self

Create a new subscription event.

pub fn with_old_data(self, old_data: Value) -> Self

Add old data for UPDATE operations.

pub const fn with_sequence(self, seq: u64) -> Self

Set the sequence number.

pub fn with_tenant_id(self, tenant_id: impl Into<String>) -> Self

Set the tenant identifier for multi-tenant filtering.

pub fn with_change_spine(self, envelope: ChangeSpineEnvelope) -> Self

Attach the Change-Spine envelope for client delivery (#425).

Trait Implementations

impl Clone for SubscriptionEvent

fn clone(&self) -> SubscriptionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscriptionEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SubscriptionEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.