Struct SQLiteProtocolAdapter 

pub struct SQLiteProtocolAdapter { /* private fields */ }

SQLite protocol adapter implementation

Note: SQLite doesn’t have a traditional network protocol like PostgreSQL or MySQL. This implementation provides a simplified protocol interface that can work with SQLite clients through file-based connections and basic query execution.

Implementations

impl SQLiteProtocolAdapter

pub fn new() -> Self

Create a new SQLite protocol adapter

pub fn with_database_path(database_path: String) -> Self

Create SQLite protocol adapter with specific database path

Trait Implementations

impl Debug for SQLiteProtocolAdapter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SQLiteProtocolAdapter

fn default() -> Self

Returns the “default value” for a type.

impl ProtocolAdapter for SQLiteProtocolAdapter

fn accept_connection<'life0, 'async_trait>( &'life0 self, stream: TcpStream, ) -> Pin<Box<dyn Future<Output = NirvResult<Connection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Accept a new connection and perform initial handshake

fn authenticate<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut Connection, credentials: Credentials, ) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Authenticate a connection with provided credentials

fn handle_query<'life0, 'life1, 'async_trait>( &'life0 self, _conn: &'life1 Connection, _query: ProtocolQuery, ) -> Pin<Box<dyn Future<Output = NirvResult<ProtocolResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle a query from the client and return a response

fn get_protocol_type(&self) -> ProtocolType

Get the protocol type this adapter handles

fn parse_message<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _conn: &'life1 Connection, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = NirvResult<ProtocolQuery>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Parse protocol-specific message into internal representation

fn format_response<'life0, 'life1, 'async_trait>( &'life0 self, _conn: &'life1 Connection, result: QueryResult, ) -> Pin<Box<dyn Future<Output = NirvResult<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Format internal query result into protocol-specific response

fn terminate_connection<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut Connection, ) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle connection termination