feat: make prover cache pool size configurable

Author: jpraynaud

mithril-aggregator/src/configuration.rs

@@ -153,6 +153,9 @@ pub struct Configuration {
     ///
     /// Will be ignored on (pre)production networks.
     pub allow_unparsable_block: bool,
+
+    /// Cardano transactions prover cache pool size
+    pub cardano_transactions_prover_cache_pool_size: u32,
 }
 
 /// Uploader needed to copy the snapshot once computed.
@@ -225,6 +228,7 @@ impl Configuration {
             cexplorer_pools_url: None,
             signer_importer_run_interval: 1,
             allow_unparsable_block: false,
+            cardano_transactions_prover_cache_pool_size: 3,
         }
     }
 
@@ -358,6 +362,9 @@ pub struct DefaultConfiguration {
     ///
     /// Will be ignored on (pre)production networks.
     pub allow_unparsable_block: String,
+
+    /// Cardano transactions prover cache pool size
+    pub cardano_transactions_prover_cache_pool_size: u32,
 }
 
 impl Default for DefaultConfiguration {
@@ -378,6 +385,7 @@ impl Default for DefaultConfiguration {
             snapshot_use_cdn_domain: "false".to_string(),
             signer_importer_run_interval: 720,
             allow_unparsable_block: "false".to_string(),
+            cardano_transactions_prover_cache_pool_size: 10,
         }
     }
 }
@@ -452,6 +460,10 @@ impl Source for DefaultConfiguration {
             "allow_unparsable_block".to_string(),
             into_value(myself.allow_unparsable_block),
         );
+        result.insert(
+            "cardano_transactions_prover_cache_pool_size".to_string(),
+            into_value(myself.cardano_transactions_prover_cache_pool_size),
+        );
 
         Ok(result)
     }

mithril-aggregator/src/dependency_injection/builder.rs

@@ -1365,7 +1365,9 @@ impl DependenciesBuilder {
 
     /// build Prover service
     pub async fn build_prover_service(&mut self) -> Result<Arc<dyn ProverService>> {
-        let mk_map_pool_size = 30; // TODO: make this configurable
+        let mk_map_pool_size = self
+            .configuration
+            .cardano_transactions_prover_cache_pool_size as usize;
         let transaction_retriever = self.get_transaction_repository().await?;
         let block_range_root_retriever = self.get_transaction_repository().await?;
         let logger = self.get_logger().await?;