mysql_cdc 0.2.1

MySQL/MariaDB binlog change data capture (CDC) connector for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

use crate::providers::mysql::gtid::uuid::Uuid;
use std::fmt;

/// MySQL 5.6+ representation of Gtid.
#[derive(Clone, Debug)]
pub struct Gtid {
    /// Gets identifier of the original server that generated the event.
    pub source_id: Uuid,

    /// Gets sequence number of the event on the original server.
    pub transaction_id: u64,
}

impl Gtid {
    pub fn new(source_id: Uuid, transaction_id: u64) -> Self {
        Self {
            source_id,
            transaction_id,
        }
    }
}

impl fmt::Display for Gtid {
    /// Returns string representation of Gtid in MySQL Server.
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "{}:{}", self.source_id, self.transaction_id)
    }
}