fix(services/s3): Batch max operations from config

core/src/services/s3/backend.rs

@@ -19,6 +19,7 @@ use std::collections::HashMap;
 use std::fmt::Debug;
 use std::fmt::Formatter;
 use std::fmt::Write;
+use std::string;
 use std::sync::Arc;
 
 use async_trait::async_trait;
@@ -93,6 +94,8 @@ pub struct S3Builder {
     /// the part size of s3 multipart upload, which should be 5 MiB to 5 GiB.
     /// There is no minimum size limit on the last part of your multipart upload
     write_min_size: Option<usize>,
+
+    batch_max_opertaions: Option<usize>,
 }
 
 impl Debug for S3Builder {
@@ -103,7 +106,6 @@ impl Debug for S3Builder {
             .field("bucket", &self.bucket)
             .field("endpoint", &self.endpoint)
             .field("region", &self.region);
-
         d.finish_non_exhaustive()
     }
 }
@@ -510,6 +512,13 @@ impl S3Builder {
 
         self
     }
+
+    /// Sets maximum batch operations.
+    pub fn batch_max_operations(&mut self, batch_max_operations: usize) -> &mut Self {
+        self.batch_max_opertaions = Some(batch_max_operations);
+
+        self
+    }
 }
 
 impl Builder for S3Builder {
@@ -714,6 +723,7 @@ impl Builder for S3Builder {
                 loader,
                 client,
                 write_min_size,
+                batch_max_operations: self.batch_max_operations,
             }),
         })
     }

core/src/services/s3/core.rs

@@ -82,6 +82,7 @@ pub struct S3Core {
     pub loader: AwsLoader,
     pub client: HttpClient,
     pub write_min_size: usize,
+    pub batch_max_operations: usize,
 }
 
 impl Debug for S3Core {