Struct SqliteEngine 

pub struct SqliteEngine {
    db_path: PathBuf,
    connection: Connection,
    read_pool: Arc<ThreadPool>,
    write_pool: Arc<ThreadPool>,
    created_db_path: bool,
}

Fields

db_path: PathBuf

connection: Connection

read_pool: Arc<ThreadPool>

write_pool: Arc<ThreadPool>

created_db_path: bool

Implementations

impl SqliteEngine

pub fn new( base_dir: &Path, db_info: &IndexedDBDescription, pool: Arc<ThreadPool>, ) -> Result<Self, Error>

pub(crate) fn created_db_path(&self) -> bool

Returns whether the physical db was created as part of new.

fn init_db( path: &Path, db_info: &IndexedDBDescription, ) -> Result<Connection, Error>

fn get( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, ) -> Result<Option<Model>, Error>

fn get_key( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, ) -> Result<Option<Vec<u8>>, Error>

fn get_item( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, ) -> Result<Option<Vec<u8>>, Error>

fn get_all( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, count: Option<u32>, ) -> Result<Vec<Model>, Error>

fn get_all_keys( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, count: Option<u32>, ) -> Result<Vec<Vec<u8>>, Error>

fn get_all_items( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, count: Option<u32>, ) -> Result<Vec<Vec<u8>>, Error>

fn get_all_records( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, ) -> Result<Vec<(Vec<u8>, Vec<u8>)>, Error>

fn put_item( connection: &Connection, store: Model, key: IndexedDBKeyType, value: Vec<u8>, should_overwrite: bool, key_generator_current_number: Option<i32>, ) -> Result<PutItemResult, Error>

fn delete_item( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, ) -> Result<(), Error>

fn clear(connection: &Connection, store: Model) -> Result<(), Error>

fn count( connection: &Connection, store: Model, key_range: IndexedDBKeyRange, ) -> Result<usize, Error>

Trait Implementations

impl KvsEngine for SqliteEngine

type Error = Error

fn create_store( &self, store_name: &str, key_path: Option<KeyPath>, auto_increment: bool, ) -> Result<CreateObjectResult, Self::Error>

fn delete_store(&self, store_name: &str) -> Result<(), Self::Error>

fn close_store(&self, _store_name: &str) -> Result<(), Self::Error>

fn delete_database(self) -> Result<(), Self::Error>

fn process_transaction( &self, transaction: KvsTransaction, on_complete: Box<dyn FnOnce() + Send + 'static>, )

fn key_generator_current_number(&self, store_name: &str) -> Option<i32>

fn key_path(&self, store_name: &str) -> Option<KeyPath>

fn object_store_names(&self) -> Result<Vec<String>, Self::Error>

fn indexes(&self, store_name: &str) -> Result<Vec<IndexedDBIndex>, Self::Error>

fn create_index( &self, store_name: &str, index_name: String, key_path: KeyPath, unique: bool, multi_entry: bool, ) -> Result<CreateObjectResult, Self::Error>

fn delete_index( &self, store_name: &str, index_name: String, ) -> Result<(), Self::Error>

fn version(&self) -> Result<u64, Self::Error>

fn set_version(&self, version: u64) -> Result<(), Self::Error>

impl MallocSizeOf for SqliteEngine

fn size_of(&self, ops: &mut MallocSizeOfOps) -> usize

Measure the heap usage of all descendant heap-allocated structures, but not the space taken up by the value itself.