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>
Expand description
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.