Function mz_storage::source::mysql::replication::events::handle_rows_event

pub(super) async fn handle_rows_event(
    event: RowsEventData<'_>,
    ctx: &ReplContext<'_>,
    new_gtid: &GtidPartition,
    event_buffer: &mut Vec<((usize, Result<SourceMessage, DataflowError>), GtidPartition, Diff)>,
) -> Result<(), TransientError>

Handles RowsEvents from the MySQL replication stream. These events contain insert/update/delete events for a single transaction or committed statement.

We use these events to update the dataflow with the new rows, and return a new frontier with which to advance the dataflow’s progress.