Struct RedisPolicyStore 

pub struct RedisPolicyStore { /* private fields */ }

Redis-backed read-through PolicyStore.

get_policy reads a JSON PolicyDocument from aa:policy:<agent_id> and returns NotFound on a cache miss — callers fall through to the authoritative store and then repopulate the cache with cache_policy. invalidate deletes the cached key. Cheap to Clone — clones share the underlying Pool.

Implementations

impl RedisPolicyStore

pub fn new(pool: Pool) -> Self

Create a store over an existing connection pool.

pub async fn cache_policy( &self, agent_id: &AgentId, policy: &PolicyDocument, ttl_secs: u64, ) -> Result<()>

Populate the cache for agent_id with policy, expiring after ttl_secs seconds (SET ... EX).

This is the write half of the read-through cache: callers invoke it after loading a policy from the authoritative store on a get_policy miss. See DEFAULT_POLICY_CACHE_TTL_SECS for the suggested default TTL.

Trait Implementations

impl Clone for RedisPolicyStore

fn clone(&self) -> RedisPolicyStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl PolicyStore for RedisPolicyStore

fn get_policy<'life0, 'life1, 'async_trait>( &'life0 self, agent_id: &'life1 AgentId, ) -> Pin<Box<dyn Future<Output = Result<PolicyDocument>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return the effective policy for agent_id.

fn invalidate<'life0, 'life1, 'async_trait>( &'life0 self, agent_id: &'life1 AgentId, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Drop any cached policy for agent_id so the next read reloads it.