binlog_reader/
binlog_reader.rs

1use mysql_cdc::{binlog_reader::BinlogReader, errors::Error};
2use std::fs::File;
3
4const PATH: &str = "mysql-bin.000001";
5
6fn main() -> Result<(), Error> {
7    let file = File::open(PATH)?;
8    let reader = BinlogReader::new(file)?;
9
10    for result in reader.read_events() {
11        let (header, event) = result?;
12        println!("{:#?}", header);
13        println!("{:#?}", event);
14    }
15    Ok(())
16}