Struct SessionLoopState 

pub struct SessionLoopState { /* private fields */ }

Per-session loop-detection state. Embedding/delta mutation happens on worker threads; the hot path reads SessionLoopState::state and SessionLoopState::action, and calls SessionLoopState::reset when an Inject verdict fires.

Implementations

impl SessionLoopState

pub fn new(cfg: BreakerConfig) -> Self

Create with cfg.

pub fn state(&self) -> BreakerState

Current breaker state (hot-path read).

pub fn action(&self) -> BreakerAction

Configured enforcement action when the breaker is open.

pub fn observe( &self, embedder: &dyn Embedder, text: &str, step_tokens: u64, ) -> BreakerVerdict

Observe one reasoning step (worker thread): embed, compute Δ against the previous step, update the streak, return the verdict.

pub fn observe_embedding( &self, embedding: Vec<f32>, step_tokens: u64, ) -> BreakerVerdict

Observe a precomputed embedding. Workers use this path when the same vector is also persisted to an off-path vector sink.

pub fn observe_embedding_with_similarity( &self, embedding: Vec<f32>, step_tokens: u64, nearest_similarity: Option<f32>, ) -> BreakerVerdict

Observe an embedding plus an optional nearest prior-step similarity (scoped to the same session) supplied by a distributed vector engine.

pub fn reset(&self)

Manually reset (e.g. after a corrective injection gave the agent a new direction). Clears the streak, the token floor, and closes the breaker.