Struct RpeRouter 

pub struct RpeRouter {
    pub threshold: f32,
    pub max_skip_turns: u32,
    /* private fields */
}

Stateful RPE router. Tracks recent embeddings and entity history.

Protected by the caller’s synchronization (typically held behind Arc<Mutex<...>> at the SemanticMemory layer).

Fields

threshold: f32

RPE below this value → skip extraction. Range: [0.0, 1.0].

max_skip_turns: u32

Force extraction after this many consecutive skips. Default: 5.

Implementations

impl RpeRouter

pub fn new(threshold: f32, max_skip_turns: u32) -> Self

pub fn push_embedding(&mut self, embedding: Vec<f32>)

Record a turn embedding. Called even when extraction is skipped, so context similarity remains up-to-date for the next turn.

pub fn push_entities(&mut self, names: &[String])

Record entity names extracted (or candidate names from text) for novelty tracking.

pub fn compute( &mut self, turn_embedding: &[f32], candidate_entities: &[String], ) -> RpeSignal

Compute the RPE signal for the current turn.

turn_embedding — embedding of the current message. candidate_entities — entity names extracted from the current message text (may be empty).

Returns the RPE signal. When recent_embeddings is empty (cold start), returns rpe_score = 1.0 and should_extract = true.