Struct AgentSystem 

pub struct AgentSystem { /* private fields */ }

Orchestrates multiple agents working together

Implementations

impl AgentSystem

pub fn new() -> Self

Create a new agent system with default configuration

pub fn with_config(config: AgentSystemConfig) -> Self

Create a new agent system with custom configuration

pub async fn register_agent( &self, agent: Arc<dyn Agent>, ) -> Result<(), AgentError>

Register a new agent with the system

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

Unregister an agent from the system

pub async fn process_with_agent( &self, agent_id: &AgentId, observation: Observation, ) -> Result<Option<Action>, AgentError>

Process an observation with a specific agent

pub async fn broadcast( &self, observation: Observation, ) -> HashMap<AgentId, Result<Option<Action>, AgentError>>

Broadcast an observation to all agents and collect their actions

pub fn config(&self) -> Result<AgentSystemConfig, AgentError>

Get the configuration

pub fn update_config(&self, config: AgentSystemConfig) -> Result<(), AgentError>

Update the configuration

pub fn metrics(&self) -> Result<AgentSystemMetrics, AgentError>

Get the system metrics

Trait Implementations

impl Default for AgentSystem

fn default() -> Self

Returns the “default value” for a type.