Struct WorkerConnection 

pub struct WorkerConnection {
    pub key: WorkerConnectionKey,
    pub sender: Sender<Message>,
    /* private fields */
}

Models an active, authenticated worker WebSocket connection.

Fields

key: WorkerConnectionKey

Authentication metadata.

sender: Sender<Message>

Channel sender to push frames onto the worker’s writer loop.

Implementations

impl WorkerConnection

pub fn new( key: WorkerConnectionKey, sender: Sender<Message>, now_ms: u64, ) -> Self

Creates a new worker connection handle.

pub fn new_in_cluster( key: WorkerConnectionKey, cluster_id: ClusterId, sender: Sender<Message>, now_ms: u64, ) -> Self

Creates a worker connection bound to an explicit cluster.

pub fn cluster_id(&self) -> Option<&ClusterId>

Returns the cluster bound during authenticated connection setup.

pub fn update_heartbeat(&self, now_ms: u64)

Updates the heartbeat timestamp.

pub fn last_heartbeat(&self) -> u64

Gets the last heartbeat timestamp.

pub fn send(&self, message: Message) -> Result<(), GatewayError>

Sends a WebSocket message to the worker.

Trait Implementations

impl Clone for WorkerConnection

fn clone(&self) -> WorkerConnection

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerConnection

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

Formats the value using the given formatter.