Function mz_storage::source::mysql::replication::raw_stream

async fn raw_stream<'a>(
    config: &RawSourceCreationConfig,
    conn: MySqlConn,
    resume_upper: &Antichain<GtidPartition>,
) -> Result<Result<(BinlogStream, Option<ManagedSshTunnelHandle>), DefiniteError>, TransientError>

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.