Struct AuthCache 

pub struct AuthCache {
    inner: Arc<RwLock<HashMap<String, AuthEntry>>>,
    locks: Arc<Mutex<HashMap<String, Arc<Mutex<()>>>>>,
}

A time-bounded, per-request-key cache for authorization decisions.

Wraps arbitrary async validator functions so that the (potentially expensive) Python callback is only invoked once per (access_key, bucket, query) tuple within the configured TTL window.

Concurrent cache misses for the same key are serialized via a per-key [Mutex] to avoid thundering-herd stampedes.

Fields

inner: Arc<RwLock<HashMap<String, AuthEntry>>>

locks: Arc<Mutex<HashMap<String, Arc<Mutex<()>>>>>

Implementations

impl AuthCache

pub fn new() -> Self

pub async fn get_or_validate<F, Fut, E>( &self, key: &str, ttl: Duration, validator_fn: F, ) -> Result<bool, E>

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<bool, E>> + Send, E: Debug,

pub fn insert(&self, key: String, authorized: bool, ttl: Duration)

Pre-populate the cache with a known decision for key.

pub fn invalidate(&self, key: &str)

Evict the cached entry for key, forcing re-validation on the next request.

Trait Implementations

impl Clone for AuthCache

fn clone(&self) -> AuthCache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AuthCache

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AuthCache

fn default() -> Self

Returns the “default value” for a type.