Struct AgentServiceImpl 

pub struct AgentServiceImpl { /* private fields */ }

Implementation of the Agent service

Implementations

impl AgentServiceImpl

pub fn new( connectome_manager: Arc<RwLock<ConnectomeManager>>, agent_registry: Arc<RwLock<AgentRegistry>>, ) -> Self

pub fn new_with_runtime( connectome_manager: Arc<RwLock<ConnectomeManager>>, agent_registry: Arc<RwLock<AgentRegistry>>, runtime_service: Arc<dyn RuntimeServiceTrait + Send + Sync>, ) -> Self

Create AgentServiceImpl with runtime service

pub fn set_registration_handler( &mut self, handler: Arc<dyn RegistrationHandlerTrait>, )

Set the PNS registration handler for full transport negotiation Set registration handler (accepts trait object to break circular dependency)

pub fn set_runtime_service( &self, runtime_service: Arc<dyn RuntimeServiceTrait + Send + Sync>, )

Set the runtime service for sensory injection (thread-safe, can be called after Arc wrapping)

Trait Implementations

impl AgentService for AgentServiceImpl

fn register_agent<'life0, 'async_trait>( &'life0 self, registration: AgentRegistration, ) -> Pin<Box<dyn Future<Output = AgentResult<AgentRegistrationResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Register a new agent

fn heartbeat<'life0, 'async_trait>( &'life0 self, request: HeartbeatRequest, ) -> Pin<Box<dyn Future<Output = AgentResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Record a heartbeat for an agent

fn list_agents<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = AgentResult<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all registered agents

fn get_agent_properties<'life0, 'life1, 'async_trait>( &'life0 self, agent_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = AgentResult<AgentProperties>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get properties for a specific agent

fn get_shared_memory_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = AgentResult<HashMap<String, HashMap<String, Value>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get shared memory information for all agents

fn deregister_agent<'life0, 'life1, 'async_trait>( &'life0 self, agent_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = AgentResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Deregister an agent

fn manual_stimulation<'life0, 'async_trait>( &'life0 self, stimulation_payload: HashMap<String, Vec<Vec<i32>>>, mode: ManualStimulationMode, ) -> Pin<Box<dyn Future<Output = AgentResult<HashMap<String, Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Trigger manual stimulation for specific cortical areas

fn try_set_runtime_service( &self, runtime_service: Arc<dyn RuntimeServiceTrait + Send + Sync>, )

Set runtime service for sensory injection (optional, implementations can ignore if not needed) This allows runtime service to be connected after AgentService is wrapped in Arc