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 execution_plane(&self) -> &dyn ExecutionPlane

pub async fn write_memory( &self, memory: MemoryWriteRequest, 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<MemoryEntry>>

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 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>

pub async fn dream(&self, agent_id: &str, now_ms: u64) -> Result<DreamResult>