Struct ReplicationLag 

pub struct ReplicationLag { /* private fields */ }

Measures and evaluates replication lag between pairs of datacenters.

Lag measurements are stored in-memory; in production these would be populated from heartbeat timestamps.

Implementations

impl ReplicationLag

pub fn new() -> Self

Create a new lag tracker with no measurements.

pub fn record( &mut self, dc_a: impl Into<String>, dc_b: impl Into<String>, lag_ms: u64, )

Record a lag measurement between dc_a and dc_b (directional).

pub fn lag_ms(&self, dc_a: &str, dc_b: &str) -> u64

Retrieve the most recently recorded lag between dc_a and dc_b in milliseconds. Returns 0 if no measurement has been recorded.

pub fn is_acceptable(&self, lag_ms: u64, sla_ms: u64) -> bool

Returns true if lag_ms is within the acceptable sla_ms bound.

pub fn alert_if_excessive( &self, dc_a: &str, dc_b: &str, lag_ms: u64, threshold_ms: u64, ) -> Option<ReplicationAlert>

Generate an alert if lag_ms exceeds threshold_ms, otherwise returns None.

pub fn check_and_alert( &self, dc_a: &str, dc_b: &str, threshold_ms: u64, ) -> Option<ReplicationAlert>

Check recorded lag between dc_a and dc_b against a threshold and produce an alert if it is excessive.

Trait Implementations

impl Clone for ReplicationLag

fn clone(&self) -> ReplicationLag

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationLag

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

Formats the value using the given formatter.

impl Default for ReplicationLag

fn default() -> ReplicationLag

Returns the “default value” for a type.