chore: added http execute benchmark (#1910)

Co-authored-by: Tushar Mathur <[email protected]>

Cargo.toml

@@ -49,6 +49,8 @@ opentelemetry-otlp = { version = "0.15.0", features = [
     "tls-roots",
 ], optional = true }
 opentelemetry-system-metrics = { version = "0.1.8", optional = true }
+tailcall-http-cache = {path = "tailcall-http-cache", optional = true }
+
 
 # dependencies safe for wasm:
 
@@ -193,7 +195,8 @@ cli = [
     "opentelemetry_sdk/rt-tokio",
     "dep:opentelemetry-otlp",
     "dep:opentelemetry-system-metrics",
-    "dep:tailcall-tracker"
+    "dep:tailcall-tracker",
+    "dep:tailcall-http-cache",
 ]
 
 # Feature flag to enable all default features.
@@ -214,7 +217,9 @@ members = [
     "tailcall-fixtures",
     "tailcall-upstream-grpc",
     "tailcall-tracker",
-    "tailcall-hasher"]
+    "tailcall-hasher",
+    "tailcall-http-cache",
+]
 
 # Boost execution_spec snapshot diffing performance
 [profile.dev.package]

benches/http_execute_bench.rs

@@ -0,0 +1,29 @@
+use criterion::Criterion;
+use hyper::Method;
+use tailcall::cli::runtime::NativeHttp;
+use tailcall::core::blueprint::Blueprint;
+use tailcall::core::HttpIO;
+
+pub fn benchmark_http_execute_method(c: &mut Criterion) {
+    let tokio_runtime = tokio::runtime::Runtime::new().unwrap();
+
+    let mut blueprint = Blueprint::default();
+    blueprint.upstream.http_cache = true; // allow http caching for bench test.
+    let native_http = NativeHttp::init(&blueprint.upstream, &blueprint.telemetry);
+    let request_url = String::from("http://jsonplaceholder.typicode.com/users");
+
+    tokio_runtime.block_on(async {
+        // cache the 1st request in order the evaluate the perf of underlying cache.
+        let request = reqwest::Request::new(Method::GET, request_url.parse().unwrap());
+        let _result = native_http.execute(request).await;
+    });
+
+    c.bench_function("test_http_execute_method", |b| {
+        b.iter(|| {
+            tokio_runtime.block_on(async {
+                let request = reqwest::Request::new(Method::GET, request_url.parse().unwrap());
+                let _result = native_http.execute(request).await;
+            })
+        });
+    });
+}