Allow to override number of actix workers with ACTIX_WORKERS

Author: barthalion

src/app.rs

@@ -59,6 +59,12 @@ pub fn load_config<P: AsRef<Path>>(path: P) -> io::Result<Config> {
         config_data.base_url = format!("http://{}:{}", config_data.host, config_data.port)
     }
 
+    if let Ok(workers_str) = std::env::var("ACTIX_WORKERS") {
+        if let Ok(workers) = workers_str.parse::<usize>() {
+            config_data.workers = workers;
+        }
+    }
+
     Ok(config_data)
 }
 
@@ -219,6 +225,7 @@ pub fn create_app(
 
     let bind_to = format!("{}:{}", config.host, config.port);
     let server = http_server
+        .workers(config.workers)
         .bind(&bind_to)
         .unwrap()
         .disable_signals()

src/config.rs

@@ -108,6 +108,10 @@ fn default_numcpu() -> u32 {
     num_cpus::get() as u32
 }
 
+fn default_workers() -> usize {
+    num_cpus::get()
+}
+
 #[derive(Deserialize, Debug, Clone)]
 #[serde(rename_all = "kebab-case", deny_unknown_fields)]
 pub struct Config {
@@ -136,6 +140,8 @@ pub struct Config {
     pub delay_update_secs: u64,
     #[serde(default = "default_numcpu")]
     pub local_delta_threads: u32,
+    #[serde(default = "default_workers")]
+    pub workers: usize,
     pub storefront_info_endpoint: Option<String>,
 }