Struct WorkerAgent 

pub struct WorkerAgent {
    pub config: WorkerAgentConfig,
    pub broadcast_emitter: Sender<NodeMessageTransporter>,
    pub broadcast_receiver: Arc<Mutex<Receiver<NodeMessageTransporter>>>,
    /* private fields */
}

Fields

config: WorkerAgentConfig

broadcast_emitter: Sender<NodeMessageTransporter>

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

Implementations

impl WorkerAgent

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

pub async fn start(&self, _inputs: Vec<u8>)

pub async fn stop(&self)

pub fn details(&self) -> AgentDetail

impl WorkerAgent

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

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

pub async fn run_with_config( &self, inputs: Vec<u8>, worker_agent_config: WorkerAgentConfig, runtime: Handle, cancellation_token: CancellationToken, ) -> Vec<JoinHandle<()>>