Struct pgx_pg_sys::LogicalDecodingContext

source ·

#[repr(C)]
pub struct LogicalDecodingContext {Show 22 fields
    pub context: MemoryContext,
    pub slot: *mut ReplicationSlot,
    pub reader: *mut XLogReaderState,
    pub reorder: *mut ReorderBuffer,
    pub snapshot_builder: *mut SnapBuild,
    pub fast_forward: bool,
    pub end_xact: bool,
    pub callbacks: OutputPluginCallbacks,
    pub options: OutputPluginOptions,
    pub output_plugin_options: *mut List,
    pub prepare_write: LogicalOutputPluginWriterPrepareWrite,
    pub write: LogicalOutputPluginWriterWrite,
    pub update_progress: LogicalOutputPluginWriterUpdateProgress,
    pub out: StringInfo,
    pub output_plugin_private: *mut c_void,
    pub output_writer_private: *mut c_void,
    pub streaming: bool,
    pub twophase: bool,
    pub accept_writes: bool,
    pub prepared_write: bool,
    pub write_location: XLogRecPtr,
    pub write_xid: TransactionId,
}

Fields

context: MemoryContextslot: *mut ReplicationSlotreader: *mut XLogReaderStatereorder: *mut ReorderBuffersnapshot_builder: *mut SnapBuildfast_forward: boolend_xact: boolcallbacks: OutputPluginCallbacksoptions: OutputPluginOptionsoutput_plugin_options: *mut Listprepare_write: LogicalOutputPluginWriterPrepareWritewrite: LogicalOutputPluginWriterWriteupdate_progress: LogicalOutputPluginWriterUpdateProgressout: StringInfooutput_plugin_private: *mut c_voidoutput_writer_private: *mut c_voidstreaming: booltwophase: boolaccept_writes: boolprepared_write: boolwrite_location: XLogRecPtrwrite_xid: TransactionId

Struct pgx_pg_sys::LogicalDecodingContext

Fields

Trait Implementations

impl Clone for LogicalDecodingContext

fn clone(&self) -> LogicalDecodingContext

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

impl Debug for LogicalDecodingContext

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

impl Default for LogicalDecodingContext

fn default() -> Self

impl Copy for LogicalDecodingContext

Auto Trait Implementations

impl RefUnwindSafe for LogicalDecodingContext

impl !Send for LogicalDecodingContext

impl !Sync for LogicalDecodingContext

impl Unpin for LogicalDecodingContext

impl UnwindSafe for LogicalDecodingContext

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>,