environment variable.

quickwit-oss · May 8, 2024 · 4b9b3f7 · 4b9b3f7
1 parent 123572a
commit 4b9b3f7
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/quickwit/quickwit-serve/src/rest.rs b/quickwit/quickwit-serve/src/rest.rs
@@ -19,6 +19,7 @@
 
 use std::net::SocketAddr;
 use std::sync::Arc;
+use std::time::Duration;
 
 use hyper::http::HeaderValue;
 use hyper::{http, Method, StatusCode};
@@ -132,9 +133,10 @@ pub(crate) async fn start_rest_server(
  let cors = build_cors(&quickwit_services.node_config.rest_config.cors_allow_origins);
 
  let service = ServiceBuilder::new()
- .concurrency_limit(20)
+ .timeout(Duration::from_millis(500)) // TO NOT MERGE THIS, THIS IS JUST FOR A TEST.
+ .concurrency_limit(quickwit_common::get_from_env("QW_REST_CONCURRENCY_LIMIT", 5))
  .load_shed()
- .concurrency_limit(150)
+ .concurrency_limit(quickwit_common::get_from_env("QW_REST_LOAD_SHED_LIMIT", 30))
  .layer(
  CompressionLayer::new()
  .gzip(true)