Struct ClientInfo 

pub struct ClientInfo {
    pub id: Uuid,
    pub subscription: Option<Subscription>,
    pub last_seen: SystemTime,
    pub sender: Sender<Message>,
    pub auth_context: Option<AuthContext>,
    pub remote_addr: SocketAddr,
    /* private fields */
}

Information about a connected client

Fields

id: Uuid

subscription: Option<Subscription>

last_seen: SystemTime

sender: Sender<Message>

auth_context: Option<AuthContext>

Authentication context for this client

remote_addr: SocketAddr

Client’s IP address for rate limiting

Implementations

impl ClientInfo

pub fn new( id: Uuid, sender: Sender<Message>, auth_context: Option<AuthContext>, remote_addr: SocketAddr, ) -> Self

pub fn record_egress(&self, bytes: usize) -> Option<u64>

Record bytes sent, returning true if within limit

pub fn record_inbound_message(&self) -> Option<u32>

Record an inbound client message, returning true if within limit.

pub fn update_last_seen(&mut self)

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

pub async fn add_subscription( &self, sub_key: String, token: CancellationToken, ) -> bool

pub async fn remove_subscription(&self, sub_key: &str) -> bool

pub async fn cancel_all_subscriptions(&self)

pub async fn subscription_count(&self) -> usize

Trait Implementations

impl Debug for ClientInfo

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

Formats the value using the given formatter.