Struct ReplicaObserver 

pub struct ReplicaObserver { /* private fields */ }

Observe protocol progress and successful TCP application bytes on this member. Byte counts include frame headers, retransmissions and heartbeats.

Implementations

impl ReplicaObserver

pub fn enable_timings(&self)

Enable per-member measurements. The normal protocol does not read a clock on these paths until a consumer requests timings.

pub fn timings(&self) -> BTreeMap<&'static str, StageDistribution>

pub async fn wait_stopped(&mut self)

Wait for the protocol to stop, for example after a disk error.

pub async fn changed(&mut self) -> bool

Waits until the role, view, readiness or stop state changes (the progress fields change without notice). False once the node is gone.

pub fn snapshot(&self) -> (NodeStatus, u64, u64)

Trait Implementations

impl Clone for ReplicaObserver

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.