Enum LagCalculation 

pub enum LagCalculation {
    Wal {
        bytes_per_second: u64,
    },
    Time,
    Hybrid {
        bytes_per_second: u64,
    },
}

Method for calculating replication lag

Variants

Wal

WAL-based lag (LSN difference converted to time)

Fields

bytes_per_second: u64

Estimated WAL bytes per second for time conversion

Time

Time-based lag (last transaction timestamp)

Hybrid

Hybrid (use both WAL and time, take maximum)

Fields

bytes_per_second: u64

Estimated WAL bytes per second for time conversion

Implementations

impl LagCalculation

pub fn wal(bytes_per_second: u64) -> Self

Create WAL-based calculation

pub fn time() -> Self

Create time-based calculation

pub fn hybrid(bytes_per_second: u64) -> Self

Create hybrid calculation

pub fn calculate_lag( &self, lag_bytes: u64, time_lag: Option<Duration>, ) -> Duration

Calculate lag duration from byte lag

Trait Implementations

impl Clone for LagCalculation

fn clone(&self) -> LagCalculation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LagCalculation

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

Formats the value using the given formatter.

impl Default for LagCalculation

fn default() -> Self

Returns the “default value” for a type.

impl PartialEq for LagCalculation

fn eq(&self, other: &LagCalculation) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for LagCalculation

impl Eq for LagCalculation

impl StructuralPartialEq for LagCalculation