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.

impl PageStrategy for OffsetPagination

type Request = u64

Exact request-position token for the next page.

type Observation<'observation> = OffsetPageObservation<'observation>

Decoded response observation, optionally borrowing provider state.

type Boundary = OffsetPageBoundary

Validated accepted page boundary.

fn next_request(&self) -> Result<Self::Request, PaginationError>

Returns the next request token or PaginationError::Complete.

fn observe<'observation>( &mut self, observation: Self::Observation<'observation>, ) -> Result<Self::Boundary, PaginationError>

Transactionally validates and accepts one response.