Struct WalStreamOpen 

pub struct WalStreamOpen {
    pub since_lsn: u64,
    pub max_count: usize,
    pub replica_id: Option<String>,
    pub await_data: bool,
    pub await_timeout_ms: u64,
}

Fields

since_lsn: u64

max_count: usize

replica_id: Option<String>

await_data: bool

await_timeout_ms: u64

Implementations

impl WalStreamOpen

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

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

Trait Implementations

impl Clone for WalStreamOpen

fn clone(&self) -> WalStreamOpen

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WalStreamOpen

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

Formats the value using the given formatter.

impl Eq for WalStreamOpen

impl PartialEq for WalStreamOpen

fn eq(&self, other: &WalStreamOpen) -> 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 WalStreamOpen