async fn raw_stream<'a>(
config: &RawSourceCreationConfig,
conn: MySqlConn,
resume_upper: &Antichain<GtidPartition>,
) -> Result<Result<(BinlogStream, Option<ManagedSshTunnelHandle>), DefiniteError>, TransientError>
Expand description
Produces the replication stream from the MySQL server. This will return all transactions
whose GTIDs were not present in the GTID UUIDs referenced in the resume_uppper
partitions.