Struct BatchCidResolver 

pub struct BatchCidResolver {
    pub cache_ttl: Duration,
    pub max_batch_size: usize,
    pub stats: Arc<BatchResolverStats>,
    /* private fields */
}

Batches CID provider lookups and caches results with TTL-based expiry.

Thread safety

All internal state is guarded by Mutex; the struct itself can be shared behind an Arc without additional synchronization.

Fields

cache_ttl: Duration

Time-to-live applied to newly stored cache entries

max_batch_size: usize

Maximum number of pending items consumed per drain_batch call

stats: Arc<BatchResolverStats>

Operational statistics

Implementations

impl BatchCidResolver

pub fn new() -> Self

Create a new resolver with default TTL (5 min) and batch size (32).

pub fn with_config(cache_ttl: Duration, max_batch_size: usize) -> Self

Create a resolver with custom TTL and batch size.

pub fn queue_lookup(&self, cid: &str) -> LookupHandle

Queue a CID for resolution.

Returns a LookupHandle the caller can use to track the request. If the CID is already in the cache the item is still queued; callers should call get_cached first if they want to avoid duplicate work.

pub fn drain_batch(&self) -> Vec<PendingLookup>

Atomically drain up to max_batch_size pending lookups.

Returns the drained items in FIFO order. Increments total_batches_drained only when at least one item is returned.

pub fn record_result(&self, cid: &str, providers: Vec<String>)

Store a resolved provider list for cid.

Any existing entry (including unexpired ones) is overwritten.

pub fn get_cached(&self, cid: &str) -> Option<Vec<String>>

Return the cached provider list for cid if it has not expired.

pub fn evict_expired(&self)

Remove all cache entries that have exceeded their TTL.

pub fn pending_count(&self) -> usize

Return the number of CIDs currently in the pending queue.

pub fn cache_size(&self) -> usize

Return the number of entries currently held in the cache (expired entries are counted until evict_expired is called).

Trait Implementations

impl Default for BatchCidResolver

fn default() -> Self

Returns the “default value” for a type.