in core/src/services/azdfs/backend.rs [152:208]
fn build(&mut self) -> Result<Self::Accessor> {
debug!("backend build started: {:?}", &self);
let root = normalize_root(&self.root.take().unwrap_or_default());
debug!("backend use root {}", root);
// Handle endpoint, region and container name.
let filesystem = match self.filesystem.is_empty() {
false => Ok(&self.filesystem),
true => Err(Error::new(ErrorKind::ConfigInvalid, "filesystem is empty")
.with_operation("Builder::build")
.with_context("service", Scheme::Azdfs)),
}?;
debug!("backend use filesystem {}", &filesystem);
let endpoint = match &self.endpoint {
Some(endpoint) => Ok(endpoint.clone()),
None => Err(Error::new(ErrorKind::ConfigInvalid, "endpoint is empty")
.with_operation("Builder::build")
.with_context("service", Scheme::Azdfs)),
}?;
debug!("backend use endpoint {}", &filesystem);
let client = if let Some(client) = self.http_client.take() {
client
} else {
HttpClient::new().map_err(|err| {
err.with_operation("Builder::build")
.with_context("service", Scheme::Azdfs)
})?
};
let config_loader = AzureStorageConfig {
account_name: self
.account_name
.clone()
.or_else(|| infer_storage_name_from_endpoint(endpoint.as_str())),
account_key: self.account_key.clone(),
sas_token: None,
..Default::default()
};
let cred_loader = AzureStorageLoader::new(config_loader);
let signer = AzureStorageSigner::new();
debug!("backend build finished: {:?}", &self);
Ok(AzdfsBackend {
core: Arc::new(AzdfsCore {
filesystem: self.filesystem.clone(),
root,
endpoint,
client,
loader: cred_loader,
signer,
}),
})
}