Struct PaginationCache 

pub struct PaginationCache<T, M = ()> { /* private fields */ }

Two-level locking pagination cache generic over result T and optional meta M.

The meta type M allows storing additional per-query context alongside results, such as warnings or metadata from the original query.

Implementations

impl<T, M> PaginationCache<T, M>

pub fn new() -> Self

Create a new empty pagination cache.

pub fn remove_if_same(&self, key: &str, candidate: &Arc<QueryLock<T, M>>)

Remove entry if it still points to the provided Arc.

This is safe for concurrent access - only removes if the current entry is the exact same Arc, preventing removal of a replaced entry.

impl<T, M: Default> PaginationCache<T, M>

pub fn get_or_create(&self, key: &str) -> Arc<QueryLock<T, M>>

Get or create the per-query lock for the given key.

If a lock already exists for this key, returns a clone of its Arc. Otherwise creates a new QueryLock and returns it.

pub fn sweep_expired(&self)

Opportunistic sweep: remove expired entries.

Call this periodically to clean up stale cache entries. Each expired entry is only removed if it hasn’t been replaced.

Trait Implementations

impl<T: Default, M: Default> Default for PaginationCache<T, M>

fn default() -> PaginationCache<T, M>

Returns the “default value” for a type.