Trait parallel_processor::buckets::LockFreeBucket

pub trait LockFreeBucket {
    type InitData;

    // Required methods
    fn new(path: &Path, data: &Self::InitData, index: usize) -> Self;
    fn write_data(&self, bytes: &[u8]);
    fn get_path(&self) -> PathBuf;
    fn finalize(self);
}

Required Associated Types

type InitData

Required Methods

fn new(path: &Path, data: &Self::InitData, index: usize) -> Self

fn write_data(&self, bytes: &[u8])

fn get_path(&self) -> PathBuf

fn finalize(self)

Implementors

impl LockFreeBucket for CompressedBinaryWriter

type InitData = (MemoryFileMode, CompressedCheckpointSize, CompressionLevelInfo)

impl LockFreeBucket for LockFreeBinaryWriter

type InitData = (MemoryFileMode, LockFreeCheckpointSize)