Struct SnapshotCursor 

pub struct SnapshotCursor { /* private fields */ }

Server-side cursor over one source’s reporting view, held open for the rebuild transaction so the snapshot is read in bounded batches.

Implementations

impl SnapshotCursor

pub async fn lock_sources(connection: &mut PgConnection) -> Result<()>

pub async fn open( connection: &mut PgConnection, definition: &'static SourceDefinition, ) -> Result<Self>

pub const fn definition(&self) -> &'static SourceDefinition

pub async fn fetch( &self, connection: &mut PgConnection, ) -> Result<Vec<SnapshotRow>>

pub async fn close(self, connection: &mut PgConnection) -> Result<()>

Trait Implementations

impl Clone for SnapshotCursor

fn clone(&self) -> SnapshotCursor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SnapshotCursor

impl Debug for SnapshotCursor

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

Formats the value using the given formatter.