mz_storage::source::mysql::replication

Function raw_stream

Source
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.