Struct AsyncSpillManager 

pub struct AsyncSpillManager { /* private fields */ }

Async manager for spill file lifecycle for out-of-core processing.

The async manager handles:

• Creating unique spill files with prefixes using async I/O
• Tracking total bytes spilled to disk
• Automatic cleanup of all spill files on drop

Implementations

impl AsyncSpillManager

pub async fn new(spill_dir: impl Into<PathBuf>) -> Result<Self>

Creates a new async spill manager with the given directory.

Creates the directory if it doesn’t exist.

Errors

Returns an error if the directory cannot be created.

pub async fn with_temp_dir() -> Result<Self>

Creates a new async spill manager using a system temp directory.

Errors

Returns an error if the temp directory cannot be created.

pub fn spill_dir(&self) -> &Path

Returns the spill directory path.

pub async fn create_file(&self, prefix: &str) -> Result<AsyncSpillFile>

Creates a new async spill file with the given prefix.

The file name format is: {prefix}_{file_id}.spill

Errors

Returns an error if the file cannot be created.

pub fn register_spilled_bytes(&self, bytes: u64)

Registers bytes spilled to disk.

Called by AsyncSpillFile when writing completes.

pub fn unregister_spilled_bytes(&self, bytes: u64)

Unregisters bytes when a spill file is deleted.

Called by AsyncSpillFile on deletion.

pub async fn unregister_file(&self, path: &Path)

Removes a file path from tracking (called when file is deleted).

pub fn spilled_bytes(&self) -> u64

Returns total bytes currently spilled to disk.

pub async fn active_file_count(&self) -> usize

Returns the number of active spill files.

pub async fn cleanup(&self) -> Result<()>

Cleans up all spill files asynchronously.

This can be called manually for async cleanup.

Errors

Returns an error if any file cannot be deleted (continues trying others).

Trait Implementations

impl Debug for AsyncSpillManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for AsyncSpillManager

fn drop(&mut self)

Executes the destructor for this type.