Struct ReplicaSlot 

pub struct ReplicaSlot {
    pub id: String,
    pub last_seen_ns: u64,
    pub acked_offset: u64,
}

One connected-or-recently-disconnected replica.

Fields

id: String

Operator-set replica identifier (opaque to the primary other than for slot bookkeeping).

last_seen_ns: u64

Monotonic ns timestamp of the most recent contact (handshake or ack). Drives expiry under reconnect_window_ms.

acked_offset: u64

Highest offset the replica has acked. The streaming loop resumes sending from here on reconnect.

Trait Implementations

impl Clone for ReplicaSlot

fn clone(&self) -> ReplicaSlot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicaSlot

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

Formats the value using the given formatter.

impl Eq for ReplicaSlot

impl PartialEq for ReplicaSlot

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