Module decoder 

MySQL binlog event decoder.

Wraps the mysql_cdc crate’s binlog events into our internal BinlogMessage types for unified CDC processing.

Structs

BeginMessage

Transaction begin message (from GTID event).

BinlogPosition

Position in the MySQL binlog.

CommitMessage

Transaction commit message (from XID event).

DeleteMessage

Row delete message.

InsertMessage

Row insert message.

QueryMessage

Query event (typically DDL).

RotateMessage

Rotate event (binlog file change).

RowData

Row data containing column values.

TableMapMessage

Table map message (schema definition for row events).

UpdateMessage

Row update message.

UpdateRowData

Update row data with before and after images.

Enums

BinlogMessage

A decoded binlog message from MySQL replication.

ColumnValue

A single column value.

DecoderError

Decoder errors.

Functions

mysql_timestamp_to_unix_ms

Decodes a timestamp from MySQL epoch to Unix milliseconds.