Struct ChangeRow 

pub struct ChangeRow {
    pub seq: i64,
    pub table_name: String,
    pub op: String,
    pub row_id: Option<String>,
    pub changed_cols: Option<String>,
    pub created_at: DateTime<Utc>,
}

One row of forge_change_log.

Mirrors the columns produced by the system migration’s forge_notify_change() trigger. Kept deliberately close to the wire shape so callers can decide how to map row_id (TEXT, may not be a UUID for every table) and the comma-separated changed_cols string.

Fields

seq: i64

Monotonic sequence number; the consumer’s high-water mark.

table_name: String

Table that produced the change.

op: String

SQL operation: INSERT, UPDATE, or DELETE.

row_id: Option<String>

Text-encoded primary key. None only when the trigger could not resolve OLD.id/NEW.id (e.g. a table with a non-id PK).

changed_cols: Option<String>

For UPDATE, comma-separated column names whose values changed. None for INSERT/DELETE and for UPDATEs where no columns differ.

created_at: DateTime<Utc>

Server-side timestamp at which the trigger inserted the row.

Trait Implementations

impl Clone for ChangeRow

fn clone(&self) -> ChangeRow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeRow

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

Formats the value using the given formatter.

impl<'a, R: Row> FromRow<'a, R> for ChangeRow

where &'a str: ColumnIndex<R>, i64: Decode<'a, R::Database> + Type<R::Database>, String: Decode<'a, R::Database> + Type<R::Database>, Option<String>: Decode<'a, R::Database> + Type<R::Database>, DateTime<Utc>: Decode<'a, R::Database> + Type<R::Database>,

fn from_row(__row: &'a R) -> Result<Self>