Struct SessionMigrate 

pub struct SessionMigrate { /* private fields */ }

Session Migrate Manager

Implementations

impl SessionMigrate

pub fn new() -> Self

Create a new session migrate manager

pub fn with_max_sessions(self, max: usize) -> Self

Configure max sessions

pub fn with_backend_template(self, template: BackendConfig) -> Self

Attach a backend-connection template so session migration can run SET, PREPARE, and CREATE TEMP TABLE against the target.

pub async fn register_endpoint(&self, node_id: NodeId, endpoint: NodeEndpoint)

Register an endpoint for a node.

pub fn with_temp_table_migration(self, enabled: bool) -> Self

Enable/disable temp table migration

pub fn set_enabled(&mut self, enabled: bool)

Enable or disable session migration

pub async fn register_session(&self, state: SessionState) -> Result<()>

Register a new session

pub async fn set_parameter( &self, session_id: Uuid, name: String, value: String, ) -> Result<()>

Update session parameter

pub async fn add_prepared_statement( &self, session_id: Uuid, info: PreparedStatementInfo, ) -> Result<()>

Add prepared statement to session

pub async fn remove_prepared_statement( &self, session_id: Uuid, name: &str, ) -> Result<()>

Remove prepared statement from session

pub async fn add_temp_table( &self, session_id: Uuid, info: TempTableInfo, ) -> Result<()>

Add temp table to session

pub async fn get_session(&self, session_id: &Uuid) -> Option<SessionState>

Get session state

pub async fn close_session(&self, session_id: &Uuid)

Close session

pub async fn migrate_session( &self, session_id: Uuid, target_node: NodeId, ) -> Result<SessionMigrateResult>

Migrate session to a new node

pub async fn stats(&self) -> SessionMigrateStats

Get statistics

Trait Implementations

impl Default for SessionMigrate

fn default() -> Self

Returns the “default value” for a type.