Struct BinlogClient 

pub struct BinlogClient {
    pub url: String,
    pub binlog_filename: String,
    pub binlog_position: u32,
    pub server_id: u64,
    pub gtid_enabled: bool,
    pub gtid_set: String,
    pub heartbeat_interval_secs: u64,
    pub timeout_secs: u64,
    pub keepalive_idle_secs: u64,
    pub keepalive_interval_secs: u64,
}

Fields

url: String

MySQL server connection URL in format “mysql://user:password@host:port”

binlog_filename: String

Name of the binlog file to start replication from, e.g. “mysql-bin.000001” Only used when gtid_enabled is false

binlog_position: u32

Position in the binlog file to start replication from

server_id: u64

Unique identifier for this replication client Must be different from other clients connected to the same MySQL server

gtid_enabled: bool

Whether to enable GTID mode for replication

gtid_set: String

GTID set in format “uuid:1-100,uuid2:1-200” Only used when gtid_enabled is true

heartbeat_interval_secs: u64

Heartbeat interval in seconds Server will send a heartbeat event if no binlog events are received within this interval If heartbeat_interval_secs=0, server won’t send heartbeat events

timeout_secs: u64

Network operation timeout in seconds Maximum wait time for operations like connection establishment and data reading If timeout_secs=0, the default value(60) will be used

keepalive_idle_secs: u64

TCP keepalive idle time in seconds The time period after which the first keepalive packet is sent if no data has been exchanged between the two endpoints If keepalive_idle_secs=0, TCP keepalive will not be enabled

keepalive_interval_secs: u64

TCP keepalive interval time in seconds The time period between keepalive packets if the connection is still active If keepalive_interval_secs=0, TCP keepalive will not be enabled

Implementations

impl BinlogClient

pub fn new(url: &str, server_id: u64, position: StartPosition) -> Self

pub fn with_master_heartbeat(self, heartbeat_interval: Duration) -> Self

pub fn with_read_timeout(self, timeout: Duration) -> Self

pub fn with_keepalive( self, keepalive_idle: Duration, keepalive_interval: Duration, ) -> Self

pub async fn connect(&mut self) -> Result<BinlogStream, BinlogError>

Trait Implementations

impl Default for BinlogClient

fn default() -> BinlogClient

Returns the “default value” for a type.