feat(router): add configuration support for actix workers (#156)

Cargo.lock

@@ -2734,6 +2734,7 @@ dependencies = [
  "mimalloc",
  "mime",
  "nanoid",
+ "num_cpus",
  "once_cell",
  "rand",
  "redis_interface",

config/docker_compose.toml

@@ -48,7 +48,7 @@ locker_decryption_key2 = ""
 host = "redis-queue"
 port = 6379
 cluster_enabled = true
-cluster_urls = ["bach-redis-queue-1:6379", "bach-redis-queue-2:6379", "bach-redis-queue-3:6379"]
+cluster_urls = ["redis-queue:6379"]
 
 [connectors.aci]
 base_url = "https://eu-test.oppwa.com/"

crates/router/Cargo.toml

@@ -48,6 +48,7 @@ maud = { version = "0.24", features = ["actix-web"] }
 mimalloc = { version = "0.1", optional = true }
 mime = "0.3.16"
 nanoid = "0.4.0"
+num_cpus = "1.14.0"
 once_cell = "1.16.0"
 rand = "0.8.5"
 reqwest = { version = "0.11.12", features = ["json", "native-tls"] }

crates/router/src/configs/settings.rs

@@ -84,6 +84,7 @@ pub struct Proxy {
 #[derive(Debug, Deserialize, Clone)]
 pub struct Server {
     pub port: u16,
+    pub workers: Option<usize>,
     pub host: String,
     pub request_body_limit: usize,
     pub base_url: String,

crates/router/src/lib.rs

@@ -133,6 +133,7 @@ pub async fn start_server(conf: Settings) -> BachResult<(Server, AppState)> {
     let request_body_limit = server.request_body_limit;
     let server = actix_web::HttpServer::new(move || mk_app(state.clone(), request_body_limit))
         .bind((server.host.as_str(), server.port))?
+        .workers(server.workers.unwrap_or_else(num_cpus::get_physical))
         .run();
 
     Ok((server, app_state))

docker-compose.yml

@@ -25,7 +25,7 @@ services:
   loki:
     image: grafana/loki:latest
     ports:
-      - "3100:3100"
+      - "3100"
     command: -config.file=/etc/loki/loki.yaml
     networks:
       - router_net
@@ -66,7 +66,7 @@ services:
   pg:
     image: postgres:14.5
     ports:
-      - "5432:5432"
+      - "5432"
     networks:
       - router_net
     volumes: