Struct Checkpoint 

pub struct Checkpoint {

    pub job_id: String,
    pub state: JobState,
    pub source_system_id: String,
    pub source_dbname: String,
    pub slot: String,
    pub publication: String,
    pub slot_owned: bool,
    pub consistent_point: Option<Lsn>,
    pub commit_lsn: Lsn,
    pub committed_lsn: Lsn,
    pub acked_lsn: Lsn,
    pub last_xid: Option<u32>,
    pub last_commit_ts: Option<i64>,
    pub txns_applied: u64,
    pub last_error: Option<String>,
}

Everything needed to identify a job’s source and resume it safely.

Invariants maintained by the engine:

• commit_lsn <= committed_lsn <= acked_lsn
• the slot’s confirmed_flush_lsn never exceeds acked_lsn
• committed_lsn only moves inside the target transaction that applied the data

Fields

job_id: String

state: JobState

source_system_id: String

IDENTIFY_SYSTEM.systemid of the source cluster.

source_dbname: String

slot: String

publication: String

slot_owned: bool

Whether PGSync created the slot (and may therefore drop it in cleanup).

consistent_point: Option<Lsn>

consistent_point returned at slot creation.

commit_lsn: Lsn

commit_lsn of the last applied transaction (Begin.final_lsn of a redelivered transaction is compared against this).

committed_lsn: Lsn

end_lsn of the last applied transaction.

acked_lsn: Lsn

Highest position reported to the server as flushed.

last_xid: Option<u32>

last_commit_ts: Option<i64>

PostgreSQL timestamp (µs since 2000-01-01) of the last applied commit.

txns_applied: u64

last_error: Option<String>

Implementations

impl Checkpoint

pub fn new_job( job_id: &str, source_system_id: &str, source_dbname: &str, slot: &str, publication: &str, ) -> Self

pub fn already_applied(&self, final_lsn: Lsn) -> bool

True when a transaction whose commit record is at final_lsn has already been applied and must be skipped.

pub fn record_commit( &mut self, commit_lsn: Lsn, end_lsn: Lsn, xid: u32, commit_ts: i64, )

Record a transaction commit. Keeps the invariants.

pub fn record_keepalive(&mut self, wal_end: Lsn) -> bool

Record a keepalive position as safe to acknowledge. Returns true if it advanced.

pub fn check_invariants(&self) -> Result<(), String>

Trait Implementations

impl Clone for Checkpoint

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Checkpoint

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Checkpoint

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Checkpoint

impl PartialEq for Checkpoint

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Checkpoint

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Checkpoint