Struct BucketApi

pub struct BucketApi<T: Clone + Copy> {
    pub stats: Arc<BucketMapStats>,
    /* private fields */
}

Fields

stats: Arc<BucketMapStats>

Implementations

impl<T: Clone + Copy> BucketApi<T>

pub fn new( drives: Arc<Vec<PathBuf>>, max_search: MaxSearch, stats: Arc<BucketMapStats>, ) -> Self

pub fn items_in_range<R>(&self, range: &Option<&R>) -> Vec<BucketItem<T>>

where R: RangeBounds<Pubkey>,

Get the items for bucket

pub fn keys(&self) -> Vec<Pubkey>

Get the Pubkeys

pub fn read_value(&self, key: &Pubkey) -> Option<(Vec<T>, RefCount)>

Get the values for Pubkey key

pub fn bucket_len(&self) -> u64

pub fn delete_key(&self, key: &Pubkey)

pub fn addref(&self, key: &Pubkey) -> Option<RefCount>

pub fn unref(&self, key: &Pubkey) -> Option<RefCount>

pub fn insert(&self, pubkey: &Pubkey, value: (&[T], RefCount))

pub fn grow(&self, err: BucketMapError)

pub fn update<F>(&self, key: &Pubkey, updatefn: F)

where F: FnMut(Option<(&[T], RefCount)>) -> Option<(Vec<T>, RefCount)>,

pub fn try_write( &self, pubkey: &Pubkey, value: (&[T], RefCount), ) -> Result<(), BucketMapError>