apollo_infra: add max_stream config value for remote infra connections

Author: Itay-Tsabary-Starkware

crates/apollo_deployments/resources/services/consolidated/node.json

@@ -10,6 +10,8 @@
   "components.batcher.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.batcher.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.batcher.max_concurrency": 128,
+  "components.batcher.max_streams_per_connection": 8,
+  "components.batcher.max_streams_per_connection.#is_none": false,
   "components.batcher.port": 0,
   "components.batcher.remote_client_config.#is_none": true,
   "components.batcher.url": "localhost",
@@ -21,6 +23,8 @@
   "components.class_manager.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.class_manager.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.class_manager.max_concurrency": 128,
+  "components.class_manager.max_streams_per_connection": 8,
+  "components.class_manager.max_streams_per_connection.#is_none": false,
   "components.class_manager.port": 0,
   "components.class_manager.remote_client_config.#is_none": true,
   "components.class_manager.url": "localhost",
@@ -32,6 +36,8 @@
   "components.config_manager.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.config_manager.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.config_manager.max_concurrency": 128,
+  "components.config_manager.max_streams_per_connection": 8,
+  "components.config_manager.max_streams_per_connection.#is_none": false,
   "components.config_manager.port": 0,
   "components.config_manager.remote_client_config.#is_none": true,
   "components.config_manager.url": "localhost",
@@ -44,6 +50,8 @@
   "components.gateway.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.gateway.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.gateway.max_concurrency": 128,
+  "components.gateway.max_streams_per_connection": 8,
+  "components.gateway.max_streams_per_connection.#is_none": false,
   "components.gateway.port": 0,
   "components.gateway.remote_client_config.#is_none": true,
   "components.gateway.url": "localhost",
@@ -56,6 +64,8 @@
   "components.l1_endpoint_monitor.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.l1_endpoint_monitor.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.l1_endpoint_monitor.max_concurrency": 128,
+  "components.l1_endpoint_monitor.max_streams_per_connection": 8,
+  "components.l1_endpoint_monitor.max_streams_per_connection.#is_none": false,
   "components.l1_endpoint_monitor.port": 0,
   "components.l1_endpoint_monitor.remote_client_config.#is_none": true,
   "components.l1_endpoint_monitor.url": "localhost",
@@ -67,6 +77,8 @@
   "components.l1_gas_price_provider.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.l1_gas_price_provider.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.l1_gas_price_provider.max_concurrency": 128,
+  "components.l1_gas_price_provider.max_streams_per_connection": 8,
+  "components.l1_gas_price_provider.max_streams_per_connection.#is_none": false,
   "components.l1_gas_price_provider.port": 0,
   "components.l1_gas_price_provider.remote_client_config.#is_none": true,
   "components.l1_gas_price_provider.url": "localhost",
@@ -79,6 +91,8 @@
   "components.l1_provider.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.l1_provider.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.l1_provider.max_concurrency": 128,
+  "components.l1_provider.max_streams_per_connection": 8,
+  "components.l1_provider.max_streams_per_connection.#is_none": false,
   "components.l1_provider.port": 0,
   "components.l1_provider.remote_client_config.#is_none": true,
   "components.l1_provider.url": "localhost",
@@ -91,6 +105,8 @@
   "components.mempool.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.mempool.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.mempool.max_concurrency": 128,
+  "components.mempool.max_streams_per_connection": 8,
+  "components.mempool.max_streams_per_connection.#is_none": false,
   "components.mempool.port": 0,
   "components.mempool.remote_client_config.#is_none": true,
   "components.mempool.url": "localhost",
@@ -102,6 +118,8 @@
   "components.mempool_p2p.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.mempool_p2p.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.mempool_p2p.max_concurrency": 128,
+  "components.mempool_p2p.max_streams_per_connection": 8,
+  "components.mempool_p2p.max_streams_per_connection.#is_none": false,
   "components.mempool_p2p.port": 0,
   "components.mempool_p2p.remote_client_config.#is_none": true,
   "components.mempool_p2p.url": "localhost",
@@ -114,6 +132,8 @@
   "components.sierra_compiler.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.sierra_compiler.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.sierra_compiler.max_concurrency": 128,
+  "components.sierra_compiler.max_streams_per_connection": 8,
+  "components.sierra_compiler.max_streams_per_connection.#is_none": false,
   "components.sierra_compiler.port": 0,
   "components.sierra_compiler.remote_client_config.#is_none": true,
   "components.sierra_compiler.url": "localhost",
@@ -125,6 +145,8 @@
   "components.signature_manager.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.signature_manager.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.signature_manager.max_concurrency": 128,
+  "components.signature_manager.max_streams_per_connection": 8,
+  "components.signature_manager.max_streams_per_connection.#is_none": false,
   "components.signature_manager.port": 0,
   "components.signature_manager.remote_client_config.#is_none": true,
   "components.signature_manager.url": "localhost",
@@ -136,6 +158,8 @@
   "components.state_sync.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.state_sync.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.state_sync.max_concurrency": 128,
+  "components.state_sync.max_streams_per_connection": 8,
+  "components.state_sync.max_streams_per_connection.#is_none": false,
   "components.state_sync.port": 0,
   "components.state_sync.remote_client_config.#is_none": true,
   "components.state_sync.url": "localhost",

crates/apollo_deployments/resources/services/consolidated/replacer_node.json

@@ -10,6 +10,8 @@
   "components.batcher.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.batcher.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.batcher.max_concurrency": 128,
+  "components.batcher.max_streams_per_connection": 8,
+  "components.batcher.max_streams_per_connection.#is_none": false,
   "components.batcher.port": 0,
   "components.batcher.remote_client_config.#is_none": true,
   "components.batcher.url": "localhost",
@@ -21,6 +23,8 @@
   "components.class_manager.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.class_manager.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.class_manager.max_concurrency": 128,
+  "components.class_manager.max_streams_per_connection": 8,
+  "components.class_manager.max_streams_per_connection.#is_none": false,
   "components.class_manager.port": 0,
   "components.class_manager.remote_client_config.#is_none": true,
   "components.class_manager.url": "localhost",
@@ -32,6 +36,8 @@
   "components.config_manager.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.config_manager.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.config_manager.max_concurrency": 128,
+  "components.config_manager.max_streams_per_connection": 8,
+  "components.config_manager.max_streams_per_connection.#is_none": false,
   "components.config_manager.port": 0,
   "components.config_manager.remote_client_config.#is_none": true,
   "components.config_manager.url": "localhost",
@@ -44,6 +50,8 @@
   "components.gateway.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.gateway.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.gateway.max_concurrency": 128,
+  "components.gateway.max_streams_per_connection": 8,
+  "components.gateway.max_streams_per_connection.#is_none": false,
   "components.gateway.port": 0,
   "components.gateway.remote_client_config.#is_none": true,
   "components.gateway.url": "localhost",
@@ -56,6 +64,8 @@
   "components.l1_endpoint_monitor.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.l1_endpoint_monitor.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.l1_endpoint_monitor.max_concurrency": 128,
+  "components.l1_endpoint_monitor.max_streams_per_connection": 8,
+  "components.l1_endpoint_monitor.max_streams_per_connection.#is_none": false,
   "components.l1_endpoint_monitor.port": 0,
   "components.l1_endpoint_monitor.remote_client_config.#is_none": true,
   "components.l1_endpoint_monitor.url": "localhost",
@@ -67,6 +77,8 @@
   "components.l1_gas_price_provider.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.l1_gas_price_provider.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.l1_gas_price_provider.max_concurrency": 128,
+  "components.l1_gas_price_provider.max_streams_per_connection": 8,
+  "components.l1_gas_price_provider.max_streams_per_connection.#is_none": false,
   "components.l1_gas_price_provider.port": 0,
   "components.l1_gas_price_provider.remote_client_config.#is_none": true,
   "components.l1_gas_price_provider.url": "localhost",
@@ -79,6 +91,8 @@
   "components.l1_provider.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.l1_provider.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.l1_provider.max_concurrency": 128,
+  "components.l1_provider.max_streams_per_connection": 8,
+  "components.l1_provider.max_streams_per_connection.#is_none": false,
   "components.l1_provider.port": 0,
   "components.l1_provider.remote_client_config.#is_none": true,
   "components.l1_provider.url": "localhost",
@@ -91,6 +105,8 @@
   "components.mempool.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.mempool.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.mempool.max_concurrency": 128,
+  "components.mempool.max_streams_per_connection": 8,
+  "components.mempool.max_streams_per_connection.#is_none": false,
   "components.mempool.port": 0,
   "components.mempool.remote_client_config.#is_none": true,
   "components.mempool.url": "localhost",
@@ -102,6 +118,8 @@
   "components.mempool_p2p.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.mempool_p2p.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.mempool_p2p.max_concurrency": 128,
+  "components.mempool_p2p.max_streams_per_connection": 8,
+  "components.mempool_p2p.max_streams_per_connection.#is_none": false,
   "components.mempool_p2p.port": 0,
   "components.mempool_p2p.remote_client_config.#is_none": true,
   "components.mempool_p2p.url": "localhost",
@@ -114,6 +132,8 @@
   "components.sierra_compiler.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.sierra_compiler.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.sierra_compiler.max_concurrency": 128,
+  "components.sierra_compiler.max_streams_per_connection": 8,
+  "components.sierra_compiler.max_streams_per_connection.#is_none": false,
   "components.sierra_compiler.port": 0,
   "components.sierra_compiler.remote_client_config.#is_none": true,
   "components.sierra_compiler.url": "localhost",
@@ -125,6 +145,8 @@
   "components.signature_manager.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.signature_manager.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.signature_manager.max_concurrency": 128,
+  "components.signature_manager.max_streams_per_connection": 8,
+  "components.signature_manager.max_streams_per_connection.#is_none": false,
   "components.signature_manager.port": 0,
   "components.signature_manager.remote_client_config.#is_none": true,
   "components.signature_manager.url": "localhost",
@@ -136,6 +158,8 @@
   "components.state_sync.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.state_sync.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.state_sync.max_concurrency": 128,
+  "components.state_sync.max_streams_per_connection": 8,
+  "components.state_sync.max_streams_per_connection.#is_none": false,
   "components.state_sync.port": 0,
   "components.state_sync.remote_client_config.#is_none": true,
   "components.state_sync.url": "localhost",

crates/apollo_deployments/resources/services/distributed/batcher.json

@@ -10,13 +10,15 @@
   "components.batcher.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.batcher.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.batcher.max_concurrency": 128,
+  "components.batcher.max_streams_per_connection.#is_none": true,
   "components.batcher.port": 55000,
   "components.batcher.remote_client_config.#is_none": true,
   "components.batcher.url": "sequencer-batcher-service",
   "components.class_manager.execution_mode": "Remote",
   "components.class_manager.ip": "0.0.0.0",
   "components.class_manager.local_server_config.#is_none": true,
   "components.class_manager.max_concurrency": 128,
+  "components.class_manager.max_streams_per_connection.#is_none": true,
   "components.class_manager.port": 55001,
   "components.class_manager.remote_client_config.#is_none": false,
   "components.class_manager.remote_client_config.attempts_per_log": 10,
@@ -34,6 +36,8 @@
   "components.config_manager.local_server_config.normal_priority_requests_channel_capacity": 1024,
   "components.config_manager.local_server_config.processing_time_warning_threshold_ms": 3000,
   "components.config_manager.max_concurrency": 128,
+  "components.config_manager.max_streams_per_connection": 8,
+  "components.config_manager.max_streams_per_connection.#is_none": false,
   "components.config_manager.port": 0,
   "components.config_manager.remote_client_config.#is_none": true,
   "components.config_manager.url": "localhost",
@@ -42,6 +46,7 @@
   "components.gateway.ip": "0.0.0.0",
   "components.gateway.local_server_config.#is_none": true,
   "components.gateway.max_concurrency": 128,
+  "components.gateway.max_streams_per_connection.#is_none": true,
   "components.gateway.port": 0,
   "components.gateway.remote_client_config.#is_none": true,
   "components.gateway.url": "localhost",
@@ -50,13 +55,15 @@
   "components.l1_endpoint_monitor.ip": "0.0.0.0",
   "components.l1_endpoint_monitor.local_server_config.#is_none": true,
   "components.l1_endpoint_monitor.max_concurrency": 128,
+  "components.l1_endpoint_monitor.max_streams_per_connection.#is_none": true,
   "components.l1_endpoint_monitor.port": 0,
   "components.l1_endpoint_monitor.remote_client_config.#is_none": true,
   "components.l1_endpoint_monitor.url": "localhost",
   "components.l1_gas_price_provider.execution_mode": "Disabled",
   "components.l1_gas_price_provider.ip": "0.0.0.0",
   "components.l1_gas_price_provider.local_server_config.#is_none": true,
   "components.l1_gas_price_provider.max_concurrency": 128,
+  "components.l1_gas_price_provider.max_streams_per_connection.#is_none": true,
   "components.l1_gas_price_provider.port": 0,
   "components.l1_gas_price_provider.remote_client_config.#is_none": true,
   "components.l1_gas_price_provider.url": "localhost",
@@ -65,6 +72,7 @@
   "components.l1_provider.ip": "0.0.0.0",
   "components.l1_provider.local_server_config.#is_none": true,
   "components.l1_provider.max_concurrency": 128,
+  "components.l1_provider.max_streams_per_connection.#is_none": true,
   "components.l1_provider.port": 55004,
   "components.l1_provider.remote_client_config.#is_none": false,
   "components.l1_provider.remote_client_config.attempts_per_log": 10,
@@ -79,6 +87,7 @@
   "components.mempool.ip": "0.0.0.0",
   "components.mempool.local_server_config.#is_none": true,
   "components.mempool.max_concurrency": 128,
+  "components.mempool.max_streams_per_connection.#is_none": true,
   "components.mempool.port": 55006,
   "components.mempool.remote_client_config.#is_none": false,
   "components.mempool.remote_client_config.attempts_per_log": 10,
@@ -92,6 +101,7 @@
   "components.mempool_p2p.ip": "0.0.0.0",
   "components.mempool_p2p.local_server_config.#is_none": true,
   "components.mempool_p2p.max_concurrency": 128,
+  "components.mempool_p2p.max_streams_per_connection.#is_none": true,
   "components.mempool_p2p.port": 0,
   "components.mempool_p2p.remote_client_config.#is_none": true,
   "components.mempool_p2p.url": "localhost",
@@ -100,20 +110,23 @@
   "components.sierra_compiler.ip": "0.0.0.0",
   "components.sierra_compiler.local_server_config.#is_none": true,
   "components.sierra_compiler.max_concurrency": 128,
+  "components.sierra_compiler.max_streams_per_connection.#is_none": true,
   "components.sierra_compiler.port": 0,
   "components.sierra_compiler.remote_client_config.#is_none": true,
   "components.sierra_compiler.url": "localhost",
   "components.signature_manager.execution_mode": "Disabled",
   "components.signature_manager.ip": "0.0.0.0",
   "components.signature_manager.local_server_config.#is_none": true,
   "components.signature_manager.max_concurrency": 128,
+  "components.signature_manager.max_streams_per_connection.#is_none": true,
   "components.signature_manager.port": 0,
   "components.signature_manager.remote_client_config.#is_none": true,
   "components.signature_manager.url": "localhost",
   "components.state_sync.execution_mode": "Disabled",
   "components.state_sync.ip": "0.0.0.0",
   "components.state_sync.local_server_config.#is_none": true,
   "components.state_sync.max_concurrency": 128,
+  "components.state_sync.max_streams_per_connection.#is_none": true,
   "components.state_sync.port": 0,
   "components.state_sync.remote_client_config.#is_none": true,
   "components.state_sync.url": "localhost",