Struct BatchResolver 

pub struct BatchResolver<T: Clone + Send> { /* private fields */ }

A DataLoader that batches and caches item lookups.

Items are queued individually via queue(), then fetched all at once with resolve_all(). Subsequent lookups of cached keys skip the loader.

Implementations

impl<T: Clone + Send + 'static> BatchResolver<T>

pub fn new( loader: Arc<dyn BatchLoader<Item = T>>, max_batch_size: usize, ) -> Self

Create a new BatchResolver with the given loader and maximum batch size.

max_batch_size controls how many keys are sent per load_batch call. A value of 0 is treated as unlimited (all queued keys in one batch).

pub fn queue(&mut self, key: impl Into<String>)

Add a key to the pending queue.

Duplicates are ignored: a key already in the cache or already queued will not be queued again.

pub fn resolve_all(&mut self) -> Result<(), BatchError>

Execute all pending batches, populating the internal cache.

Keys are split into batches of at most max_batch_size and passed to the loader. After this call pending_count() returns 0.

pub fn get(&self, key: &str) -> Option<&T>

Retrieve a cached item by key.

Returns None if the key was never resolved or was missing from the loader.

pub fn cache_size(&self) -> usize

Number of items in the cache.

pub fn clear_cache(&mut self)

Clear the internal cache (does not clear the queue).

pub fn pending_count(&self) -> usize

Number of keys currently pending resolution.

pub fn batches_executed(&self) -> usize

Total number of load_batch calls made so far.