Struct kaspa_database::prelude::CachedDbSetAccess

pub struct CachedDbSetAccess<TKey, TData, S = RandomState, W = RandomState>
where
    TKey: Clone + Hash + Eq + Send + Sync,
    TData: Clone + Send + Sync,
    W: Send + Sync,
{ /* private fields */ }

A concurrent DB store for set access with typed caching.

Implementations

impl<TKey, TData, S, W> CachedDbSetAccess<TKey, TData, S, W>

where TKey: Clone + Hash + Eq + Send + Sync + AsRef<[u8]>, TData: Clone + Hash + Eq + Send + Sync + DeserializeOwned + Serialize, S: BuildHasher + Default, W: BuildHasher + Default + Send + Sync,

pub fn new(db: Arc<DB>, cache_policy: CachePolicy, prefix: Vec<u8>) -> Self

pub fn read_from_cache(&self, key: TKey) -> Option<ReadLock<HashSet<TData, W>>>

pub fn read(&self, key: TKey) -> Result<ReadLock<HashSet<TData, W>>, StoreError>

pub fn write( &self, writer: impl DbWriter, key: TKey, data: TData ) -> Result<(), StoreError>

pub fn delete_bucket( &self, writer: impl DbWriter, key: TKey ) -> Result<(), StoreError>

pub fn delete( &self, writer: impl DbWriter, key: TKey, data: TData ) -> Result<(), StoreError>

pub fn prefix(&self) -> &[u8]

Trait Implementations

impl<TKey, TData, S: Clone, W> Clone for CachedDbSetAccess<TKey, TData, S, W>

where TKey: Clone + Hash + Eq + Send + Sync + Clone, TData: Clone + Send + Sync + Clone, W: Send + Sync + Clone,

fn clone(&self) -> CachedDbSetAccess<TKey, TData, S, W>

Returns a copy of the value.

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

Performs copy-assignment from source.