Struct DeltaAllocator 

pub struct DeltaAllocator { /* private fields */ }

Packs raw chunk bytes into compressed blocks.

The current (unflushed) block is held in memory; completed blocks are compressed and written to a single backing tempfile. fetch serves the current block from memory and decompresses completed blocks from that file on demand — no second file is needed.

Call commit to flush the final block and retrieve the compressed output file plus block metadata.

Implementations

impl DeltaAllocator

pub fn new(codec: Arc<dyn CompressionCodec>, block_target_size: usize) -> Self

pub fn allocate(&mut self, slice: &[u8]) -> BlockAllocAddress

Appends slice to the current block and returns its allocation address. Flushes the current block to the output file if it reaches the target size.

pub fn fetch(&self, addr: &BlockAllocAddress) -> Option<Bytes>

Returns the raw (uncompressed) bytes for the given allocation address.

Serves the current block from memory; for completed blocks it reads from the tempfile at the block’s offset (positional read, no seek), decompresses the block, and slices out the bytes.

pub async fn commit(self) -> AllocatorOutput

Flushes the remaining partial block and returns a file handle to the compressed output (seeked to position 0), the total output size, and the block metadata table.