Struct MonitorRegistry 

pub struct MonitorRegistry {
    pub monitors: Mutex<HashMap<String, Vec<MonitorSub>>>,
    pub conns: Mutex<HashMap<u64, Sender<Vec<u8>>>>,
}

Active connection channels and monitor subscriptions managed by the server.

Fields

monitors: Mutex<HashMap<String, Vec<MonitorSub>>>

PV name → list of active monitor subscriptions.

conns: Mutex<HashMap<u64, Sender<Vec<u8>>>>

Connection id → message sender.

Implementations

impl MonitorRegistry

pub fn new() -> MonitorRegistry

pub async fn send_msg(&self, conn_id: u64, msg: Vec<u8>)

Send a raw message to a connection.

pub async fn notify_monitors(&self, pv_name: &str, payload: &NtPayload)

Broadcast a monitor update for pv_name to all running subscribers.

pub async fn send_monitor_update_for( &self, pv_name: &str, conn_id: u64, ioid: u32, payload: &NtPayload, )

Send a monitor update to a specific subscriber.

pub async fn update_monitor_subscription( &self, conn_id: u64, ioid: u32, pv_name: &str, running: bool, nfree: Option<u32>, pipeline_enabled: Option<bool>, ) -> bool

Update a monitor subscription’s running/pipeline state.

pub async fn remove_monitor_subscription( &self, conn_id: u64, ioid: u32, pv_name: &str, )

Remove a monitor subscription.

pub async fn cleanup_connection(&self, conn_id: u64)

Remove all subscriptions and connection entries for a given connection.