apollo_network_benchmark: initial commit

Author: sirandreww-starkware

Cargo.toml

@@ -60,6 +60,7 @@ members = [
   "crates/apollo_monitoring_endpoint",
   "crates/apollo_monitoring_endpoint_config",
   "crates/apollo_network",
+  "crates/apollo_network_benchmark",
   "crates/apollo_network_types",
   "crates/apollo_node",
   "crates/apollo_node_config",
@@ -177,6 +178,7 @@ apollo_metrics = { path = "crates/apollo_metrics", version = "0.0.0" }
 apollo_monitoring_endpoint.path = "crates/apollo_monitoring_endpoint"
 apollo_monitoring_endpoint_config.path = "crates/apollo_monitoring_endpoint_config"
 apollo_network.path = "crates/apollo_network"
+apollo_network_benchmark.path = "crates/apollo_network_benchmark"
 apollo_network_types.path = "crates/apollo_network_types"
 apollo_node.path = "crates/apollo_node"
 apollo_node_config.path = "crates/apollo_node_config"

crates/apollo_network_benchmark/Cargo.toml

@@ -0,0 +1,37 @@
+[package]
+name = "apollo_network_benchmark"
+version.workspace = true
+edition.workspace = true
+repository.workspace = true
+license-file.workspace = true
+
+[features]
+testing = []
+
+[[bin]]
+name = "broadcast_network_stress_test_node"
+path = "bin/broadcast_network_stress_test_node/main.rs"
+
+[dependencies]
+apollo_metrics.workspace = true
+apollo_network.workspace = true
+clap = { workspace = true, features = ["derive"] }
+futures.workspace = true
+lazy_static.workspace = true
+libp2p = { workspace = true, features = ["identify"] }
+metrics-exporter-prometheus.workspace = true
+sysinfo.workspace = true
+tokio = { workspace = true, features = ["full", "sync"] }
+tokio-metrics = { workspace = true, features = ["metrics-rs-integration", "rt"] }
+tracing.workspace = true
+tracing-subscriber.workspace = true
+
+
+[dev-dependencies]
+assert_matches.workspace = true
+rstest.workspace = true
+tokio = { workspace = true, features = ["full", "sync", "test-util"] }
+tokio-stream.workspace = true
+
+[lints]
+workspace = true

crates/apollo_network_benchmark/bin/broadcast_network_stress_test_node/main.rs

@@ -0,0 +1,4 @@
+//! Runs a node that stress tests the p2p communication of the network.
+
+#[tokio::main]
+async fn main() -> Result<(), Box<dyn std::error::Error>> {}