Struct KvSpillManager 

pub struct KvSpillManager { /* private fields */ }

Manages swap file creation, opening, deletion, and space limits.

Implementations

impl KvSpillManager

pub fn new(spill_dir: PathBuf, max_bytes: u64) -> Result<Self>

Create a new spill manager rooted at spill_dir with a byte budget.

Creates the directory if it doesn’t exist. Removes any stale files from prior runs.

pub fn create_file(&mut self) -> Result<(u64, BufWriter<File>)>

Create a new swap file. Returns (id, buffered_writer).

pub fn open_file(&self, id: u64) -> Result<BufReader<File>>

Open an existing swap file for reading.

pub fn remove_file(&mut self, id: u64) -> Result<()>

Remove a swap file and reclaim its disk usage.

pub fn record_usage(&mut self, id: u64)

Record bytes written to a swap file (call after flush).

pub fn has_space(&self, estimated_bytes: u64) -> bool

Check if estimated_bytes can fit within the space budget.

pub fn used_bytes(&self) -> u64

Current disk usage in bytes.

Trait Implementations

impl Drop for KvSpillManager

fn drop(&mut self)

Executes the destructor for this type.