azure_storage_blobs/blob/operations/
set_blob_tier.rs

1use crate::prelude::*;
2use azure_core::{headers::*, prelude::*, RequestId};
3
4operation! {
5    SetBlobTier,
6    client: BlobClient,
7    access_tier: AccessTier,
8    ?rehydrate_priority: RehydratePriority,
9    ?blob_versioning: BlobVersioning,
10    ?if_tags: IfTags
11}
12
13impl SetBlobTierBuilder {
14    pub fn into_future(mut self) -> SetBlobTier {
15        Box::pin(async move {
16            let mut url = self.client.url()?;
17            url.query_pairs_mut().append_pair("comp", "tier");
18            self.blob_versioning.append_to_url_query(&mut url);
19
20            let mut headers = Headers::new();
21            headers.add(self.access_tier);
22            headers.add(
23                self.rehydrate_priority
24                    .unwrap_or(RehydratePriority::Standard),
25            );
26            headers.add(self.if_tags);
27
28            let mut request =
29                BlobClient::finalize_request(url, azure_core::Method::Put, headers, None)?;
30
31            let response = self.client.send(&mut self.context, &mut request).await?;
32            response.headers().try_into()
33        })
34    }
35}
36
37#[derive(Debug, Clone)]
38pub struct SetBlobTierResponse {
39    pub request_id: RequestId,
40    pub client_request_id: Option<String>,
41    pub version: String,
42}
43
44impl TryFrom<&Headers> for SetBlobTierResponse {
45    type Error = azure_core::Error;
46
47    fn try_from(headers: &Headers) -> Result<Self, Self::Error> {
48        Ok(SetBlobTierResponse {
49            request_id: request_id_from_headers(headers)?,
50            client_request_id: client_request_id_from_headers_optional(headers),
51            version: version_from_headers(headers)?,
52        })
53    }
54}