Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Session manager for tracking all client sessions

Implementations

impl SessionManager

pub fn new(max_connections: usize, metrics: Option<Arc<MqttMetrics>>) -> Self

Create a new session manager

pub async fn connect( &self, client_id: String, clean_session: bool, keep_alive: u16, sender: ClientSender, ) -> Result<(bool, ConnackCode), ConnackCode>

Handle a new client connection

pub async fn disconnect(&self, client_id: &str)

Handle client disconnect

pub async fn subscribe( &self, client_id: &str, subscriptions: Vec<(String, QoS)>, ) -> Option<Vec<SubackReturnCode>>

Handle SUBSCRIBE packet

pub async fn unsubscribe( &self, client_id: &str, topic_filters: Vec<String>, ) -> bool

Handle UNSUBSCRIBE packet

pub async fn publish(&self, publisher_id: &str, publish: &PublishPacket)

Handle PUBLISH packet - route to subscribers

pub async fn handle_puback(&self, client_id: &str, packet_id: u16)

Handle PUBACK from client

pub async fn handle_pubrec(&self, client_id: &str, packet_id: u16) -> bool

Handle PUBREC from client (QoS 2 step 1)

pub async fn handle_pubrel(&self, client_id: &str, packet_id: u16) -> bool

Handle PUBREL from client (QoS 2 step 2)

pub async fn handle_pubcomp(&self, client_id: &str, packet_id: u16)

Handle PUBCOMP from client (QoS 2 step 3)

pub async fn touch(&self, client_id: &str)

Update client activity timestamp (for PINGREQ)

pub async fn get_retained_messages( &self, filter: &str, ) -> Vec<(String, PublishPacket)>

Get retained messages matching a topic filter

pub async fn get_sender(&self, client_id: &str) -> Option<ClientSender>

Get sender for a specific client

pub async fn get_connected_clients(&self) -> Vec<String>

Get list of connected client IDs

pub async fn connection_count(&self) -> usize

Get count of active connections

pub async fn cleanup_expired_sessions(&self) -> Vec<String>

Check and disconnect expired sessions

pub async fn assign_packet_id(&self, client_id: &str) -> Option<u16>

Assign a packet ID for outgoing QoS > 0 message

pub async fn get_client_subscriptions( &self, client_id: &str, ) -> Vec<(String, QoS)>

Get a client’s subscriptions

pub async fn start_qos2_inbound(&self, client_id: &str, packet_id: u16)

Start QoS 2 inbound tracking

pub async fn mark_pubrec_sent(&self, client_id: &str, packet_id: u16)

Mark PUBREC sent for QoS 2 inbound

pub async fn complete_qos2_inbound(&self, client_id: &str, packet_id: u16)

Complete QoS 2 inbound (PUBCOMP sent)