Struct pgx_pg_sys::WalRcvData

#[repr(C)]
pub struct WalRcvData {

    pub pid: pid_t,
    pub walRcvState: WalRcvState,
    pub walRcvStoppedCV: ConditionVariable,
    pub startTime: pg_time_t,
    pub receiveStart: XLogRecPtr,
    pub receiveStartTLI: TimeLineID,
    pub flushedUpto: XLogRecPtr,
    pub receivedTLI: TimeLineID,
    pub latestChunkStart: XLogRecPtr,
    pub lastMsgSendTime: TimestampTz,
    pub lastMsgReceiptTime: TimestampTz,
    pub latestWalEnd: XLogRecPtr,
    pub latestWalEndTime: TimestampTz,
    pub conninfo: [c_char; 1024],
    pub sender_host: [c_char; 1025],
    pub sender_port: c_int,
    pub slotname: [c_char; 64],
    pub is_temp_slot: bool,
    pub ready_to_display: bool,
    pub latch: *mut Latch,
    pub mutex: slock_t,
    pub writtenUpto: pg_atomic_uint64,
    pub force_reply: sig_atomic_t,
}

Fields

pid: pid_t

walRcvState: WalRcvState

walRcvStoppedCV: ConditionVariable

startTime: pg_time_t

receiveStart: XLogRecPtr

receiveStartTLI: TimeLineID

flushedUpto: XLogRecPtr

receivedTLI: TimeLineID

latestChunkStart: XLogRecPtr

lastMsgSendTime: TimestampTz

lastMsgReceiptTime: TimestampTz

latestWalEnd: XLogRecPtr

latestWalEndTime: TimestampTz

conninfo: [c_char; 1024]

sender_host: [c_char; 1025]

sender_port: c_int

slotname: [c_char; 64]

is_temp_slot: bool

ready_to_display: bool

latch: *mut Latch

mutex: slock_t

writtenUpto: pg_atomic_uint64

force_reply: sig_atomic_t

Trait Implementations

impl Clone for WalRcvData

fn clone(&self) -> WalRcvData

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WalRcvData

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

Formats the value using the given formatter.

impl Default for WalRcvData

fn default() -> Self

Returns the “default value” for a type.

impl Copy for WalRcvData