Struct StorageDeploymentStorage 

pub struct StorageDeploymentStorage { /* private fields */ }

Default DeploymentStorage backed by a ferro_storage::Disk.

Artifacts are stored under deployments/{deployment_id}/ — each deployment gets its own isolated key namespace.

Implementations

impl StorageDeploymentStorage

pub fn new(disk: Disk) -> Self

Create a new storage adapter wrapping the given disk.

Trait Implementations

impl DeploymentStorage for StorageDeploymentStorage

fn store<'life0, 'life1, 'async_trait>( &'life0 self, deployment_id: i64, path: &'life1 str, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Store bytes under {deployment_id}/{path}.

fn retrieve<'life0, 'life1, 'async_trait>( &'life0 self, deployment_id: i64, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Bytes, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve bytes stored under {deployment_id}/{path}.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, deployment_id: i64, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove a single artifact at {deployment_id}/{path}.

fn list<'life0, 'async_trait>( &'life0 self, deployment_id: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all artifact paths under the deployment prefix.

fn remove_all<'life0, 'async_trait>( &'life0 self, deployment_id: i64, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Remove all artifacts for a deployment (deletes the whole prefix).