Struct DownstreamSlot 

pub struct DownstreamSlot {
    pub id: String,
    pub confirmed_lsn: u64,
    pub sent_lsn: u64,
}

A sub-replica slot held by an intermediate.

Fields

id: String

Identity of the sub-replica streaming through this intermediate.

confirmed_lsn: u64

Highest LSN the sub-replica has confirmed durably applied. Drives the retention frontier reported upstream — the intermediate must keep WAL above this point so it can still forward it.

sent_lsn: u64

Highest LSN forwarded to the sub-replica so far. Always >= confirmed_lsn; the gap is in-flight, not yet acked.

Trait Implementations

impl Clone for DownstreamSlot

fn clone(&self) -> DownstreamSlot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DownstreamSlot

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

Formats the value using the given formatter.

impl Eq for DownstreamSlot

impl PartialEq for DownstreamSlot

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