Struct ReplSession 

pub struct ReplSession { /* private fields */ }

REPL session context and state

Implementations

impl ReplSession

pub fn new( db_path: &Path, config: Config, database: Database, ) -> ReplResult<Self>

Create a new REPL session

pub async fn initialize(&mut self) -> ReplResult<()>

Initialize the session

pub fn state(&self) -> &SessionState

Get current session state

pub fn current_keyspace(&self) -> Option<&String>

Get current keyspace

pub fn db_path(&self) -> &Path

Get database path

pub fn database(&self) -> Option<&Database>

Get reference to the database (for status metrics collection)

pub fn data_dir(&self) -> Option<&Path>

Get data directory

pub fn set_data_dir(&mut self, path: Option<PathBuf>)

Set data directory

pub async fn use_keyspace(&mut self, keyspace: &str) -> ReplResult<()>

Switch to a keyspace

pub async fn execute_query(&mut self, query: &str) -> ReplResult<QueryResult>

Execute a query

pub async fn list_tables(&mut self) -> ReplResult<Vec<String>>

List available tables

pub async fn list_keyspaces(&mut self) -> ReplResult<Vec<String>>

List available keyspaces

pub async fn describe_object(&mut self, object_name: &str) -> ReplResult<String>

Describe an object (table, keyspace, etc.)

pub fn get_variable(&self, name: &str) -> Option<&String>

Get session variable

pub fn set_variable(&mut self, name: String, value: String)

Set session variable

pub fn connection_info(&self) -> &ConnectionInfo

Get connection information

pub fn metrics(&self) -> &SessionMetrics

Get session metrics

pub async fn shutdown(&mut self) -> ReplResult<()>

Shutdown the session

pub fn export_metrics(&self) -> String

Export session metrics as a report

pub fn replace_database(&mut self, new_database: Database) -> ReplResult<()>

Replace the Database instance with a new one

Used when rebuilding the database after ingestion changes. The old Database will be dropped when the Arc refcount reaches zero.

pub fn config(&self) -> &Config

Get reference to the session configuration

pub fn schema_registry(&self) -> Option<Arc<RwLock<SchemaRegistry>>>

Get reference to SchemaRegistry for coverage reporting

pub fn set_schema_registry( &mut self, registry: Option<Arc<RwLock<SchemaRegistry>>>, )

Set the schema registry