Struct Device 

pub struct Device {
    pub id: String,
    pub label: Option<String>,
    /* private fields */
}

A device attached to the relay.

Held behind an Arc: the control session, the pool, and every in-flight request all refer to the same entry, and the data connections cannot be cloned.

Fields

id: String

Relay-assigned identifier; also the routing key in /d/<id>/….

label: Option<String>

Optional label the device supplied, for operator-facing logs.

Implementations

impl Device

pub fn is_stale(&self, timeout: Duration) -> bool

Whether the device has missed heartbeats for longer than timeout.

pub fn touch(&self)

Record that the device is alive.

pub async fn offer(&self, conn: WebSocket) -> Option<WebSocket>

Offer a freshly opened data connection to the pool.

Returns the connection back if the pool is full, so the caller can close it rather than leak it.

pub async fn take(&self, timeout: Duration) -> Option<WebSocket>

Take an idle data connection, waiting up to timeout for one.

Asks the device to open a replacement first: the request that consumes a connection is exactly the event that makes the pool one short.

Trait Implementations

impl Debug for Device

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

Formats the value using the given formatter.