Struct FiveSignalRuntime 

pub struct FiveSignalRuntime {
    pub weights: FiveSignalWeights,
    pub access_cache: AccessFrequencyCache,
    pub causal_computer: Mutex<CausalDistanceComputer>,
    pub novelty_computer: NoveltyComputer,
    pub metrics: Arc<FiveSignalMetrics>,
    pub pool: DbPool,
    pub qdrant: Option<Arc<EmbeddingStore>>,
    pub session_start: i64,
    pub session_id: SessionId,
    pub config: FiveSignalConfig,
}

Runtime state for the five-signal retrieval subsystem.

Created once at bootstrap when five_signal.enabled = true and attached to crate::semantic::SemanticMemory via an Option<Arc<FiveSignalRuntime>>. None when disabled — guarantees zero overhead per NFR-005.

Fields

weights: FiveSignalWeights

Normalized signal weights (computed once at startup).

access_cache: AccessFrequencyCache

Access frequency aggregator.

causal_computer: Mutex<CausalDistanceComputer>

Causal distance computer (contains BFS cache per goal entity).

novelty_computer: NoveltyComputer

Novelty computer (pure arithmetic, no I/O).

metrics: Arc<FiveSignalMetrics>

Prometheus-compatible counters.

pool: DbPool

SQLite pool (shared with the rest of SemanticMemory).

qdrant: Option<Arc<EmbeddingStore>>

Qdrant store (optional; used by the consolidation daemon).

session_start: i64

Unix timestamp of session start, used by NoveltyComputer.

session_id: SessionId

Session identifier used to scope fact_access_log inserts and queries.

Set at bootstrap from a per-process UUID so access counts are isolated per session and do not bleed across process restarts.

config: FiveSignalConfig

Config snapshot (used by the consolidation daemon).

Implementations

impl FiveSignalRuntime

pub fn new( config: FiveSignalConfig, pool: DbPool, graph_store: Arc<GraphStore>, qdrant: Option<Arc<EmbeddingStore>>, session_start: i64, session_id: impl Into<SessionId>, ) -> Self

Create a new runtime from config, pool, and optional graph + Qdrant stores.

Normalizes signal weights (logging WARN if they do not sum to 1.0). Logs a WARN if consolidation_daemon.top_k_per_run < batch_size (MINOR-03).

Examples

use std::sync::Arc;
use zeph_config::memory::FiveSignalConfig;
use zeph_memory::five_signal::FiveSignalRuntime;

let cfg = FiveSignalConfig::default();
let session_start = std::time::SystemTime::now()
    .duration_since(std::time::UNIX_EPOCH)
    .map_or(0, |d| d.as_secs() as i64);
let session_id = uuid::Uuid::new_v4().to_string();
let runtime = FiveSignalRuntime::new(cfg, pool, graph, None, session_start, session_id);