Struct CloudSubscriber 

pub struct CloudSubscriber {
    ctrl_tx: UnboundedSender<CtrlMsg>,
    agents: Arc<Mutex<HashSet<String>>>,
}

Fields

ctrl_tx: UnboundedSender<CtrlMsg>

agents: Arc<Mutex<HashSet<String>>>

In-memory copy of subscribed agents, kept in sync with the WS loop so add_agent/remove_agent can be called before the WS connects.

Implementations

impl CloudSubscriber

pub fn init_global(wstore: Arc<Store>)

Initialize the global subscriber and start the background WS loop. Should be called once at startup. No-op if already initialized.

pub fn add_agent(&self, agent_id: &str)

Notify the WS loop that a new agent is registered locally. Normalizes to lowercase and skips the WS send if already subscribed, so calling this on every COMMAND_AGENT_INPUT turn is safe.

pub fn remove_agent(&self, agent_id: &str)

Notify the WS loop that an agent has been unregistered.

pub fn reload_token(&self)

Called after muxbus.login completes — trigger a fresh WS connection with the newly stored token.

pub fn subscribed_agents(&self) -> Vec<String>

Snapshot of the agents this sidecar has subscribed to the cloud relay (Tier-4), sorted for stable output. Empty when no MUXBUS_TOKEN is set (cloud disabled). Read-only; used by the discovery endpoint.