Struct TaskRegistry 

pub struct TaskRegistry { /* private fields */ }

Implementations

impl TaskRegistry

pub fn new(persistence: Arc<dyn Persistence>) -> Self

pub fn with_parent_session(self, parent_id: SessionId) -> Self

pub fn with_ttl(self, ttl: Duration) -> Self

pub async fn register( &self, id: String, agent_type: String, description: String, ) -> Receiver<()>

pub async fn set_handle(&self, id: &str, handle: JoinHandle<()>)

pub async fn complete(&self, id: &str, result: AgentResult)

pub async fn fail(&self, id: &str, error: String)

pub async fn cancel(&self, id: &str) -> bool

pub async fn get_status(&self, id: &str) -> Option<SessionState>

pub async fn get_result( &self, id: &str, ) -> Option<(SessionState, Option<String>, Option<String>)>

pub async fn wait_for_completion( &self, id: &str, timeout: Duration, ) -> Option<(SessionState, Option<String>, Option<String>)>

pub async fn list_running(&self) -> Vec<(String, String, Duration)>

pub async fn cleanup_completed(&self) -> usize

pub async fn running_count(&self) -> usize

pub async fn save_messages(&self, id: &str, messages: Vec<Message>)

pub async fn get_messages(&self, id: &str) -> Option<Vec<Message>>

pub async fn get_session(&self, id: &str) -> Option<Session>

Trait Implementations

impl Clone for TaskRegistry

fn clone(&self) -> TaskRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.