mysql_binlog_connector_rust/event/
xid_event.rs

1use std::io::Cursor;
2
3use byteorder::{LittleEndian, ReadBytesExt};
4use serde::{Deserialize, Serialize};
5
6use crate::binlog_error::BinlogError;
7
8#[derive(Debug, Deserialize, Serialize, Clone)]
9pub struct XidEvent {
10    pub xid: u64,
11}
12
13impl XidEvent {
14    pub fn parse(cursor: &mut Cursor<&Vec<u8>>) -> Result<Self, BinlogError> {
15        Ok(XidEvent {
16            xid: cursor.read_u64::<LittleEndian>()?,
17        })
18    }
19}