Struct InventoryCache 

pub struct InventoryCache { /* private fields */ }

In-memory inventory cache with a freshness window (design D2).

Owned by the supervisor’s sweep loop: the sweep stores a fresh snapshot at its cadence, and /tell / /agents reuse the cached snapshot while it is younger than max_age, rebuilding on demand only when stale. There is no on-disk cache — a supervisor restart produces a fresh inventory.

Implementations

impl InventoryCache

pub fn new(max_age: Duration) -> Self

Creates an empty cache with the given freshness window.

pub fn from_seconds(seconds: u64) -> Self

Creates an empty cache with a freshness window in seconds (the [supervisor.tell] inventory_max_age_seconds config value).

pub fn max_age(&self) -> Duration

The configured freshness window.

pub fn snapshot(&self) -> Option<&AgentInventory>

The cached snapshot, if any.

pub fn is_fresh_at(&self, now: Instant) -> bool

Whether the cache holds a snapshot still within max_age as of now.

pub fn store(&mut self, snapshot: AgentInventory)

Stores a freshly-built snapshot (called by the sweep loop).

pub fn get_or_refresh<F, E>( &mut self, now: Instant, refresh: F, ) -> Result<&AgentInventory, E>

where F: FnOnce() -> Result<AgentInventory, E>,

Returns the cached snapshot when fresh as of now; otherwise calls refresh to rebuild it, stores the result, and returns it.

refresh is invoked at most once per stale lookup, so rapid consecutive /agents within the freshness window trigger only one rebuild (the broker is not re-polled while the snapshot is fresh).

Errors

Propagates any error from refresh; the previous snapshot (if any) is left untouched on failure.

Panics

Does not panic in practice: when the cache is stale refresh populates the snapshot before it is unwrapped, so the Some invariant holds.

Trait Implementations

impl Debug for InventoryCache

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

Formats the value using the given formatter.