Struct Orchestrator 

pub struct Orchestrator { /* private fields */ }

Implementations

impl Orchestrator

pub fn new(config: Config, api: Api, sessions: SessionService) -> Self

pub fn api(&self) -> &Api

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

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

pub async fn initialize_until_ready(&self)

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

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

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

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

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>

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

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

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

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

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

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

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

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