Struct Runtime 

pub struct Runtime { /* private fields */ }

Implementations

impl Runtime

pub fn new( config: Config, control: Arc<Orchestrator>, roots: DirectoryRoots, ) -> Self

pub async fn run(self: Arc<Self>) -> Result<()>

Methods from Deref<Target = Orchestrator>

pub fn api(&self) -> &Api

pub fn writer(&self) -> &Arc<Mutex<()>>

pub async fn run(self: Arc<Orchestrator>) -> Result<(), Error>

pub async fn initialize_until_ready(&self)

pub fn runtime(&self) -> Result<&SessionRuntime, Error>

pub async fn open_session( &self, runtime: SessionRuntime, options: SessionOptions, restored: Option<&Value>, ) -> Result<Session, Error>

pub async fn pending_stop( &self, session_id: &str, ) -> Result<Option<SessionStopRequest>, Error>

pub async fn complete_pending_stop( &self, session_id: &str, outcome: Value, ) -> Result<(), Error>

pub async fn operation_is_active(&self, session_id: &str) -> bool

pub async fn register_operation(&self, session_id: &str, operation_id: Uuid)

pub async fn remove_operation(&self, session_id: &str, operation_id: Uuid)

pub async fn run_session_turn<C, F>( &self, session_id: &str, session: &mut Session, operation_id: Uuid, checkpoint: C, ) -> Result<TurnCompletion, Error>

where C: FnMut(Value) -> F + Send, F: Future<Output = Result<(), Error>> + Send,

pub async fn list_history(&self) -> Result<Vec<SessionRecord>, Error>

pub async fn conversation_lock(&self, id: &str) -> Arc<Mutex<()>>

pub async fn session_for_record( &self, record: &SessionRecord, ) -> Result<Session, Error>

pub async fn close_conversation( &self, record: &Arc<Mutex<SessionRecord>>, session: &Session, ) -> Result<(), Error>

pub async fn request_conversation_ingress( &self, record: &Arc<Mutex<SessionRecord>>, state: Option<Value>, ) -> Result<(), Error>

pub async fn get_conversation(&self, id: &str) -> Result<SessionRecord, Error>

pub async fn get_listed_conversation( &self, id: &str, ) -> Result<Option<SessionRecord>, Error>

Trait Implementations

impl Deref for Runtime

type Target = Orchestrator

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.