Struct ClientSession 

pub struct ClientSession { /* private fields */ }

Represents an active client session

Implementations

impl ClientSession

pub fn new(client_addr: SocketAddr, buffer_pool: BufferPool) -> Self

Create a new client session for 1:1 mode

pub fn new_with_router( client_addr: SocketAddr, buffer_pool: BufferPool, router: Arc<BackendSelector>, ) -> Self

Create a new client session for per-command routing mode

pub fn client_id(&self) -> ClientId

Get the unique client ID

pub fn is_per_command_routing(&self) -> bool

Check if this session is using per-command routing

pub async fn handle_with_pooled_backend<T>( &self, client_stream: TcpStream, backend_conn: T, ) -> Result<(u64, u64)>

where T: AsyncRead + AsyncWrite + Unpin,

Handle client connection with a pooled backend connection This keeps the pooled connection object alive and returns it to the pool when done Intercepts authentication commands since backend connection is already authenticated

pub async fn handle_per_command_routing( &self, client_stream: TcpStream, ) -> Result<(u64, u64)>

Handle a client connection with per-command routing Each command is routed independently to potentially different backends