Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f99a77ece0
|
||
|
|
3d3568d5a5
|
+21
@@ -47,6 +47,7 @@ pub enum Error {
|
||||
}
|
||||
|
||||
impl Labyrinth {
|
||||
/// Upload object to the bucket
|
||||
pub async fn upload(
|
||||
&self,
|
||||
file_key: &str,
|
||||
@@ -77,6 +78,7 @@ impl Labyrinth {
|
||||
}
|
||||
}
|
||||
|
||||
/// Download object from the bucket
|
||||
pub async fn download(&self, file_key: &str) -> Result<Vec<u8>, Error> {
|
||||
let client = init_client(&self.config).await;
|
||||
|
||||
@@ -103,4 +105,23 @@ impl Labyrinth {
|
||||
Err(err) => Err(Error::Info(err.to_string())),
|
||||
}
|
||||
}
|
||||
|
||||
/// Delete an object from the bucket
|
||||
pub async fn delete(
|
||||
&self,
|
||||
file_key: &str,
|
||||
) -> Result<aws_sdk_s3::operation::delete_object::DeleteObjectOutput, Error> {
|
||||
let client = init_client(&self.config).await;
|
||||
|
||||
match client
|
||||
.delete_object()
|
||||
.bucket(self.config.bucket.clone())
|
||||
.key(file_key)
|
||||
.send()
|
||||
.await
|
||||
{
|
||||
Ok(response) => Ok(response),
|
||||
Err(err) => Err(Error::Info(err.to_string())),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user