Struct CacheService 

pub struct CacheService { /* private fields */ }

Implementations

impl CacheService

pub fn new(config: Arc<Config>) -> Self

Create a new cache service with the given configuration.

Note: This cannot fail - moka cache creation is infallible.

pub async fn get(&self, domain: &str) -> Option<WhoisResponse>

Get a cached response for a domain.

Returns Some(response) with cached=true if found, None otherwise.

pub async fn set(&self, domain: &str, response: &WhoisResponse)

Store a response in the cache.

pub async fn get_or_fetch<F, Fut>( &self, domain: &str, fetch_fn: F, ) -> Result<WhoisResponse, WhoisError>

where F: FnOnce() -> Fut, Fut: Future<Output = Result<WhoisResponse, WhoisError>>,

Get cached response or fetch with automatic deduplication.

If multiple concurrent requests for the same domain arrive, only ONE fetch operation will be executed. All other requests will wait for and share the same result. This prevents thundering herd problems and reduces load on WHOIS/RDAP servers.

Arguments

• domain - The domain to lookup
• fetch_fn - Async function that performs the actual lookup

Returns

WhoisResponse with cached field set appropriately