Struct SqliteBackend 

pub struct SqliteBackend { /* private fields */ }

SQLite storage backend with tenant isolation.

Each tenant gets its own database file at {base_path}/{tenant}.db. This ensures complete data isolation between tenants.

Implementations

impl SqliteBackend

pub async fn open( base_path: impl AsRef<Path>, tenant: &str, ) -> Result<Self, StorageError>

Opens or creates a SQLite database for a tenant.

Arguments

• base_path - Directory where tenant databases are stored
• tenant - Tenant identifier (must match [a-z0-9_-]+)

Errors

Returns an error if:

• Tenant name is invalid
• Directory cannot be created
• Database connection fails

pub fn with_actor(self, actor: impl Into<String>) -> Self

Sets the actor for audit logging.

Returns a new instance with the actor set. All operations performed with this instance will be logged with this actor.

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

Returns the current actor, if set.

pub async fn execute_raw(&self, sql: &str) -> Result<(), StorageError>

Executes raw SQL statements (for migrations/schema creation).

pub async fn execute( &self, sql: &str, params: &[&str], ) -> Result<(), StorageError>

Executes a SQL statement with parameters.

pub async fn query_one<T>( &self, sql: &str, params: &[&str], ) -> Result<Option<T>, StorageError>

where T: for<'r> FromRow<'r, SqliteRow> + Send + Unpin,

Queries a single row with typed results.

pub async fn query_all<T>( &self, sql: &str, params: &[&str], ) -> Result<Vec<T>, StorageError>

where T: for<'r> FromRow<'r, SqliteRow> + Send + Unpin,

Queries multiple rows with typed results.

Trait Implementations

impl Clone for SqliteBackend

fn clone(&self) -> SqliteBackend

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl StorageBackend for SqliteBackend

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, StorageError>> + Send + 'async_trait>>

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

Get a value by key.

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, value: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Put a value with a key.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Delete a value by key.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StorageError>> + Send + 'async_trait>>

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

List keys with a prefix.

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

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

Check if a key exists.