Struct MultiAgentSession 

pub struct MultiAgentSession {
    pub agents: Arc<DashMap<AgentId, Arc<AISession>>>,
    pub message_bus: Arc<MessageBus>,
    pub task_distributor: Arc<TaskDistributor>,
    pub resource_manager: Arc<ResourceManager>,
}

Multi-agent session coordinator

Fields

agents: Arc<DashMap<AgentId, Arc<AISession>>>

Active agent sessions

message_bus: Arc<MessageBus>

Message bus for inter-agent communication

task_distributor: Arc<TaskDistributor>

Task distributor

resource_manager: Arc<ResourceManager>

Resource manager

Implementations

impl MultiAgentSession

pub fn new() -> Self

Create a new multi-agent session

pub fn register_agent( &self, agent_id: AgentId, session: Arc<AISession>, ) -> Result<()>

Register an agent

pub fn unregister_agent(&self, agent_id: &AgentId) -> Result<()>

Unregister an agent

pub fn get_agent(&self, agent_id: &AgentId) -> Option<Arc<AISession>>

Get an agent session

pub fn list_agents(&self) -> Vec<AgentId>

List all agents

pub async fn send_message( &self, from: AgentId, to: AgentId, message: Message, ) -> Result<()>

Send a message to an agent

pub async fn broadcast( &self, from: AgentId, message: BroadcastMessage, ) -> Result<()>

Broadcast a message to all agents

Trait Implementations

impl Default for MultiAgentSession

fn default() -> Self

Returns the “default value” for a type.