Struct mysql_binlog_connector_rust::command::command_util::CommandUtil

pub struct CommandUtil {}

Implementations

impl CommandUtil

pub async fn execute_query( channel: &mut PacketChannel, sql: &str, ) -> Result<Vec<ResultSetRowPacket>, BinlogError>

pub async fn execute_sql( channel: &mut PacketChannel, sql: &str, ) -> Result<(), BinlogError>

pub async fn fetch_binlog_info( channel: &mut PacketChannel, ) -> Result<(String, u32), BinlogError>

pub async fn fetch_binlog_checksum( channel: &mut PacketChannel, ) -> Result<ChecksumType, BinlogError>

pub async fn setup_binlog_connection( channel: &mut PacketChannel, ) -> Result<(), BinlogError>

pub async fn dump_binlog( channel: &mut PacketChannel, binlog_filename: &str, binlog_position: u32, server_id: u64, ) -> Result<(), BinlogError>

pub fn parse_result(buf: &Vec<u8>) -> Result<(), BinlogError>

pub fn check_error_packet(buf: &Vec<u8>) -> Result<(), BinlogError>