refactor(ingester2): rename concurrent limit var

The ingester will handle many types of requests - this limit applies to
queries only.

clap_blocks/src/ingester2.rs

@@ -20,13 +20,13 @@ pub struct Ingester2Config {
     )]
     pub wal_rotation_period_seconds: u64,
 
-    /// Sets how many concurrent requests the ingester will handle before rejecting
-    /// incoming requests.
+    /// Sets how many queries the ingester will handle simultaneously before
+    /// rejecting further incoming requests.
     #[clap(
-        long = "concurrent-request-limit",
-        env = "INFLUXDB_IOX_CONCURRENT_REQUEST_LIMIT",
+        long = "concurrent-query-limit",
+        env = "INFLUXDB_IOX_CONCURRENT_QUERY_LIMIT",
         default_value = "20",
         action
     )]
-    pub concurrent_request_limit: usize,
+    pub concurrent_query_limit: usize,
 }

ioxd_ingester2/src/lib.rs

@@ -34,7 +34,7 @@ struct IngesterServerType<I: IngesterRpcInterface> {
     shutdown: CancellationToken,
     metrics: Arc<Registry>,
     trace_collector: Option<Arc<dyn TraceCollector>>,
-    max_simultaneous_requests: usize,
+    max_simultaneous_queries: usize,
 }
 
 impl<I: IngesterRpcInterface> IngesterServerType<I> {
@@ -42,14 +42,14 @@ impl<I: IngesterRpcInterface> IngesterServerType<I> {
         server: IngesterGuard<I>,
         metrics: Arc<Registry>,
         common_state: &CommonServerState,
-        max_simultaneous_requests: usize,
+        max_simultaneous_queries: usize,
     ) -> Self {
         Self {
             server,
             shutdown: CancellationToken::new(),
             metrics,
             trace_collector: common_state.trace_collector(),
-            max_simultaneous_requests,
+            max_simultaneous_queries,
         }
     }
 }
@@ -90,7 +90,7 @@ impl<I: IngesterRpcInterface + Sync + Send + Debug + 'static> ServerType for Ing
             builder,
             self.server
                 .rpc()
-                .query_service(self.max_simultaneous_requests)
+                .query_service(self.max_simultaneous_queries)
         );
 
         serve_builder!(builder);
@@ -157,6 +157,6 @@ pub async fn create_ingester_server_type(
         grpc,
         metrics,
         common_state,
-        ingester_config.concurrent_request_limit,
+        ingester_config.concurrent_query_limit,
     )))
 }