Struct ReplicationMetrics 

pub struct ReplicationMetrics { /* private fields */ }

Implementations

impl ReplicationMetrics

pub fn record_emit(&self, queue_depth: usize)

pub fn record_emit_count(&self, count: usize, queue_depth: usize)

pub fn record_drop(&self)

pub fn record_backpressure(&self)

pub fn record_batch( &self, records: usize, uncompressed_bytes: usize, compressed_bytes: usize, compression_ns: u64, )

pub fn record_queue_depth(&self, queue_depth: usize)

pub fn record_replica_apply(&self, applied: bool, apply_ns: u64)

pub fn record_replica_apply_batch( &self, applied: u64, skipped: u64, apply_ns: u64, )

pub fn record_backlog_catch_up(&self)

pub fn record_snapshot_catch_up(&self)

pub fn snapshot(&self) -> ReplicationMetricsSnapshot

Trait Implementations

impl Clone for ReplicationMetrics

fn clone(&self) -> ReplicationMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationMetrics

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

Formats the value using the given formatter.

impl Default for ReplicationMetrics

fn default() -> ReplicationMetrics

Returns the “default value” for a type.