Struct WalStreamChunk 

pub struct WalStreamChunk {
    pub records: Vec<WalStreamRecord>,
    pub current_lsn: u64,
    pub oldest_available_lsn: Option<u64>,
    pub partial_resync: bool,
    pub partial_resync_count: u64,
    pub needs_rebootstrap: bool,
    pub invalidation_reason: Option<String>,
    pub catchup: Option<CatchupModeReply>,
}

Fields

records: Vec<WalStreamRecord>

current_lsn: u64

oldest_available_lsn: Option<u64>

partial_resync: bool

partial_resync_count: u64

needs_rebootstrap: bool

invalidation_reason: Option<String>

catchup: Option<CatchupModeReply>

Implementations

impl WalStreamChunk

pub fn encode_json(&self) -> Vec<u8>

pub fn decode_json( bytes: &[u8], ) -> Result<WalStreamChunk, ReplicationPayloadError>

Trait Implementations

impl Clone for WalStreamChunk

fn clone(&self) -> WalStreamChunk

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WalStreamChunk

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

Formats the value using the given formatter.

impl Eq for WalStreamChunk

impl PartialEq for WalStreamChunk

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for WalStreamChunk