Refactor object lock config, retention, tags (#140)

* refactor make-bucket, bucket_exists, remove_bucket

* refactor disable-object-legal-hold, enable-object-legal-hold, is-object-legal-hold-enabled

Author: HJLebbink

.rustfmt.toml

@@ -7,3 +7,5 @@ max_width = 100
 array_width = 60  # default is 60
 attr_fn_like_width = 70  # default is 70
 chain_width = 60  # default is 60
+
+reorder_imports = true

Cargo.toml

@@ -53,6 +53,7 @@ tokio-stream = "0.1.17"
 tokio-util = { version = "0.7.13", features = ["io"] }
 urlencoding = "2.1.3"
 xmltree = "0.11.0"
+futures = "0.3.31"
 
 [dev-dependencies]
 async-std = { version = "1.13.0", features = ["attributes", "tokio1"] }

examples/common.rs

@@ -1,6 +1,7 @@
-use minio::s3::args::{BucketExistsArgs, MakeBucketArgs};
 use minio::s3::creds::StaticProvider;
 use minio::s3::http::BaseUrl;
+use minio::s3::response::BucketExistsResponse;
+use minio::s3::types::S3Api;
 use minio::s3::{Client, ClientBuilder};
 
 #[allow(dead_code)]
@@ -25,16 +26,11 @@ pub async fn create_bucket_if_not_exists(
     client: &Client,
 ) -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     // Check 'bucket_name' bucket exist or not.
-    let exists: bool = client
-        .bucket_exists(&BucketExistsArgs::new(bucket_name).unwrap())
-        .await?;
+    let resp: BucketExistsResponse = client.bucket_exists(bucket_name).send().await?;
 
     // Make 'bucket_name' bucket if not exist.
-    if !exists {
-        client
-            .make_bucket(&MakeBucketArgs::new(bucket_name).unwrap())
-            .await
-            .unwrap();
+    if !resp.exists {
+        client.make_bucket(bucket_name).send().await.unwrap();
     };
     Ok(())
 }

examples/put_object.rs

@@ -13,16 +13,12 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use std::path::PathBuf;
-
 use clap::Parser;
 use log::info;
-use minio::s3::{
-    args::{BucketExistsArgs, MakeBucketArgs},
-    builders::ObjectContent,
-    client::ClientBuilder,
-    creds::StaticProvider,
-};
+use minio::s3::response::BucketExistsResponse;
+use minio::s3::types::S3Api;
+use minio::s3::{builders::ObjectContent, client::ClientBuilder, creds::StaticProvider};
+use std::path::PathBuf;
 
 /// Upload a file to the given bucket and object path on the MinIO Play server.
 #[derive(Parser)]
@@ -49,16 +45,10 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
         .provider(Some(Box::new(static_provider)))
         .build()?;
 
-    let exists: bool = client
-        .bucket_exists(&BucketExistsArgs::new(&args.bucket).unwrap())
-        .await
-        .unwrap();
+    let resp: BucketExistsResponse = client.bucket_exists(&args.bucket).send().await.unwrap();
 
-    if !exists {
-        client
-            .make_bucket(&MakeBucketArgs::new(&args.bucket).unwrap())
-            .await
-            .unwrap();
+    if !resp.exists {
+        client.make_bucket(&args.bucket).send().await.unwrap();
     }
 
     let content = ObjectContent::from(args.file.as_path());