pub struct XaRecoverCollector { /* private fields */ }Expand description
Bounded writer handle into the MySQL-owned XA_recover_txn[] array
the server passes to recover. The engine pushes prepared XIDs via
Self::add; the shim writes each one into the next free slot and
sets the slot’s mod_tables pointer to NULL (engines do not yet
expose the modified-tables list). Self::filled is what the FFI
callback returns to MySQL as the recovered-transaction count.
Implementations§
Source§impl XaRecoverCollector
impl XaRecoverCollector
Sourcepub fn add(&mut self, format_id: i64, gtrid: &[u8], bqual: &[u8]) -> bool
pub fn add(&mut self, format_id: i64, gtrid: &[u8], bqual: &[u8]) -> bool
Push one prepared XA transaction into the next free slot. Returns
false when the array is already full (the engine should stop
recovering in that case; MySQL will call back with a larger
buffer if more transactions are expected).
Trait Implementations§
Auto Trait Implementations§
impl !Send for XaRecoverCollector
impl !Sync for XaRecoverCollector
impl Freeze for XaRecoverCollector
impl RefUnwindSafe for XaRecoverCollector
impl Unpin for XaRecoverCollector
impl UnsafeUnpin for XaRecoverCollector
impl UnwindSafe for XaRecoverCollector
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more