feat: add tracing instrument for persistent cache (#9001)

Author: jerrykingxyz

Cargo.lock

@@ -38,6 +38,7 @@ struct DependencyRef<'a> {
   path: &'a ArcPath,
 }
 
+#[tracing::instrument("Cache::Occasion::Make::Dependencies::save", skip_all)]
 pub fn save_dependencies_info(
   file_dependencies: &FileCounter,
   context_dependencies: &FileCounter,
@@ -107,6 +108,7 @@ pub fn save_dependencies_info(
     });
 }
 
+#[tracing::instrument("Cache::Occasion::Make::Dependencies::recovery", skip_all)]
 pub async fn recovery_dependencies_info(
   storage: &Arc<dyn Storage>,
 ) -> Result<(FileCounter, FileCounter, FileCounter, FileCounter)> {

crates/rspack_core/src/cache/persistent/occasion/make/dependencies.rs

@@ -29,6 +29,7 @@ pub struct MetaRef<'a> {
   pub next_dependencies_id: u32,
 }
 
+#[tracing::instrument("Cache::Occasion::Make::Meta::save", skip_all)]
 pub fn save_meta(
   make_failed_dependencies: &HashSet<BuildDependency>,
   make_failed_module: &IdentifierSet,
@@ -46,6 +47,7 @@ pub fn save_meta(
   );
 }
 
+#[tracing::instrument("Cache::Occasion::Make::Meta::recovery", skip_all)]
 pub async fn recovery_meta(
   storage: &Arc<dyn Storage>,
 ) -> Result<(HashSet<BuildDependency>, IdentifierSet)> {

crates/rspack_core/src/cache/persistent/occasion/make/meta.rs

@@ -20,7 +20,7 @@ impl MakeOccasion {
     Self { storage, context }
   }
 
-  #[tracing::instrument(name = "MakeOccasion::save", skip_all)]
+  #[tracing::instrument(name = "Cache::Occasion::Make::save", skip_all)]
   pub fn save(&self, artifact: &MakeArtifact) {
     let MakeArtifact {
       // write all of field here to avoid forget to update occasion when add new fields
@@ -61,7 +61,7 @@ impl MakeOccasion {
     meta::save_meta(make_failed_dependencies, make_failed_module, &self.storage);
   }
 
-  #[tracing::instrument(name = "MakeOccasion::recovery", skip_all)]
+  #[tracing::instrument(name = "Cache::Occasion::Make::recovery", skip_all)]
   pub async fn recovery(&self) -> Result<MakeArtifact> {
     let mut artifact = MakeArtifact::default();
 

crates/rspack_core/src/cache/persistent/occasion/make/mod.rs

@@ -49,6 +49,7 @@ struct NodeRef<'a> {
   pub blocks: Vec<&'a AsyncDependenciesBlock>,
 }
 
+#[tracing::instrument("Cache::Occasion::Make::ModuleGraph::save", skip_all)]
 pub fn save_module_graph(
   partial: &ModuleGraphPartial,
   revoked_modules: &IdentifierSet,
@@ -123,6 +124,7 @@ pub fn save_module_graph(
   }
 }
 
+#[tracing::instrument("Cache::Occasion::Make::ModuleGraph::recovery", skip_all)]
 pub async fn recovery_module_graph(
   storage: &Arc<dyn Storage>,
   context: &CacheableContext,

crates/rspack_core/src/cache/persistent/occasion/make/module_graph.rs

@@ -39,6 +39,7 @@ impl Snapshot {
     }
   }
 
+  #[tracing::instrument("Cache::Snapshot::add", skip_all)]
   pub async fn add(&self, paths: impl Iterator<Item = &Path>) {
     let default_strategy = StrategyHelper::compile_time();
     let mut helper = StrategyHelper::new(self.fs.clone());
@@ -82,6 +83,7 @@ impl Snapshot {
     }
   }
 
+  #[tracing::instrument("Cache::Snapshot::calc_modified_path", skip_all)]
   pub async fn calc_modified_paths(&self) -> Result<(HashSet<ArcPath>, HashSet<ArcPath>)> {
     let mut helper = StrategyHelper::new(self.fs.clone());
     let mut modified_path = HashSet::default();

crates/rspack_core/src/cache/persistent/snapshot/mod.rs

@@ -20,5 +20,6 @@ rspack_fs    = { workspace = true }
 rspack_paths = { workspace = true }
 rustc-hash   = { workspace = true }
 tokio        = { workspace = true, features = ["rt", "rt-multi-thread", "macros", "test-util", "parking_lot", "fs"] }
+tracing      = { workspace = true }
 
 [dev-dependencies]

crates/rspack_storage/Cargo.toml

@@ -204,6 +204,7 @@ impl ScopeManager {
   }
 }
 
+#[tracing::instrument("Cache::Storage::update_scopes", skip_all)]
 async fn update_scopes(
   scopes: &mut ScopeMap,
   mut updates: ScopeUpdates,
@@ -243,6 +244,7 @@ async fn update_scopes(
   Ok(())
 }
 
+#[tracing::instrument("Cache::Storage::save_scopes", skip_all)]
 async fn save_scopes(
   mut scopes: ScopeMap,
   root_meta: &RootMeta,