Struct pgx_pg_sys::ReorderBuffer

source ·

#[repr(C)]
pub struct ReorderBuffer {Show 40 fields
    pub by_txn: *mut HTAB,
    pub toplevel_by_lsn: dlist_head,
    pub txns_by_base_snapshot_lsn: dlist_head,
    pub by_txn_last_xid: TransactionId,
    pub by_txn_last_txn: *mut ReorderBufferTXN,
    pub begin: ReorderBufferBeginCB,
    pub apply_change: ReorderBufferApplyChangeCB,
    pub apply_truncate: ReorderBufferApplyTruncateCB,
    pub commit: ReorderBufferCommitCB,
    pub message: ReorderBufferMessageCB,
    pub begin_prepare: ReorderBufferBeginCB,
    pub prepare: ReorderBufferPrepareCB,
    pub commit_prepared: ReorderBufferCommitPreparedCB,
    pub rollback_prepared: ReorderBufferRollbackPreparedCB,
    pub stream_start: ReorderBufferStreamStartCB,
    pub stream_stop: ReorderBufferStreamStopCB,
    pub stream_abort: ReorderBufferStreamAbortCB,
    pub stream_prepare: ReorderBufferStreamPrepareCB,
    pub stream_commit: ReorderBufferStreamCommitCB,
    pub stream_change: ReorderBufferStreamChangeCB,
    pub stream_message: ReorderBufferStreamMessageCB,
    pub stream_truncate: ReorderBufferStreamTruncateCB,
    pub private_data: *mut c_void,
    pub output_rewrites: bool,
    pub context: MemoryContext,
    pub change_context: MemoryContext,
    pub txn_context: MemoryContext,
    pub tup_context: MemoryContext,
    pub current_restart_decoding_lsn: XLogRecPtr,
    pub outbuf: *mut c_char,
    pub outbufsize: Size,
    pub size: Size,
    pub spillTxns: int64,
    pub spillCount: int64,
    pub spillBytes: int64,
    pub streamTxns: int64,
    pub streamCount: int64,
    pub streamBytes: int64,
    pub totalTxns: int64,
    pub totalBytes: int64,
}

Fields§

§by_txn: *mut HTAB§toplevel_by_lsn: dlist_head§txns_by_base_snapshot_lsn: dlist_head§by_txn_last_xid: TransactionId§by_txn_last_txn: *mut ReorderBufferTXN§begin: ReorderBufferBeginCB§apply_change: ReorderBufferApplyChangeCB§apply_truncate: ReorderBufferApplyTruncateCB§commit: ReorderBufferCommitCB§message: ReorderBufferMessageCB§begin_prepare: ReorderBufferBeginCB§prepare: ReorderBufferPrepareCB§commit_prepared: ReorderBufferCommitPreparedCB§rollback_prepared: ReorderBufferRollbackPreparedCB§stream_start: ReorderBufferStreamStartCB§stream_stop: ReorderBufferStreamStopCB§stream_abort: ReorderBufferStreamAbortCB§stream_prepare: ReorderBufferStreamPrepareCB§stream_commit: ReorderBufferStreamCommitCB§stream_change: ReorderBufferStreamChangeCB§stream_message: ReorderBufferStreamMessageCB§stream_truncate: ReorderBufferStreamTruncateCB§private_data: *mut c_void§output_rewrites: bool§context: MemoryContext§change_context: MemoryContext§txn_context: MemoryContext§tup_context: MemoryContext§current_restart_decoding_lsn: XLogRecPtr§outbuf: *mut c_char§outbufsize: Size§size: Size§spillTxns: int64§spillCount: int64§spillBytes: int64§streamTxns: int64§streamCount: int64§streamBytes: int64§totalTxns: int64§totalBytes: int64

Struct pgx_pg_sys::ReorderBuffer

Fields§

Trait Implementations§

impl Clone for ReorderBuffer

fn clone(&self) -> ReorderBuffer

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

impl Debug for ReorderBuffer

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

impl Default for ReorderBuffer

fn default() -> Self

impl Copy for ReorderBuffer

Auto Trait Implementations§

impl RefUnwindSafe for ReorderBuffer

impl !Send for ReorderBuffer

impl !Sync for ReorderBuffer

impl Unpin for ReorderBuffer

impl UnwindSafe for ReorderBuffer

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<T> Any for Twhere
T: 'static + ?Sized,

impl<T> Borrow<T> for Twhere
T: ?Sized,

impl<T> BorrowMut<T> for Twhere
T: ?Sized,

impl<T, U> Into<U> for Twhere
U: From<T>,

impl<T> ToOwned for Twhere
T: Clone,

impl<T, U> TryFrom<U> for Twhere
U: Into<T>,

impl<T, U> TryInto<U> for Twhere
U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where
S: Into<Dispatch>,