Struct StorageManager 

pub struct StorageManager { /* private fields */ }

Manages storage volumes for containers

Implementations

impl StorageManager

pub fn new(base_dir: impl AsRef<Path>) -> Result<Self>

Create a new StorageManager with the given base directory

Errors

Returns an error if the base directory cannot be created.

pub fn volume_dir(&self) -> &Path

Get the base volume directory

pub fn create_anonymous( &mut self, container_id: &str, target: &str, ) -> Result<PathBuf>

Create an anonymous volume for a container Returns the path to the volume directory

Errors

Returns an error if the volume directory cannot be created.

pub fn cleanup_anonymous(&mut self, container_id: &str) -> Result<()>

Clean up all anonymous volumes for a container

Errors

Returns an error if volume directories cannot be removed.

pub fn list_anonymous(&self, container_id: &str) -> Vec<&VolumeInfo>

List anonymous volumes for a container

pub fn ensure_volume(&mut self, name: &str) -> Result<PathBuf>

Ensure a named volume exists, creating it if necessary

Errors

Returns an error if the volume name is invalid or the directory cannot be created.

pub async fn ensure_volume_with_sync(&mut self, name: &str) -> Result<PathBuf>

Ensure a named volume exists, register it with layer sync, and restore from S3 if a backup exists.

This is the async counterpart to [ensure_volume] that integrates with the S3 layer sync. When the s3 feature is not enabled or no layer sync is configured, this behaves identically to [ensure_volume].

Errors

Returns an error if the volume cannot be created or S3 restore fails.

pub fn attach_volume(&mut self, name: &str, container_id: &str) -> Result<()>

Attach a container to a volume (track usage)

Errors

Returns an error if the volume does not exist.

pub fn detach_volume(&mut self, name: &str, container_id: &str) -> Result<()>

Detach a container from a volume (untrack usage)

Errors

This function currently always succeeds but returns Result for future compatibility.

pub fn delete_volume(&mut self, name: &str) -> Result<()>

Delete a volume if it’s not in use

Errors

Returns an error if the volume is still in use or cannot be removed.

pub fn list_volumes(&self) -> Vec<&VolumeInfo>

List all tracked volumes

pub fn get_volume(&self, name: &str) -> Option<&VolumeInfo>

Get info for a specific volume

pub fn mount_s3( &mut self, bucket: &str, prefix: Option<&str>, endpoint: Option<&str>, container_id: &str, ) -> Result<PathBuf>

Mount an S3 bucket via s3fs FUSE

Requires s3fs-fuse to be installed on the system. Credentials should be configured via environment or ~/.aws/credentials

Errors

Returns an error if the S3 mount point cannot be created or the s3fs command fails.

pub fn unmount_s3( &mut self, bucket: &str, prefix: Option<&str>, container_id: &str, ) -> Result<()>

Unmount an S3 bucket

Errors

Returns an error if the unmount command fails.

pub fn list_s3_mounts(&self) -> Vec<&S3MountInfo>

List all S3 mounts

pub fn get_s3_mount( &self, bucket: &str, prefix: Option<&str>, ) -> Option<&S3MountInfo>

Get S3 mount info