Struct mysql_async::binlog::events::TransactionPayloadEvent

pub struct TransactionPayloadEvent<'a> { /* private fields */ }

Event that encloses all the events of a transaction.

It is used for carrying compressed payloads, and contains compression metadata.

Implementations

impl<'a> TransactionPayloadEvent<'a>

pub fn new( payload_size: u64, algorithm: TransactionPayloadCompressionType, uncompressed_size: u64, payload: impl Into<Cow<'a, [u8]>>, ) -> TransactionPayloadEvent<'a>

pub fn with_payload_size(self, payload_size: u64) -> TransactionPayloadEvent<'a>

Sets the payload_size field value.

pub fn with_algorithm( self, algorithm: TransactionPayloadCompressionType, ) -> TransactionPayloadEvent<'a>

Sets the algorithm field value.

pub fn with_uncompressed_size( self, uncompressed_size: u64, ) -> TransactionPayloadEvent<'a>

Sets the uncompressed_size field value.

pub fn with_payload( self, payload: impl Into<Cow<'a, [u8]>>, ) -> TransactionPayloadEvent<'a>

Sets the payload field value.

pub fn payload_size(&self) -> u64

Returns the payload_size.

pub fn payload_raw(&'a self) -> &'a [u8]

Returns raw payload of the binlog event.

pub fn decompressed(&self) -> Result<TransactionPayloadReader<'_>, Error>

Returns decompressed payload in form of a struct that implements io::BufRead.

See EventStreamReader::read_decompressed.

pub fn danger_decompress(self) -> Vec<u8>

Decompress the whole payload.

Danger

This function may allocate a huge buffer and cause OOM. Consider using TransactionPayloadEvent::decompressed instead.

pub fn algorithm(&self) -> TransactionPayloadCompressionType

Returns the algorithm.

pub fn uncompressed_size(&self) -> u64

Returns the uncompressed_size.

pub fn into_owned(self) -> TransactionPayloadEvent<'static>

Trait Implementations

impl<'a> BinlogEvent<'a> for TransactionPayloadEvent<'a>

const EVENT_TYPE: EventType = EventType::TRANSACTION_PAYLOAD_EVENT

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

impl<'a> BinlogStruct<'a> for TransactionPayloadEvent<'a>

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

Returns serialized length of this struct in bytes.

impl<'a> Clone for TransactionPayloadEvent<'a>

fn clone(&self) -> TransactionPayloadEvent<'a>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for TransactionPayloadEvent<'a>

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

Formats the value using the given formatter.

impl<'a> Hash for TransactionPayloadEvent<'a>

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

where __H: Hasher,

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 TransactionPayloadEvent<'de>

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: <TransactionPayloadEvent<'de> as MyDeserialize<'de>>::Ctx, buf: &mut ParseBuf<'de>, ) -> Result<TransactionPayloadEvent<'de>, Error>

Deserializes self from the given buf.

impl MySerialize for TransactionPayloadEvent<'_>

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

Serializes self into the buf.

impl<'a> PartialEq for TransactionPayloadEvent<'a>

fn eq(&self, other: &TransactionPayloadEvent<'a>) -> 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<'a> Eq for TransactionPayloadEvent<'a>

impl<'a> StructuralPartialEq for TransactionPayloadEvent<'a>