Struct mysql_common::binlog::events::GtidEvent

pub struct GtidEvent { /* private fields */ }

GTID stands for Global Transaction IDentifier.

Implementations

impl GtidEvent

pub const POST_HEADER_LENGTH: usize = 42usize

pub const ENCODED_SID_LENGTH: usize = 16usize

pub const LOGICAL_TIMESTAMP_TYPECODE: u8 = 2u8

pub const IMMEDIATE_COMMIT_TIMESTAMP_LENGTH: usize = 7usize

pub const ORIGINAL_COMMIT_TIMESTAMP_LENGTH: usize = 7usize

pub const UNDEFINED_SERVER_VERSION: u32 = 999_999u32

pub const IMMEDIATE_SERVER_VERSION_LENGTH: usize = 4usize

pub fn new(sid: [u8; 16], gno: u64) -> Self

pub fn with_flags(self, flags: GtidFlags) -> Self

Defines the flags value.

pub fn flags_raw(&self) -> u8

Returns the raw flags value.

pub fn flags(&self) -> GtidFlags

Returns the flags value. Unknown bits will be truncated.

00000001 – Transaction may have changes logged with SBR.

In 5.6, 5.7.0-5.7.18, and 8.0.0-8.0.1, this flag is always set. Starting in 5.7.19 and 8.0.2, this flag is cleared if the transaction only contains row events. It is set if any part of the transaction is written in statement format.

pub fn with_sid(self, sid: [u8; 16]) -> Self

Defines the sid value.

pub fn sid(&self) -> [u8; 16]

Returns the sid value.

sid is the UUID representing the SID.

pub fn with_gno(self, gno: u64) -> Self

Defines the gno value.

pub fn gno(&self) -> u64

Returns the gno value.

gno is a group number, second component of GTID.

pub fn lc_typecode(&self) -> Option<u8>

Returns the lc_typecode value.

lc_typecode is the type of logical timestamp used in the logical clock fields.

pub fn with_lc_typecode(self) -> Self

Sets the lc_typecode value to GtidEvent::LOGICAL_TIMESTAMP_TYPECODE.

This is already by default, but lc_typecode might be None if Self is obtained from an old MySql server via MyDeserialize::deserialize.

pub fn with_last_committed(self, last_committed: u64) -> Self

Sets the last_committed value.

pub fn last_committed(&self) -> u64

Returns the last_committed value.

last_committed stores the transaction’s commit parent sequence_number.

pub fn with_sequence_number(self, sequence_number: u64) -> Self

Sets the sequence_number value.

pub fn sequence_number(&self) -> u64

Returns the sequence_number value.

sequence_number is the transaction’s logical timestamp assigned at prepare phase.

pub fn with_immediate_commit_timestamp( self, immediate_commit_timestamp: u64, ) -> Self

Sets the immediate_commit_timestamp value.

pub fn immediate_commit_timestamp(&self) -> u64

Returns the immediate_commit_timestamp value.

immediate_commit_timestamp is a timestamp of commit on the immediate master.

pub fn with_original_commit_timestamp( self, original_commit_timestamp: u64, ) -> Self

Sets the original_commit_timestamp value.

pub fn original_commit_timestamp(&self) -> u64

Returns the original_commit_timestamp value.

original_commit_timestamp is the timestamp of commit on the originating master.

pub fn with_tx_length(self, tx_length: u64) -> Self

Sets the tx_length value.

pub fn tx_length(&self) -> u64

Returns the tx_length value.

tx_length is the packed transaction’s length in bytes, including the Gtid.

pub fn with_original_server_version(self, original_server_version: u32) -> Self

Sets the original_server_version value.

pub fn original_server_version(&self) -> u32

Returns the original_server_version value.

original_server_version is the version of the server where the transaction was originally executed.

pub fn with_immediate_server_version( self, immediate_server_version: u32, ) -> Self

Sets the immediate_server_version value.

pub fn immediate_server_version(&self) -> u32

Returns the immediate_server_version value.

immediate_server_version is the server version of the immediate server.

Trait Implementations

impl<'a> BinlogEvent<'a> for GtidEvent

const EVENT_TYPE: EventType = EventType::GTID_EVENT

An event type, associated with this struct (if any).

impl<'a> BinlogStruct<'a> for GtidEvent

fn len(&self, _version: BinlogVersion) -> usize

Returns serialized length of this struct in bytes.

impl Clone for GtidEvent

fn clone(&self) -> GtidEvent

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GtidEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Hash for GtidEvent

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<'de> MyDeserialize<'de> for GtidEvent

const SIZE: Option<usize> = None

Size hint of a serialized value (in bytes), if it’s constant.

type Ctx = BinlogCtx<'de>

Some structs defines deserialization in the context of another value.

fn deserialize(_ctx: Self::Ctx, buf: &mut ParseBuf<'de>) -> Result<Self>

Deserializes self from the given buf.

impl MySerialize for GtidEvent

fn serialize(&self, buf: &mut Vec<u8>)

Serializes self into the buf.

impl PartialEq for GtidEvent

fn eq(&self, other: &GtidEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for GtidEvent

impl StructuralPartialEq for GtidEvent