Struct Session 

pub struct Session {
    id: SessionId,
    sender: UnboundedSender<(UnboundedSender<Response>, Command)>,
    connection_count: AtomicU32,
    shutdown_requested: AtomicBool,
    pack_names: RwLock<Vec<String>>,
}

A session represents a single client’s connection state.

Each session has its own background thread for processing commands, ensuring complete isolation between clients.

Fields

id: SessionId

Unique identifier for this session.

sender: UnboundedSender<(UnboundedSender<Response>, Command)>

Sender to communicate with this session’s background thread.

connection_count: AtomicU32

Number of active connections using this session.

shutdown_requested: AtomicBool

Whether this session has been marked for shutdown.

pack_names: RwLock<Vec<String>>

Names of the pack files currently open in this session.

Implementations

impl Session

pub fn new(id: SessionId) -> Arc<Self>

Create a new session with its own background thread.

pub fn id(&self) -> SessionId

Get the session ID.

pub fn connect(&self)

Increment the connection count.

pub fn disconnect(&self)

Decrement the connection count.

pub fn connection_count(&self) -> u32

Get the current connection count.

pub fn is_shutdown_requested(&self) -> bool

Check if shutdown has been requested.

pub fn pack_names(&self) -> Vec<String>

Get the pack names for this session.

pub fn add_pack_name(&self, name: &str)

Add a pack name to this session.

pub fn remove_pack_name(&self, name: &str)

Remove a pack name from this session.

pub fn shutdown(&self)

Shutdown this session by sending an Exit command.

pub fn send(&self, command: Command) -> UnboundedReceiver<Response>

Send a command to this session’s background thread.

Returns a receiver to get the response.