add bucket_create_parallelism to NamespaceConfig.

apache · Aug 3, 2023 · af70d94 · af70d94
1 parent 258124b
commit af70d94
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/analytic_engine/src/lib.rs b/analytic_engine/src/lib.rs
@@ -179,6 +179,7 @@ pub struct ManifestNamespaceConfig {
     pub init_scan_batch_size: i32,
     pub clean_scan_timeout: ReadableDuration,
     pub clean_scan_batch_size: usize,
+    pub bucket_create_parallelism: usize,
 }
 
 impl Default for ManifestNamespaceConfig {
@@ -192,6 +193,7 @@ impl Default for ManifestNamespaceConfig {
             init_scan_batch_size: namespace_config.init_scan_batch_size,
             clean_scan_timeout: namespace_config.clean_scan_timeout,
             clean_scan_batch_size: namespace_config.clean_scan_batch_size,
+            bucket_create_parallelism: namespace_config.bucket_create_parallelism,
         }
     }
 }
@@ -206,6 +208,7 @@ impl From<ManifestNamespaceConfig> for NamespaceConfig {
             init_scan_batch_size: manifest_config.init_scan_batch_size,
             clean_scan_timeout: manifest_config.clean_scan_timeout,
             clean_scan_batch_size: manifest_config.clean_scan_batch_size,
+            bucket_create_parallelism: manifest_config.bucket_create_parallelism,
         }
     }
 }
@@ -227,6 +230,7 @@ pub struct WalNamespaceConfig {
     pub ttl: ReadableDuration,
     pub init_scan_timeout: ReadableDuration,
     pub init_scan_batch_size: i32,
+    pub bucket_create_parallelism: usize,
 }
 
 impl Default for WalNamespaceConfig {
@@ -239,6 +243,7 @@ impl Default for WalNamespaceConfig {
             ttl: namespace_config.ttl.unwrap(),
             init_scan_timeout: namespace_config.init_scan_timeout,
             init_scan_batch_size: namespace_config.init_scan_batch_size,
+            bucket_create_parallelism: namespace_config.bucket_create_parallelism,
         }
     }
 }
@@ -251,6 +256,7 @@ impl From<WalNamespaceConfig> for NamespaceConfig {
             ttl: Some(wal_config.ttl),
             init_scan_timeout: wal_config.init_scan_timeout,
             init_scan_batch_size: wal_config.init_scan_batch_size,
+            bucket_create_parallelism: wal_config.bucket_create_parallelism,
             ..Default::default()
         }
     }