Struct ReplicaState 

pub struct ReplicaState {
    pub id: String,
    pub last_acked_lsn: u64,
    pub last_sent_lsn: u64,
    pub last_durable_lsn: u64,
    pub apply_error_count: u64,
    pub divergence_count: u64,
    pub connected_at_unix_ms: u128,
    pub last_seen_at_unix_ms: u128,
    pub region: Option<String>,
    pub rebootstrapping: bool,
}

State of a connected replica. PLAN.md Phase 11.4 fields: last_seen_at_unix_ms updates on every interaction (pull or ack); last_sent_lsn updates when the primary serves a pull_wal_records batch; last_durable_lsn updates when the replica reports its WAL is durably written via ack_replica_lsn.

Fields

id: String

last_acked_lsn: u64

last_sent_lsn: u64

last_durable_lsn: u64

apply_error_count: u64

divergence_count: u64

connected_at_unix_ms: u128

last_seen_at_unix_ms: u128

region: Option<String>

Region identifier declared by the replica at handshake time (Phase 2.6 multi-region PG parity). None until the replica handshake extension lands in 2.6.2; the quorum coordinator’s region-binding map covers the in-process case meanwhile.

rebootstrapping: bool

true while this replica is re-bootstrapping — loading a fresh snapshot to replace its current dataset (issue #837). It keeps serving non-causal reads from the old data, but the advertiser surfaces this flag so a causal reader routes bookmark reads elsewhere: the replica’s last_acked_lsn describes data it is about to discard. Cleared atomically when the swap completes.

Trait Implementations

impl Clone for ReplicaState

fn clone(&self) -> ReplicaState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicaState

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

Formats the value using the given formatter.