Struct UnifiedAgent 

pub struct UnifiedAgent {
    pub broadcast_emitter: Sender<NodeMessageTransporter>,
    pub broadcast_receiver: Arc<Mutex<Receiver<NodeMessageTransporter>>>,
    pub shutdown_send: UnboundedSender<String>,
    pub shutdown_recv: Arc<Mutex<UnboundedReceiver<String>>>,
    /* private fields */
}

Fields

broadcast_emitter: Sender<NodeMessageTransporter>

broadcast_receiver: Arc<Mutex<Receiver<NodeMessageTransporter>>>

shutdown_send: UnboundedSender<String>

shutdown_recv: Arc<Mutex<UnboundedReceiver<String>>>

Implementations

impl UnifiedAgent

pub fn new( config: Option<UnifiedAgentConfig>, config_path: Option<String>, on_message: Arc<dyn MessageHandler>, processor: Arc<dyn Processor>, on_event: Arc<dyn EventHandler>, ) -> Self

pub async fn send_direct(&self, to_peer: String, message: Vec<u8>)

pub async fn broadcast(&self, message: Vec<u8>)

pub fn details(&self) -> AgentDetail

pub async fn get_connected_agents(&self) -> Vec<AgentDetail>

pub async fn start( &self, inputs: Vec<u8>, agents: Option<Vec<Arc<UnifiedAgent>>>, )

pub async fn stop(&self)