Struct IncrementalSnapshotHandle 

pub struct IncrementalSnapshotHandle { /* private fields */ }

A StreamHandle that interleaves per-table chunk reads with the live replication stream using the DBLog watermark pattern.

Obtain an instance via PostgresConnection::start_incremental_snapshot.

Trait Implementations

impl StreamHandle for IncrementalSnapshotHandle

fn next_events<'life0, 'async_trait>( &'life0 mut self, timeout_ms: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn save_position<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint: &'life1 mut dyn Checkpoint, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn requeue_events<'life0, 'async_trait>( &'life0 mut self, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Requeue events so they are returned by a subsequent next_events call.

fn confirm_lsn<'life0, 'async_trait>( &'life0 mut self, lsn: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Confirm that all messages up to lsn have been durably consumed. Prevents WAL retention bloat on replication slots.

fn replication_slot_lag_bytes(&self) -> Option<u64>

Return the most recently observed replication slot WAL lag in bytes.