azure_storage_blobs/blob/operations/
set_blob_tier.rs1use 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}