Enum SubscriptionUpdate 

pub enum SubscriptionUpdate {
    Full {
        subscription_id: SubscriptionId,
        rows: Vec<Row>,
    },
    Delta {
        subscription_id: SubscriptionId,
        inserts: Vec<Row>,
        updates: Vec<(Row, Row)>,
        deletes: Vec<Row>,
    },
    Error {
        subscription_id: SubscriptionId,
        message: String,
    },
    Partial {
        subscription_id: SubscriptionId,
        updates: Vec<PartialRowDelta>,
    },
}

Update notification sent to subscribers

When a subscription’s results change, an update is sent through the subscription’s notification channel.

Variants

Full

Full result set (initial subscription or major change)

Contains all rows matching the query. This is sent when:

• A new subscription is created (initial results)
• The results have changed and delta calculation isn’t available

Fields

subscription_id: SubscriptionId

The subscription ID this update is for

rows: Vec<Row>

All rows in the result set

Delta

Incremental delta update

Contains only the changes since the last update. More efficient for large result sets with small changes. Sent when the change can be expressed as a set of inserts, updates, and deletes.

Fields

subscription_id: SubscriptionId

The subscription ID this update is for

inserts: Vec<Row>

Newly inserted rows (in new result, not in previous)

updates: Vec<(Row, Row)>

Updated rows (old value, new value) - rows with same identity but different content

deletes: Vec<Row>

Deleted rows (in previous result, not in new)

Error

Query execution error

Sent when the subscription query fails to execute, typically due to schema changes that invalidate the query.

Fields

subscription_id: SubscriptionId

The subscription ID this update is for

message: String

Error message describing what went wrong

Partial

Partial row updates (selective column updates)

Sent when a subscription is eligible for selective column updates and only a subset of columns have changed. Contains only the changed columns plus the primary key columns, reducing bandwidth for wide tables.

This is more efficient than Delta for tables with many columns where only a few columns change at a time.

Fields

subscription_id: SubscriptionId

The subscription ID this update is for

updates: Vec<PartialRowDelta>

Partial row updates, each containing only changed columns + PK columns

Implementations

impl SubscriptionUpdate

pub fn subscription_id(&self) -> SubscriptionId

Get the subscription ID this update is for

Trait Implementations

impl Clone for SubscriptionUpdate

fn clone(&self) -> SubscriptionUpdate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionUpdate

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

Formats the value using the given formatter.