Struct KvdbSqliteSharded

pub struct KvdbSqliteSharded<ValueType> { /* private fields */ }

Implementations

impl<ValueType> KvdbSqliteSharded<ValueType>

pub fn new( shard_connections: Option<Box<[SqliteConnection]>>, statements: Arc<KvdbSqliteStatements>, ) -> Self

pub fn into_connections(self) -> Option<Box<[SqliteConnection]>>

impl<ValueType> KvdbSqliteSharded<ValueType>

pub fn db_path<P: AsRef<Path>>(path: P, shard_id: u16) -> PathBuf

pub fn try_clone(&self) -> Result<Self>

pub fn open<P: AsRef<Path>>( num_shards: u16, dir: P, readonly: bool, statements: Arc<KvdbSqliteStatements>, ) -> Result<Self>

pub fn open_or_create<P: AsRef<Path>>( num_shards: u16, dir: P, statements: Arc<KvdbSqliteStatements>, unsafe_mode: bool, ) -> Result<(bool, Self)>

pub fn create_and_open<P: AsRef<Path>>( num_shards: u16, dir: P, statements: Arc<KvdbSqliteStatements>, create_table: bool, unsafe_mode: bool, ) -> Result<Self>

pub fn create_table( connections: &mut Box<[SqliteConnection]>, statements: &KvdbSqliteStatements, ) -> Result<()>

Call initialize databases separately. Typical usage is to create a new table from the existing db.

pub fn check_if_table_exist( connections: &mut Box<[SqliteConnection]>, statements: &KvdbSqliteStatements, ) -> Result<bool>

pub fn drop_table( connections: &mut Box<[SqliteConnection]>, statements: &KvdbSqliteStatements, ) -> Result<()>

pub fn vacumm_db( connections: &mut Box<[SqliteConnection]>, statements: &KvdbSqliteStatements, ) -> Result<()>

Trait Implementations

impl DerefMutPlusSelf for KvdbSqliteSharded<()>

type Target = KvdbSqliteSharded<()>

fn deref_mut(&mut self) -> &mut Self

impl DerefMutPlusSelf for KvdbSqliteSharded<Box<[u8]>>

type Target = KvdbSqliteSharded<Box<[u8]>>

fn deref_mut(&mut self) -> &mut Self

impl DerefPlusSelf for KvdbSqliteSharded<()>

type Target = KvdbSqliteSharded<()>

fn deref(&self) -> &Self

impl DerefPlusSelf for KvdbSqliteSharded<Box<[u8]>>

type Target = KvdbSqliteSharded<Box<[u8]>>

fn deref(&self) -> &Self

impl ElementSatisfy<dyn KeyValueDbIterableTrait<(Vec<u8>, ()), [u8], KvdbSqliteShardedIteratorTag>> for KvdbSqliteSharded<()>

fn to_constrain_object( &self, ) -> &(dyn KeyValueDbIterableTrait<(Vec<u8>, ()), [u8], KvdbSqliteShardedIteratorTag> + 'static)

fn to_constrain_object_mut( &mut self, ) -> &mut (dyn KeyValueDbIterableTrait<(Vec<u8>, ()), [u8], KvdbSqliteShardedIteratorTag> + 'static)

impl ElementSatisfy<dyn KeyValueDbIterableTrait<(Vec<u8>, Box<[u8]>), [u8], KvdbSqliteShardedIteratorTag>> for KvdbSqliteSharded<Box<[u8]>>

fn to_constrain_object( &self, ) -> &(dyn KeyValueDbIterableTrait<MptKeyValue, [u8], KvdbSqliteShardedIteratorTag> + 'static)

fn to_constrain_object_mut( &mut self, ) -> &mut (dyn KeyValueDbIterableTrait<MptKeyValue, [u8], KvdbSqliteShardedIteratorTag> + 'static)

impl<ValueType: 'static + DbValueType + ValueRead + ValueReadImpl<<ValueType as ValueRead>::Kind>> KeyValueDbTraitTransactional for KvdbSqliteSharded<ValueType>

where ValueType::Type: SqlBindableValue + BindValueAppendImpl<<ValueType::Type as SqlBindableValue>::Kind>,

type TransactionType = KvdbSqliteShardedTransaction<ValueType>

fn start_transaction( &self, immediate_write: bool, ) -> Result<KvdbSqliteShardedTransaction<ValueType>>

Immediate_write indicates whether the transaction should acquire a write-lock immediately if any.

impl<ValueType: DbValueType> KeyValueDbTypes for KvdbSqliteSharded<ValueType>

type ValueType = ValueType

impl<ValueType> MallocSizeOf for KvdbSqliteSharded<ValueType>

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.

impl OwnedReadImplFamily for &KvdbSqliteSharded<Box<[u8]>>

type FamilyRepresentative = dyn KeyValueDbTraitMultiReader<ValueType = Box<[u8]>>

impl<ValueType> OwnedReadImplFamily for KvdbSqliteSharded<ValueType>

type FamilyRepresentative = KvdbSqliteSharded<ValueType>

impl<ValueType> ReadImplFamily for KvdbSqliteSharded<ValueType>

type FamilyRepresentative = KvdbSqliteSharded<ValueType>

impl<ValueType> SingleWriterImplFamily for KvdbSqliteSharded<ValueType>

type FamilyRepresentative = KvdbSqliteSharded<ValueType>

impl WrappedLifetimeFamily<'_, dyn KeyValueDbIterableTrait<(Vec<u8>, ()), [u8], KvdbSqliteShardedIteratorTag>> for KvdbSqliteSharded<()>

type Out = KvdbSqliteSharded<()>

impl WrappedLifetimeFamily<'_, dyn KeyValueDbIterableTrait<(Vec<u8>, Box<[u8]>), [u8], KvdbSqliteShardedIteratorTag>> for KvdbSqliteSharded<Box<[u8]>>

type Out = KvdbSqliteSharded<Box<[u8]>>

impl DeltaDbTrait for KvdbSqliteSharded<Box<[u8]>>

impl KeyValueDbTraitMultiReader for KvdbSqliteSharded<Box<[u8]>>

impl WrappedTrait<dyn KeyValueDbIterableTrait<(Vec<u8>, ()), [u8], KvdbSqliteShardedIteratorTag>> for KvdbSqliteSharded<()>

impl WrappedTrait<dyn KeyValueDbIterableTrait<(Vec<u8>, Box<[u8]>), [u8], KvdbSqliteShardedIteratorTag>> for KvdbSqliteSharded<Box<[u8]>>