Method read

src/secrets/src/cache.rs:157–184

(&self, id: CatalogItemId)

#[async_trait]
impl SecretsReader for CachingSecretsReader {
    async fn read(&self, id: CatalogItemId) -> Result<Vec<u8>, anyhow::Error> {
        // Iff our cache is enabled will we read from it.
        if self.policy.enabled() {
            let read_guard = self.cache.read().expect("CachingSecretsReader panicked!");
            let ttl = self.policy.ttl();

            // If we have a cached value we still need to check if it's expired.
            if let Some(CacheItem { secret, ts }) = read_guard.get(&id) {
                if Instant::now().duration_since(*ts) < ttl {
                    return Ok(secret.clone());
                }
            }
        }

        // Otherwise, we need to read from source!
        let value = self.inner.read(id).await?;

        // Cache it, if caching is enabled.
        if self.policy.enabled() {
            let cache_value = CacheItem::new(value.clone(), Instant::now());
            self.cache
                .write()
                .expect("CachingSecretsReader panicked!")
                .insert(id, cache_value);
        }

        Ok(value)
    }
}

#[cfg(test)]