Struct OffsetPagination 

pub struct OffsetPagination { /* private fields */ }

Stateful offset strategy with fixed page size and total metadata.

This type is intentionally neither Copy nor Clone.

Implementations

impl OffsetPagination

pub fn new( first_offset: u64, expected_page_size: u64, budget: PaginationBudget, ) -> Result<Self, PaginationError>

Starts an offset traversal.

pub const fn next_offset(&self) -> Result<u64, PaginationError>

Returns the offset the caller must request next.

pub const fn progress(&self) -> PaginationProgress

Returns accepted counters.

pub fn observe( &mut self, metadata: OffsetPageMetadata, entries: usize, rate_limit: Option<RateLimit>, snapshot: Option<SnapshotId<'_>>, ) -> Result<OffsetPageBoundary, PaginationError>

Validates one response transactionally, then advances the strategy.

Trait Implementations

impl Debug for OffsetPagination

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

Formats the value using the given formatter.