Struct DatabaseEventBuilder 

pub struct DatabaseEventBuilder { /* private fields */ }

Builder for constructing a single DatabaseEvent.

Implementations

impl DatabaseEventBuilder

pub fn new( operation: OperationType, schema: impl Into<String>, table: impl Into<String>, ) -> Self

Create a new builder for a DML operation.

pub fn insert(schema: impl Into<String>, table: impl Into<String>) -> Self

Create a builder for an INSERT event.

pub fn update(schema: impl Into<String>, table: impl Into<String>) -> Self

Create a builder for an UPDATE event.

pub fn delete(schema: impl Into<String>, table: impl Into<String>) -> Self

Create a builder for a DELETE event.

pub fn snapshot_row(schema: impl Into<String>, table: impl Into<String>) -> Self

Create a builder for a snapshot row.

pub fn begin() -> Self

Create a builder for BEGIN transaction.

pub fn commit() -> Self

Create a builder for COMMIT transaction.

pub fn ddl(sql: impl Into<String>, object_type: impl Into<String>) -> Self

Create a builder for a DDL event.

pub fn event_id(self, id: impl Into<String>) -> Self

Set the event ID.

pub fn timestamp_us(self, ts: u64) -> Self

Set the timestamp in microseconds.

pub fn timestamp(self, ts: SystemTime) -> Self

Set the timestamp from SystemTime.

pub fn position(self, pos: u64) -> Self

Set the replication position (LSN).

pub fn transaction_id(self, xid: u64) -> Self

Set the transaction ID.

pub fn new_row(self, row: Row) -> Self

Set the new row data.

pub fn old_row(self, row: Row) -> Self

Set the old row data.

pub fn columns(self, columns: Vec<String>) -> Self

Set column names.

pub fn relation_meta(self, meta: RelationMeta) -> Self

Set relation metadata.

pub fn build(self) -> DatabaseEvent

Build the event.