Struct Session 

pub struct Session {
    id: SessionId,
    is_mcp: bool,
    last_activity: Mutex<Instant>,
    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.

is_mcp: bool

Whether this session was created for an MCP client.

MCP sessions have no disconnect signal (the MCP transport keeps the session registered until the client sends an HTTP DELETE, which many clients never do), so they are reaped based on command inactivity instead of connection count.

last_activity: Mutex<Instant>

Instant of the last command sent to this session’s background thread.

Only updated by Session::send, so it reflects actual work, not transport-level pings.

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, is_mcp: bool) -> Arc<Self>

Create a new session with its own background thread.

is_mcp marks sessions created for MCP clients, which are reaped by inactivity instead of by connection count (see Session::is_mcp).

pub fn id(&self) -> SessionId

Get the session ID.

pub fn is_mcp(&self) -> bool

Whether this session was created for an MCP client.

fn touch(&self)

Record that a command was just sent to this session’s background thread.

pub fn last_activity(&self) -> Instant

Get the instant of the last command sent to this session.

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.