Struct ReplEngine 

pub struct ReplEngine { /* private fields */ }

Main REPL engine

Implementations

impl ReplEngine

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

Create a new REPL engine

pub fn with_schema_registry( config: ReplConfig, db_path: &Path, app_config: Config, database: Database, schema_registry: Option<Arc<RwLock<SchemaRegistry>>>, ) -> ReplResult<Self>

Create a new REPL engine with an optional pre-loaded SchemaRegistry

This is used when the CLI performs ingestion at startup, allowing the REPL to have immediate access to schema information for commands like :describe without needing to run :schema refresh first.

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

Start the REPL loop

pub fn process_input<'a>( &'a mut self, input: &'a str, ) -> Pin<Box<dyn Future<Output = ReplResult<ExecutionResult>> + 'a>>

Process a line of input

pub fn session(&self) -> &ReplSession

Get reference to session

pub fn session_mut(&mut self) -> &mut ReplSession

Get mutable reference to session

pub fn config(&self) -> &ReplConfig

Get current configuration

pub async fn rebuild_database_from_discovery( &mut self, data_dir: PathBuf, schema_paths: Vec<PathBuf>, version_hint: Option<String>, ) -> ReplResult<()>

Rebuild Database from discovery when ingestion changes

This method orchestrates schema loading and SSTable discovery to create a new Database instance, replacing the existing one in the REPL session.

Use cases:

• After :config data-dir <path> changes the data directory
• After :schema load <path> loads new schema files
• After :schema refresh reloads existing schemas

Arguments

• data_dir - Root data directory containing SSTables
• schema_paths - Schema file paths (.cql or .json) to load
• version_hint - Optional Cassandra version hint (e.g., “5.0”)

Errors

Returns ReplError::Database for ingestion failures, schema loading errors, or database initialization errors.