Struct ParallelLookupExecutor 

pub struct ParallelLookupExecutor { /* private fields */ }

Executes parallel DHT provider lookups with integrated caching.

Implementations

impl ParallelLookupExecutor

pub fn new(cache: Arc<LookupCache>, config: ParallelLookupConfig) -> Arc<Self>

Create a new ParallelLookupExecutor wrapped in an Arc.

pub async fn lookup<F, Fut>( &self, cid_str: &str, now_ms: u64, query_fn: F, ) -> ParallelLookupResult

where F: Fn(String) -> Fut + Send + Sync, Fut: Future<Output = Vec<String>> + Send,

Look up providers for cid_str, using the cache first.

Cache hit

Returns immediately with from_cache = true and lookup_count = 0.

Cache miss

Runs alpha parallel calls to query_fn(cid_str), merges and deduplicates the results, stores them in the cache, and returns with from_cache = false and lookup_count = alpha.

pub fn cache_saves(&self) -> u64

Total number of cache hits served (lookups avoided).

pub fn total_lookups(&self) -> u64

Total number of lookup calls (cache hit or miss).