Struct Session

pub struct Session {
    pub id: SessionId,
    /* private fields */
}

Fields

id: SessionId

Implementations

impl Session

pub fn new(channel_buffer: usize) -> (SessionId, Self)

pub async fn add_task(&self, task: Task)

pub async fn set_current_task(&self, task: Task)

pub async fn is_task_queue_empty(&self) -> bool

pub async fn get_top_task(&self) -> Option<Task>

pub async fn get_current_task(&self) -> Option<Task>

pub async fn get_task(&self, sub_id: SubmissionId) -> Option<Task>

pub fn event_sender(&self) -> Sender<Event>

pub fn take_event_receiver(&mut self) -> Option<ReceiverStream<Event>>

pub async fn register_agent_with_id<E>( &self, agent_id: Uuid, agent: BaseAgent<E>, )

where E: AgentExecutor, E::Output: Into<Value> + Send, E::Error: Error + Send + Sync + 'static,

pub async fn run_task( &self, task: Option<Task>, agent_id: AgentID, ) -> Result<AgentRunResult, Error>

pub async fn run(&self, agent_id: Uuid) -> Result<AgentRunResult, Error>

pub async fn run_all( &self, agent_id: Uuid, ) -> Result<Vec<AgentRunResult>, Error>