Struct LayerSyncManager 

pub struct LayerSyncManager { /* private fields */ }

Manages layer synchronization between local storage and S3

Implementations

impl LayerSyncManager

pub async fn new(config: LayerStorageConfig) -> Result<Self>

Create a new sync manager

Errors

Returns an error if directories cannot be created, the database cannot be opened, or the AWS SDK fails to initialize.

pub async fn register_container( &self, container_id: ContainerLayerId, ) -> Result<()>

Register a container for layer sync tracking

Errors

Returns an error if persisting the sync state to the database fails.

pub async fn check_for_changes( &self, container_id: &ContainerLayerId, upper_layer_path: impl AsRef<Path>, ) -> Result<bool>

Check if a container’s layer has changed and needs sync

Errors

Returns an error if the container is not registered or if calculating the directory digest fails.

pub async fn sync_layer( &self, container_id: &ContainerLayerId, upper_layer_path: impl AsRef<Path>, ) -> Result<Option<LayerSnapshot>>

Create a snapshot and upload it to S3

Errors

Returns an error if snapshot creation, S3 upload, or state persistence fails.

pub async fn restore_layer( &self, container_id: &ContainerLayerId, target_path: impl AsRef<Path>, ) -> Result<LayerSnapshot>

Download and restore a layer from S3

Errors

Returns an error if the remote layer is not found, download fails, digest verification fails, or extraction fails.

pub async fn list_containers(&self) -> Vec<ContainerLayerId>

List all containers with sync state

pub async fn get_sync_state( &self, container_id: &ContainerLayerId, ) -> Option<SyncState>

Get sync state for a container