Struct AccessFrequencyCache 

pub struct AccessFrequencyCache { /* private fields */ }

Per-turn access frequency aggregator backed by fact_access_log.

Loads raw access counts for a candidate set in a single GROUP BY query per turn. Normalized values are log(1 + count) / log(1 + MAX_ACCESS_COUNT) ∈ [0.0, 1.0].

Implementations

impl AccessFrequencyCache

pub fn new(pool: DbPool) -> Self

Create a new cache backed by the given pool.

pub async fn load_for_candidates( &self, session_id: &str, fact_ids: &[MessageId], ) -> Result<HashMap<MessageId, f64>, MemoryError>

Load and normalize access counts for fact_ids within session_id.

Issues a single SQL GROUP BY query indexed by (session_id, accessed_at DESC). Returns a map of fact_id → normalized_score ∈ [0.0, 1.0].

Errors

Returns an error if the database query fails.

pub async fn log_access( &self, fact_id: MessageId, fact_type: &str, session_id: &str, )

Record a fact access event in fact_access_log.

Failures are logged as WARN and do not propagate — access logging is non-critical.