Struct concurrency_manager::LockTable

[+] Show declaration

pub struct LockTable(pub Arc<SkipMap<Key, Weak<KeyHandle>>>);

Implementations

impl LockTable[−]

pub async fn lock_key(&self, key: &Key) -> KeyHandleGuard

pub fn check_key<E>(
    &self,
    key: &Key,
    check_fn: impl FnOnce(&Lock) -> Result<(), E>
) -> Result<(), E>

pub fn check_range<E>(
    &self,
    start_key: Option<&Key>,
    end_key: Option<&Key>,
    check_fn: impl FnMut(&Key, &Lock) -> Result<(), E>
) -> Result<(), E>

pub fn get(&self, key: &Key) -> Option<Arc<KeyHandle>>[−]

Gets the handle of the key.

pub fn find_first<'m, T>(
    &'m self,
    start_key: Option<&Key>,
    end_key: Option<&Key>,
    pred: impl FnMut(Arc<KeyHandle>) -> Option<T>
) -> Option<T>[−]

Finds the first handle in the given range that pred returns Some. The Some return value of pred will be returned by find_first.

pub fn for_each(&self, f: impl FnMut(Arc<KeyHandle>))[−]

Iterates all handles and call a specified function on each of them.

pub fn remove(&self, key: &Key)[−]

Removes the key and its key handle from the map.

Trait Implementations

impl Clone for LockTable[+]

[+] Show hidden undocumented items

fn clone(&self) -> LockTable[−]

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)[−]

Performs copy-assignment from source.

impl Default for LockTable[+]

[+] Show hidden undocumented items

fn default() -> Self[−]

Returns the “default value” for a type.