Enum FrontendReplication 

pub enum FrontendReplication {
    StandbyStatus {
        written: u64,
        flushed: u64,
        applied: u64,
        client_time: i64,
        reply_requested: bool,
    },
    HotStandbyFeedback {
        client_time: i64,
        xmin: u32,
        xmin_epoch: u32,
        catalog_xmin: u32,
        catalog_xmin_epoch: u32,
    },
    Unknown {
        tag: u8,
        body: Bytes,
    },
}

A typed payload sent by a standby inside frontend CopyData.

Variants

StandbyStatus

The standby’s WAL receipt, flush, and replay positions.

Fields

written: u64

Last WAL position written locally.

flushed: u64

Last WAL position flushed durably.

applied: u64

Last WAL position applied during replay.

client_time: i64

Client clock as microseconds since 2000-01-01 UTC.

reply_requested: bool

Whether the standby requests an immediate keepalive reply.

HotStandbyFeedback

Transaction horizons used to prevent premature vacuuming on the primary.

Fields

client_time: i64

Client clock as microseconds since 2000-01-01 UTC.

xmin: u32

Oldest transaction identifier still needed by the standby.

xmin_epoch: u32

Epoch disambiguating wraparound of xmin.

catalog_xmin: u32

Oldest catalog transaction identifier still needed by the standby.

catalog_xmin_epoch: u32

Epoch disambiguating wraparound of catalog_xmin.

Unknown

An extension payload whose tag is not recognised by this crate.

Fields

tag: u8

Replication sub-message tag.

body: Bytes

Bytes following the tag.

Implementations

impl FrontendReplication

pub fn decode(payload: Bytes) -> Result<Self>

Decodes a standby payload while preserving extension messages.

Errors

Returns an error for a truncated known message or an invalid Boolean byte.

pub fn encode(&self) -> Bytes

Encodes this value as a frontend replication sub-message.

Trait Implementations

impl Clone for FrontendReplication

fn clone(&self) -> FrontendReplication

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FrontendReplication

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

Formats the value using the given formatter.

impl Eq for FrontendReplication

impl PartialEq for FrontendReplication

fn eq(&self, other: &FrontendReplication) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for FrontendReplication