Struct CachingRoutingStore 

pub struct CachingRoutingStore { /* private fields */ }

Wraps any RoutingStore with a per-org RoutingEngine cache.

The cache also implements RoutingStore so callers can swap it in without changing wiring. Prefer CachingRoutingStore::engine_for when you actually want the pre-built engine — that’s the hot path.

Implementations

impl CachingRoutingStore

pub fn new(inner: Arc<dyn RoutingStore>) -> Self

pub fn with_ttl(inner: Arc<dyn RoutingStore>, ttl: Duration) -> Self

pub async fn engine_for( &self, org_id: Uuid, ) -> Result<Arc<RoutingEngine>, RoutingStoreError>

Hot path. Returns the cached engine for org_id when fresh, otherwise refreshes from the underlying store. Errors from the backend propagate — callers should treat them as “no routes” and dispatch unchanged.

pub async fn invalidate(&self, org_id: Uuid)

Manually drop the cached entry for org_id. Used by tests; could later be wired to an admin “force refresh” endpoint.

Trait Implementations

impl Debug for CachingRoutingStore

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

Formats the value using the given formatter.

impl RoutingStore for CachingRoutingStore

fn list_for_org<'life0, 'async_trait>( &'life0 self, org_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Route>, RoutingStoreError>> + Send + 'async_trait>>

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

Fetch the enabled-and-current route list for org_id. Returns Ok(vec![]) when the org has no routes — not an error.

fn list_all_for_org<'life0, 'async_trait>( &'life0 self, org_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Route>, RoutingStoreError>> + Send + 'async_trait>>

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

Management: ALL of an org’s routes, including disabled ones.

fn create_route<'life0, 'async_trait>( &'life0 self, org_id: Uuid, spec: NewRoute, ) -> Pin<Box<dyn Future<Output = Result<Route, RoutingStoreError>> + Send + 'async_trait>>

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

Management: create a route for org_id. Returns the created route.

fn get_route<'life0, 'async_trait>( &'life0 self, org_id: Uuid, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<Route>, RoutingStoreError>> + Send + 'async_trait>>

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

Management: fetch one route owned by org_id.

fn delete_route<'life0, 'async_trait>( &'life0 self, org_id: Uuid, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<bool, RoutingStoreError>> + Send + 'async_trait>>

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

Management: delete one route owned by org_id. Returns whether a row was removed.