Struct Messaging 

pub struct Messaging { /* private fields */ }

Connection manager for miner WebSocket sessions. Each connected miner gets an mpsc::UnboundedSender that the WS task polls.

Implementations

impl Messaging

pub fn new() -> Arc<Messaging>

pub async fn register(&self, device_id: String, tx: UnboundedSender<String>)

Register a connected miner.

pub async fn unregister(&self, device_id: &str)

Remove a disconnected miner.

pub async fn connected_count(&self) -> usize

Number of currently connected miners.

pub async fn active_devices(&self) -> Vec<String>

List all connected device IDs.

pub async fn broadcast(&self, msg: &ValidatorMessage)

Push a message to every connected miner.

pub async fn send_to(&self, device_id: &str, msg: &ValidatorMessage)

Push a message to a specific miner.