Struct DeviceRegistry 

pub struct DeviceRegistry { /* private fields */ }

Thread-safe set of attached devices.

Mirrors crate::session::SessionStore: an RwLock<HashMap<_, _>> rather than a concurrent-map dependency, since reads dominate and the map is small.

Implementations

impl DeviceRegistry

pub fn new() -> Self

Create an empty registry.

pub fn attach( &self, id: impl Into<String>, label: Option<String>, ) -> DeviceHandles

Attach a device under id, replacing any previous entry for it.

pub fn detach(&self, id: &str) -> bool

Detach a device, e.g. when its control connection closes.

pub fn get(&self, id: &str) -> Option<Arc<Device>>

Look up an attached device.

pub fn touch(&self, id: &str) -> bool

Record a heartbeat. Returns false if the device is not attached.

pub fn list(&self) -> Vec<DeviceSummary>

Snapshot of every attached device, newest attachment first.

pub fn count(&self) -> usize

Number of attached devices.

pub fn evict_stale(&self, timeout: Duration) -> Vec<String>

Drop devices that have not been heard from within timeout.

A half-open connection (the peer vanished without a close frame) is indistinguishable from an idle one at the socket level, so staleness is judged from heartbeats.

Trait Implementations

impl Clone for DeviceRegistry

fn clone(&self) -> DeviceRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DeviceRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DeviceRegistry

fn default() -> DeviceRegistry

Returns the “default value” for a type.