Struct RuntimeRunner 

pub struct RuntimeRunner { /* private fields */ }

Orchestrates the agentic turn loop via the runtime kernel + session event log.

Implementations

impl RuntimeRunner

pub fn new(opts: RuntimeOptions) -> Self

pub fn interrupt(&self)

pub fn interrupt_with_reason(&self, reason: CancellationReason)

pub fn execution_plane(&self) -> &dyn ExecutionPlane

pub async fn write_memory( &self, memory: MemoryRecord, session_id: Option<&str>, agent_id: Option<&str>, ) -> Result<()>

pub async fn query_memory( &self, query: MemoryQuery, session_id: Option<&str>, agent_id: Option<&str>, ) -> Result<Vec<MemoryRecall>>

pub async fn execute(&self, goal: &str) -> Result<String>

pub async fn execute_with_criteria( &self, goal: &str, criteria: &[String], ) -> Result<String>

pub async fn run_streaming<'a>( &'a self, goal: &'a str, criteria: &'a [String], extensions: Option<&'a Value>, session_id: Option<&'a str>, ) -> Result<Pin<Box<dyn Stream<Item = Result<RunEvent>> + 'a>>>

pub async fn run_streaming_with_attachments<'a>( &'a self, goal: &'a str, criteria: &'a [String], extensions: Option<&'a Value>, session_id: Option<&'a str>, attachments: &'a [ContentPart], ) -> Result<Pin<Box<dyn Stream<Item = Result<RunEvent>> + 'a>>>

Like Self::run_streaming, but seeds multimodal attachments into kernel history before the first render (parity with Node/Python run({ attachments })).

pub async fn wake_streaming( &self, session_id: &str, extensions: Option<&Value>, ) -> Result<Pin<Box<dyn Stream<Item = Result<RunEvent>> + '_>>>

pub async fn wake(&self, session_id: &str) -> Result<String>