Skip to main content

min_seq

Function min_seq 

Source
pub async fn min_seq(pool: &PgPool) -> Result<Option<i64>>
Expand description

Read the smallest seq currently in the log, or None if it is empty.

Pair with the consumer’s high-water mark to detect unrecoverable gaps: if min_seq() is Some(n) with n > last_seq, retention has trimmed past the consumer’s position and a full resync is required.