Struct TurnObserver 

pub struct TurnObserver { /* private fields */ }

Captures observations during agent turns.

Implementations

impl TurnObserver

pub fn new(session_id: Option<String>) -> Self

Create a new TurnObserver.

pub fn find_marker(text: &str, markers: &[&str]) -> Option<usize>

Find the byte offset of the first matching marker phrase in text.

Searches case-insensitively. Returns Some(byte_offset) of the match start, or None if no marker is found.

pub fn capture_window( text: &str, marker_pos: usize, window_bytes: usize, ) -> String

Extract a context window centered on marker_pos.

Returns approximately window_bytes / 2 bytes before and after the marker, with the marker phrase centered. Respects UTF-8 char boundaries.

pub fn truncate_context(context: String, max_bytes: usize) -> String

👎Deprecated since 0.2.0:

Use find_marker + capture_window instead. This function keeps the head of the string, losing the actual signal.

Truncate context to fit max_bytes, appending a marker if truncated.

pub fn start_turn(&mut self)

Start a new turn.

pub fn record_correction(&mut self, context: String, intensity: f64)

Record a correction signal.

pub fn record_error(&mut self, context: String, intensity: f64)

Record an error signal.

pub fn record_satisfaction(&mut self, context: String, intensity: f64)

Record a satisfaction signal.

pub fn record_inefficiency(&mut self, context: String, intensity: f64)

Record an inefficiency signal.

pub fn current_observations(&self) -> &[Observation]

Get all observations for the current turn.

pub fn turn_number(&self) -> u32

Get the current turn number.

pub fn session_id(&self) -> Option<&str>

Get the session ID.

pub fn drain_observations(&mut self) -> Vec<Observation>

Drain observations from the current turn.