Struct TableConnection

pub struct TableConnection<K, V>
where
    K: Key + Sized + 'static,
    V: Value + Sized + 'static,
{
    db: Arc<Database>,
    table_def: TableDefinition<'static, K, V>,
    table_name: String,
}

A connection to a specific table in a redb database.

Fields

db: Arc<Database>

table_def: TableDefinition<'static, K, V>

table_name: String

Implementations

impl<K, V> TableConnection<K, V>

where K: Key + Sized + 'static, V: Value + Sized + 'static,

fn open_table(db: Arc<Database>, table_name: &str) -> Result<Self>

fn open_u(table_name: &str) -> Result<Self>

Open pooled unwrapped database and create TableConnection.

pub fn open(table_name: &str) -> Result<Self>

Open pooled (TODO: wrapped) database and create TableConnection.

fn acquire_db_lock(&self) -> Result<ResourceLock>

Acquire the per-database cross-process lock for this connection’s database. Returns a guard that releases on drop.

fn get<'k, R, F>(&self, key: <K as Value>::SelfType<'k>, map: F) -> Option<R>

where F: for<'v> FnOnce(<V as Value>::SelfType<'v>) -> R,

Read-only get: returns an owned R produced by mapper while txn is alive.

This operation is serialized across processes per database via ResourceLock.

pub fn get_vec<'k>(&self, key: <K as Value>::SelfType<'k>) -> Option<Vec<u8>>

where V: Value, for<'v> <V as Value>::SelfType<'v>: AsRef<[u8]>,

If V is &u8 or similar, get and convert to Vec<u8>

pub fn get_str<'k>(&self, key: <K as Value>::SelfType<'k>) -> Option<String>

where V: Value, for<'v> <V as Value>::SelfType<'v>: AsRef<str>,

If V is &str or similar, get and convert to String

pub fn get_u64<'k>(&self, key: <K as Value>::SelfType<'k>) -> Option<u64>

where V: Value, for<'a> <V as Value>::SelfType<'a>: Into<u64>,

If V is u64, get and return it directly

pub fn put<'k>( &self, key: <K as Value>::SelfType<'_>, value: <V as Value>::SelfType<'_>, ) -> Result<()>

where K: Key + Sized, V: Value + Sized,

Put: opens a write txn and inserts value.

This operation is serialized across processes per database via ResourceLock.

pub fn delete(&self, key: <K as Value>::SelfType<'_>) -> Result<()>

Delete

This operation is serialized across processes per database via ResourceLock.