Struct AdminAgent 

pub struct AdminAgent {
    pub config: AdminAgentConfig,
    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

config: AdminAgentConfig

broadcast_emitter: Sender<NodeMessageTransporter>

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

shutdown_send: UnboundedSender<String>

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

Implementations

impl AdminAgent

pub fn new( config: AdminAgentConfig, 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 async fn start(&self, inputs: Vec<u8>, agents: Vec<Arc<WorkerAgent>>)

pub async fn stop(&self)

pub fn details(&self) -> AgentDetail