about summary refs log tree commit diff
path: root/tvix/castore/src/composition.rs
diff options
context:
space:
mode:
authorFlorian Klink <flokli@flokli.de>2024-11-09T13·16+0000
committerflokli <flokli@flokli.de>2024-11-11T18·46+0000
commitd505f03e005b87d315694a22a75c11205266ba7d (patch)
tree67efb1d5d1756e7dce67f95b877a92bd5004bc7e /tvix/castore/src/composition.rs
parent8df919dcf04b5c2502f3a63b4d013669da5e70c1 (diff)
refactor(tvix/store/composition): rename 'default' to 'root' r/8899
This becomes the root of the composition. `default` implies we can
directly access anything else, which we cannot. `root` makes this more
understandable, and it's all internal only anyways.

Change-Id: I297511bc05a7c32c59510b9d192b40d1bd937b5f
Reviewed-on: https://cl.tvl.fyi/c/depot/+/12746
Reviewed-by: yuka <yuka@yuka.dev>
Tested-by: BuildkiteCI
Diffstat (limited to 'tvix/castore/src/composition.rs')
-rw-r--r--tvix/castore/src/composition.rs22
1 files changed, 11 insertions, 11 deletions
diff --git a/tvix/castore/src/composition.rs b/tvix/castore/src/composition.rs
index b251187e1c34..c6fa1ce64ac4 100644
--- a/tvix/castore/src/composition.rs
+++ b/tvix/castore/src/composition.rs
@@ -62,7 +62,7 @@
 //!   "blobstore2": {
 //!     "type": "memory"
 //!   },
-//!   "default": {
+//!   "root": {
 //!     "type": "combined",
 //!     "local": "blobstore1",
 //!     "remote": "blobstore2"
@@ -72,7 +72,7 @@
 //! let blob_services_configs = with_registry(&REG, || serde_json::from_value(blob_services_configs_json))?;
 //! let mut blob_service_composition = Composition::new(&REG);
 //! blob_service_composition.extend_with_configs::<dyn BlobService>(blob_services_configs);
-//! let blob_service: Arc<dyn BlobService> = blob_service_composition.build("default").await?;
+//! let blob_service: Arc<dyn BlobService> = blob_service_composition.build("root").await?;
 //! # Ok(())
 //! # })
 //! # }
@@ -281,7 +281,7 @@ pub fn add_default_services(reg: &mut Registry) {
 pub struct CompositionContext<'a> {
     // The stack used to detect recursive instantiations and prevent deadlocks
     // The TypeId of the trait object is included to distinguish e.g. the
-    // BlobService "default" and the DirectoryService "default".
+    // BlobService "root" and the DirectoryService "root".
     stack: Vec<(TypeId, String)>,
     registry: &'static Registry,
     composition: Option<&'a Composition>,
@@ -529,7 +529,7 @@ mod test {
     #[tokio::test]
     async fn concurrent() {
         let blob_services_configs_json = serde_json::json!({
-            "default": {
+            "root": {
                 "type": "memory",
             }
         });
@@ -539,8 +539,8 @@ mod test {
         let mut blob_service_composition = Composition::new(&REG);
         blob_service_composition.extend_with_configs::<dyn BlobService>(blob_services_configs);
         let (blob_service1, blob_service2) = tokio::join!(
-            blob_service_composition.build::<dyn BlobService>("default"),
-            blob_service_composition.build::<dyn BlobService>("default")
+            blob_service_composition.build::<dyn BlobService>("root"),
+            blob_service_composition.build::<dyn BlobService>("root")
         );
         assert!(Arc::ptr_eq(
             &blob_service1.unwrap(),
@@ -552,15 +552,15 @@ mod test {
     #[tokio::test]
     async fn reject_recursion() {
         let blob_services_configs_json = serde_json::json!({
-            "default": {
+            "root": {
                 "type": "combined",
                 "local": "other",
                 "remote": "other"
             },
             "other": {
                 "type": "combined",
-                "local": "default",
-                "remote": "default"
+                "local": "root",
+                "remote": "root"
             }
         });
 
@@ -569,11 +569,11 @@ mod test {
         let mut blob_service_composition = Composition::new(&REG);
         blob_service_composition.extend_with_configs::<dyn BlobService>(blob_services_configs);
         match blob_service_composition
-            .build::<dyn BlobService>("default")
+            .build::<dyn BlobService>("root")
             .await
         {
             Err(CompositionError::Recursion(stack)) => {
-                assert_eq!(stack, vec!["default".to_string(), "other".to_string()])
+                assert_eq!(stack, vec!["root".to_string(), "other".to_string()])
             }
             other => panic!("should have returned an error, returned: {:?}", other.err()),
         }