Function mz_storage_types::sources::mysql::gtid_set_frontier

source ·
pub fn gtid_set_frontier(
    gtid_set_str: &str
) -> Result<Antichain<GtidPartition>, Error>
Expand description

Parses a GTID Set string received from a MySQL server (e.g. from @@gtid_purged or @@gtid_executed).

Returns the frontier of all future GTIDs that are not contained in the provided GTID set.

This includes singlular partitions that represent each UUID seen in the GTID Set, and range partitions that represent the missing UUIDs between the singular partitions, which are each set to GtidState::Absent.

TODO(roshan): Add compatibility for MySQL 8.3 ‘Tagged’ GTIDs