Struct SessionRunner 

pub struct SessionRunner { /* private fields */ }

Coordinator that drives run_agent while persisting the session after every turn. Implements TurnSink so the loop calls back after each turn.

Implementations

impl SessionRunner

pub fn new( adapter: Arc<dyn PersistenceAdapter>, session_id: SessionId, model: impl Into<String>, max_turns: usize, system_message: Option<String>, ) -> Self

Create a runner for a new or empty session.

pub async fn load( adapter: Arc<dyn PersistenceAdapter>, session_id: SessionId, ) -> RuntimeResult<Option<Self>>

Load a persisted session into a runner, if the adapter has one.

pub fn messages(&self) -> Vec<AgentMessage>

Snapshot the runner’s current messages.

pub fn model_id(&self) -> &str

The model id this session runs against.

pub fn max_turns(&self) -> usize

The max-turns budget for this session.

pub fn system_message(&self) -> Option<String>

The system message (instructions) for this session, if any.

Trait Implementations

impl TurnSink for SessionRunner

fn after_turn<'life0, 'life1, 'async_trait>( &'life0 self, _turn: usize, messages: &'life1 [AgentMessage], ) -> Pin<Box<dyn Future<Output = CoreResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called after turn turn (1-indexed) with the full message history so far. Returning Err aborts the run with that error.