Struct TurnRunner 

pub struct TurnRunner<S: SessionStore> { /* private fields */ }

Executes a turn against a pooled connection.

Implementations

impl<S: SessionStore + 'static> TurnRunner<S>

pub fn new( pool: Arc<ConnectionPool<S>>, gate: QueryGate, classifier: EventClassifier, store: Arc<S>, cfg: Option<TurnConfig>, ) -> Self

Create a runner.

pub async fn execute( &self, session_id: &str, message: &str, user_id: &str, workspace_id: &str, attachments: Option<Value>, opts: Option<InputOpts>, ) -> Result<String>

Execute one turn for a session; returns concatenated assistant text when found.