Enum ChangeEvent 

pub enum ChangeEvent {
    Ack {
        subscription_id: String,
        total_rows: u32,
        batch_control: BatchControl,
        schema: Vec<SchemaField>,
    },
    InitialDataBatch {
        subscription_id: String,
        rows: Vec<HashMap<String, KalamCellValue>>,
        batch_control: BatchControl,
    },
    Insert {
        subscription_id: String,
        rows: Vec<HashMap<String, KalamCellValue>>,
    },
    Update {
        subscription_id: String,
        rows: Vec<HashMap<String, KalamCellValue>>,
        old_rows: Vec<HashMap<String, KalamCellValue>>,
    },
    Delete {
        subscription_id: String,
        old_rows: Vec<HashMap<String, KalamCellValue>>,
    },
    Error {
        subscription_id: String,
        code: String,
        message: String,
    },
    Unknown {
        raw: Value,
    },
}

Change event received via WebSocket subscription.

Variants

Ack

Acknowledgement of subscription registration with batch info

Fields

subscription_id: String

Subscription ID

total_rows: u32

Total rows available for initial load

batch_control: BatchControl

Batch control information

schema: Vec<SchemaField>

Schema describing the columns in the subscription result

InitialDataBatch

Initial data batch (paginated loading)

Fields

subscription_id: String

Subscription ID the batch belongs to

rows: Vec<HashMap<String, KalamCellValue>>

Rows in this batch (named columns)

batch_control: BatchControl

Batch control information

Insert

Insert notification

Fields

subscription_id: String

Subscription ID the change belongs to

rows: Vec<HashMap<String, KalamCellValue>>

Inserted rows (named columns)

Update

Update notification

Fields

subscription_id: String

Subscription ID the change belongs to

rows: Vec<HashMap<String, KalamCellValue>>

Updated rows (only changed columns + PK/_seq). The changed user columns are exactly the non-system keys in each row: row.keys().filter(|k| !k.starts_with('_'))

old_rows: Vec<HashMap<String, KalamCellValue>>

Previous row values (only changed columns + PK/_seq)

Delete

Delete notification

Fields

subscription_id: String

Subscription ID the change belongs to

old_rows: Vec<HashMap<String, KalamCellValue>>

Deleted rows (named columns)

Error

Error notification from the server

Fields

subscription_id: String

Subscription ID related to the error

code: String

Error code

message: String

Human-readable error message

Unknown

Unknown payload (kept for logging/diagnostics)

Fields

raw: Value

Raw JSON payload

Implementations

impl ChangeEvent

pub fn is_error(&self) -> bool

Returns true if this is an error event

pub fn subscription_id(&self) -> Option<&str>

Returns the subscription ID for this event, if any

pub fn from_server_message(msg: ServerMessage) -> Option<ChangeEvent>

Convert a ServerMessage into a ChangeEvent.

Returns None for auth-only messages (AuthSuccess, AuthError) that are not subscription events.

pub fn to_server_message(&self) -> ServerMessage

Convert this event back to a ServerMessage.

Trait Implementations

impl Clone for ChangeEvent

fn clone(&self) -> ChangeEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeEvent

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

Formats the value using the given formatter.