Parking commit: container name different from label

Signed-off-by: itowlson <ivan.towlson@fermyon.com>

Author: itowlson

crates/blobstore-s3/src/lib.rs

@@ -31,6 +31,7 @@ pub struct S3BlobStoreRuntimeConfig {
     token: Option<String>,
     /// The AWS region where the S3 account is located
     region: String,
+    container_name: Option<String>,
 }
 
 impl MakeBlobStore for S3BlobStore {
@@ -50,7 +51,7 @@ impl MakeBlobStore for S3BlobStore {
             _ => anyhow::bail!("either both of access_key and secret_key must be provided, or neither"),
         };
 
-        let blob_store = BlobStoreS3::new(runtime_config.region, auth)?;
+        let blob_store = BlobStoreS3::new(runtime_config.region, auth, runtime_config.container_name)?;
         Ok(blob_store)
     }
 }

crates/blobstore-s3/src/store.rs

@@ -16,6 +16,7 @@ pub struct BlobStoreS3 {
         aws_sdk_s3::Client,
         std::pin::Pin<Box<dyn std::future::Future<Output = aws_sdk_s3::Client> + Send>>,
     >,
+    container_name: Option<String>,
 }
 
 /// AWS S3 runtime config literal options for authentication
@@ -69,6 +70,7 @@ impl BlobStoreS3 {
     pub fn new(
         region: String,
         auth_options: BlobStoreS3AuthOptions,
+        container_name: Option<String>,
     ) -> Result<Self> {
         let builder = match &auth_options {
             BlobStoreS3AuthOptions::RuntimeConfigValues(config) =>
@@ -95,17 +97,19 @@ impl BlobStoreS3 {
             aws_sdk_s3::Client::new(&sdk_config)
         });
 
-        Ok(Self { builder, client: async_once_cell::Lazy::from_future(client_fut) })
+        Ok(Self { builder, client: async_once_cell::Lazy::from_future(client_fut), container_name })
     }
 }
 
 #[async_trait]
 impl ContainerManager for BlobStoreS3 {
     async fn get(&self, name: &str) -> Result<Arc<dyn Container>, Error> {
-        let store = self.builder.clone().with_bucket_name(name).build().map_err(|e| e.to_string())?;
+        let name = self.container_name.clone().unwrap_or_else(|| name.to_owned());
+
+        let store = self.builder.clone().with_bucket_name(&name).build().map_err(|e| e.to_string())?;
 
         Ok(Arc::new(S3Container {
-            name: name.to_owned(),
+            name,
             store,
             client: self.client.get_unpin().await.clone(),
         }))