Module mysql 

MySQL binlog replication CDC source connector. Reads row-level changes from a MySQL server’s binlog (GTID or file/position based), decodes them via the decoder submodule, resolves column types against schema::TableCache, and emits Z-set changelog::ChangeEvents that MySqlCdcSource converts into Arrow RecordBatches on poll_batch.

Re-exports

pub use changelog::column_value_to_json;

pub use changelog::delete_to_events;

pub use changelog::events_to_record_batch;

pub use changelog::insert_to_events;

pub use changelog::row_to_json;

pub use changelog::update_to_events;

pub use changelog::CdcOperation;

pub use changelog::ChangeEvent;

pub use config::MySqlCdcConfig;

pub use config::SnapshotMode;

pub use config::SslMode;

pub use decoder::BeginMessage;

pub use decoder::BinlogMessage;

pub use decoder::BinlogPosition;

pub use decoder::ColumnValue;

pub use decoder::CommitMessage;

pub use decoder::DecoderError;

pub use decoder::DeleteMessage;

pub use decoder::InsertMessage;

pub use decoder::QueryMessage;

pub use decoder::RotateMessage;

pub use decoder::RowData;

pub use decoder::TableMapMessage;

pub use decoder::UpdateMessage;

pub use decoder::UpdateRowData;

pub use gtid::Gtid;

pub use gtid::GtidRange;

pub use gtid::GtidSet;

pub use metrics::MetricsSnapshot;

pub use metrics::MySqlCdcMetrics;

pub use schema::cdc_envelope_schema;

pub use schema::TableCache;

pub use schema::TableInfo;

pub use source::MySqlCdcSource;

pub use types::mysql_type;

pub use types::mysql_type_name;

pub use types::mysql_type_to_arrow;

pub use types::mysql_type_to_sql;

pub use types::MySqlColumn;

Modules

changelog

MySQL CDC changelog conversion to Z-set format.

config

MySQL CDC source connector configuration.

decoder

MySQL binlog event decoder.

gtid

MySQL GTID (Global Transaction Identifier) type.

metrics

MySQL CDC source connector metrics.

mysql_io

MySQL CDC binlog I/O.

schema

MySQL table schema cache.

source

MySQL CDC source connector implementation.

types

MySQL type to Arrow type mapping.

Functions

register_mysql_cdc_source

Registers the MySQL CDC source connector factory on the given registry.