Enum BackendReplication 

pub enum BackendReplication {
    XLogData {
        wal_start: u64,
        wal_end: u64,
        server_time: i64,
        data: Bytes,
    },
    PrimaryKeepalive {
        wal_end: u64,
        server_time: i64,
        reply_requested: bool,
    },
    Unknown {
        tag: u8,
        body: Bytes,
    },
}

A typed payload sent by a walsender inside backend CopyData.

Variants

XLogData

A range of write-ahead log data.

Fields

wal_start: u64

WAL position of the first byte in data.

wal_end: u64

Current end of WAL on the server.

server_time: i64

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

data: Bytes

WAL bytes.

PrimaryKeepalive

A primary keepalive message.

Fields

wal_end: u64

Current end of WAL on the server.

server_time: i64

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

reply_requested: bool

Whether the server requests an immediate status reply.

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 BackendReplication

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

Decodes a backend walsender 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 backend replication sub-message.

Trait Implementations

impl Clone for BackendReplication

fn clone(&self) -> BackendReplication

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackendReplication

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

Formats the value using the given formatter.

impl Eq for BackendReplication

impl PartialEq for BackendReplication

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for BackendReplication