Struct SnapshotCollector 

pub struct SnapshotCollector {
    schema: AppSchema,
    limits: SnapshotLimits,
    entity_index: usize,
    cursor: Option<Value>,
    records: Vec<Record>,
    bytes: u64,
}

Shared keyset pagination and accounting. Adapters must keep every page in the same database read transaction; separate calls to query are insufficient.

Fields

schema: AppSchema

limits: SnapshotLimits

entity_index: usize

cursor: Option<Value>

records: Vec<Record>

bytes: u64

Implementations

impl SnapshotCollector

pub fn new( schema: &AppSchema, limits: SnapshotLimits, ) -> Result<Self, DatabaseError>

pub fn next_query(&self) -> Result<Option<Query>, DatabaseError>

pub fn accept( &mut self, rows: Vec<Map<String, Value>>, ) -> Result<(), DatabaseError>

pub fn finish(self) -> Result<Vec<Record>, DatabaseError>