Struct DatabaseEvent 

pub struct DatabaseEvent {

    pub event_id: Option<String>,
    pub timestamp_us: u64,
    pub operation: OperationType,
    pub schema: String,
    pub table: String,
    pub position: u64,
    pub transaction_id: u64,
    pub new_row: Option<Row>,
    pub old_row: Option<Row>,
    pub columns: Vec<String>,
    pub relation_meta: Option<RelationMeta>,
    pub ddl_sql: Option<String>,
    pub ddl_object_type: Option<String>,
}

A single database event.

Fields

event_id: Option<String>

Unique event identifier (UUID v4).

timestamp_us: u64

Event timestamp (Unix timestamp in microseconds).

operation: OperationType

Operation type.

schema: String

Schema name.

table: String

Table name.

position: u64

Replication position (PostgreSQL LSN as u64).

transaction_id: u64

Transaction ID.

new_row: Option<Row>

New row data (for INSERT, UPDATE, SnapshotRow).

old_row: Option<Row>

Old row data (for UPDATE with REPLICA IDENTITY FULL, DELETE).

columns: Vec<String>

Column names in order.

relation_meta: Option<RelationMeta>

Relation metadata (sent once per table per stream).

ddl_sql: Option<String>

DDL SQL statement (when operation == Ddl). Contains the full CREATE/ALTER/DROP statement.

ddl_object_type: Option<String>

DDL object type for filtering/logging. e.g., “extension”, “table”, “index”, “constraint”, “function”, “trigger”

Implementations

impl DatabaseEvent

pub fn qualified_name(&self) -> String

Get the fully qualified table name.

pub fn size_bytes(&self) -> usize

Estimate the size of this event in bytes.

Trait Implementations

impl Clone for DatabaseEvent

fn clone(&self) -> DatabaseEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DatabaseEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DatabaseEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for DatabaseEvent

fn eq(&self, other: &DatabaseEvent) -> 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 Serialize for DatabaseEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for DatabaseEvent