Struct MultiThreadBuckets

pub struct MultiThreadBuckets<B: LockFreeBucket> { /* private fields */ }

Implementations

impl<B: LockFreeBucket> MultiThreadBuckets<B>

pub const EMPTY: Self

pub fn get_buckets_count(&self) -> &BucketsCount

pub fn create_matching_multichunks(&self) -> Vec<Mutex<MultiChunkBucket>>

pub fn new( size: BucketsCount, path: PathBuf, chunking_size_threshold: Option<u64>, init_data: &B::InitData, format_info: &impl Encode, ) -> MultiThreadBuckets<B>

pub fn get_stored_buckets(&self) -> &Vec<Mutex<MultiChunkBucket>>

pub fn into_buckets(self) -> impl Iterator<Item = B>

pub fn get_path(&self, bucket: u16) -> PathBuf

pub fn add_data(&self, index: u16, data: &[u8]) -> ChunkingStatus

pub fn finalize_single(self: Arc<Self>) -> Vec<SingleBucket>

pub fn finalize(self: Arc<Self>) -> Vec<MultiChunkBucket>

Trait Implementations

impl<B: LockFreeBucket> Drop for MultiThreadBuckets<B>

fn drop(&mut self)

Executes the destructor for this type.

impl<B: LockFreeBucket> Send for MultiThreadBuckets<B>

impl<B: LockFreeBucket> Sync for MultiThreadBuckets<B>