feat: add hotpath primitive profiling coverage (#5492)

* chore(deps): refresh google cloud dependencies

Co-Authored-By: heihutu <heihutu@gmail.com>

* feat: add hotpath primitive coverage

Co-Authored-By: heihutu <heihutu@gmail.com>

* feat: extend hotpath profiling features

Co-Authored-By: heihutu <heihutu@gmail.com>

* fix: gate OPA hotpath client wrapping

Co-Authored-By: heihutu <heihutu@gmail.com>

* fix: avoid request-scoped hotpath primitive wrappers

Preserve the original bounded channel and stream semantics in EC and RIO request paths while keeping hotpath CPU profiling as a separate opt-in feature that implies base hotpath instrumentation.

Co-Authored-By: heihutu <heihutu@gmail.com>

---------

Co-authored-by: heihutu <heihutu@gmail.com>

crates/ecstore/Cargo.toml

@@ -48,6 +48,12 @@ hotpath-alloc = [
     "rustfs-filemeta/hotpath-alloc",
     "rustfs-rio/hotpath-alloc",
 ]
+hotpath-cpu = [
+    "hotpath",
+    "hotpath/hotpath-cpu",
+    "rustfs-filemeta/hotpath-cpu",
+    "rustfs-rio/hotpath-cpu",
+]
 # Exposes shared lifecycle/tier test utilities (MockWarmBackend, fault
 # injection, xl.meta transition assertions) via `api::tier::test_util`.
 # Enable only from `[dev-dependencies]` (rustfs/backlog#1148 ilm-6).

crates/filemeta/Cargo.toml

@@ -29,6 +29,7 @@ documentation = "https://docs.rs/rustfs-filemeta/latest/rustfs_filemeta/"
 default = []
 hotpath = ["hotpath/hotpath", "hotpath/tokio"]
 hotpath-alloc = ["hotpath/hotpath-alloc"]
+hotpath-cpu = ["hotpath", "hotpath/hotpath-cpu"]
 
 [dependencies]
 hotpath.workspace = true

crates/policy/Cargo.toml

@@ -28,6 +28,12 @@ documentation = "https://docs.rs/rustfs-policy/latest/rustfs_policy/"
 [lints]
 workspace = true
 
+[features]
+default = []
+hotpath = ["hotpath/hotpath", "hotpath/reqwest-0-13"]
+hotpath-alloc = ["hotpath/hotpath-alloc"]
+hotpath-cpu = ["hotpath", "hotpath/hotpath-cpu"]
+
 [dependencies]
 rustfs-credentials = { workspace = true }
 rustfs-config = { workspace = true, features = ["opa"] }
@@ -49,6 +55,7 @@ moka = { workspace = true, features = ["future"] }
 async-trait.workspace = true
 futures.workspace = true
 pollster.workspace = true
+hotpath.workspace = true
 
 [dev-dependencies]
 pollster.workspace = true

crates/policy/src/policy/opa.rs

@@ -32,10 +32,15 @@ impl Args {
 
 #[derive(Debug, Clone)]
 pub struct AuthZPlugin {
-    client: reqwest::Client,
+    client: OpaHttpClient,
     args: Args,
 }
 
+#[cfg(feature = "hotpath")]
+type OpaHttpClient = hotpath::wrap::reqwest::Client;
+#[cfg(not(feature = "hotpath"))]
+type OpaHttpClient = reqwest::Client;
+
 #[derive(Debug, thiserror::Error)]
 pub enum OpaConfigError {
     #[error("Missing required env var: {0}")]
@@ -141,6 +146,9 @@ impl AuthZPlugin {
                 reqwest::Client::new()
             });
 
+        #[cfg(feature = "hotpath")]
+        let client = hotpath::http!(client, label = "Policy::OPA");
+
         Self { client, args: config }
     }
 

crates/rio/Cargo.toml

@@ -32,6 +32,7 @@ workspace = true
 default = []
 hotpath = ["hotpath/hotpath", "hotpath/tokio", "hotpath/futures", "hotpath/reqwest-0-13"]
 hotpath-alloc = ["hotpath/hotpath-alloc"]
+hotpath-cpu = ["hotpath", "hotpath/hotpath-cpu"]
 
 [dependencies]
 hotpath.workspace = true