pub fn record_replication_lag_events(peer_id: &str, lag_events: u64)
Record replication lag in events (how many events behind stream head).