Struct IndexingCache 

pub struct IndexingCache { /* private fields */ }

Cache for agent and workspace IDs during batch indexing.

Prevents N+1 database queries by caching the results of ensure_agent and ensure_workspace calls within a batch. This is per-batch and single-threaded, so no synchronization is needed.

Usage

let mut cache = IndexingCache::new();
for conv in conversations {
    let agent_id = cache.get_or_insert_agent(storage, &agent)?;
    let workspace_id = cache.get_or_insert_workspace(storage, workspace)?;
    // ... use agent_id and workspace_id
}

Rollback

Set environment variable CASS_SQLITE_CACHE=0 to bypass caching and use direct DB calls (useful for debugging).

Implementations

impl IndexingCache

pub fn new() -> Self

Create a new empty cache.

pub fn is_enabled() -> bool

Check if caching is enabled via environment variable. Returns true unless CASS_SQLITE_CACHE is set to “0” or “false”.

pub fn get_or_insert_agent<S>( &mut self, storage: &S, agent: &Agent, ) -> Result<i64>

where S: IndexingCacheStorage + ?Sized,

Get or insert an agent ID, using cache if available.

Returns the cached ID if present, otherwise calls ensure_agent and caches the result.

pub fn get_or_insert_workspace( &mut self, storage: &(impl IndexingCacheStorage + ?Sized), path: &Path, display_name: Option<&str>, ) -> Result<i64>

Get or insert a workspace ID, using cache if available.

Returns the cached ID if present, otherwise calls ensure_workspace and caches the result.

pub fn stats(&self) -> (u64, u64, f64)

Get cache statistics: (hits, misses, hit_rate).

pub fn clear(&mut self)

Clear the cache, resetting all state.

pub fn agent_count(&self) -> usize

Number of cached agents.

pub fn workspace_count(&self) -> usize

Number of cached workspaces.

Trait Implementations

impl Debug for IndexingCache

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

Formats the value using the given formatter.

impl Default for IndexingCache

fn default() -> IndexingCache

Returns the “default value” for a type.