Struct sage_broker::Session

pub struct Session { /* fields omitted */ }

Represents a client and holds all of its data, may it be active or not. If the client is connected, peer is used to retrieve its information and send him packets.

Implementations

impl Session

pub fn new(client_id: &str, peer: Arc<Peer>, cache: Arc<Cache>) -> Self

Creates a new session, giving a peer and an id

pub fn id(&self) -> &str

A unique ID that cannot be changed neither can collide with other instances of Session This ID is not part of MQTT specification but is used to ensure a new session can be created with a same client_id

pub fn client_id(&self) -> &str

Returns the client_id of the session

pub fn bind(&self, peer: Arc<Peer>)

Assign the session to another peer

pub fn peer(&self) -> Option<Arc<Peer>>

Gets the currently bound peer as as owning pointer

pub fn subs(&self) -> &RwLock<Subs>

Gets the subscriptions this session has

Trait Implementations

impl Debug for Session

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

Formats the value using the given formatter.