azure_storage_blobs/blob/operations/
set_metadata.rs

1use crate::prelude::*;
2use azure_core::{headers::*, prelude::*, Method, RequestId};
3use time::OffsetDateTime;
4
5operation! {
6    SetMetadata,
7    client: BlobClient,
8    ?if_modified_since: IfModifiedSinceCondition,
9    ?if_match: IfMatchCondition,
10    ?if_tags: IfTags,
11    ?lease_id: LeaseId,
12    ?metadata: Metadata
13}
14
15impl SetMetadataBuilder {
16    pub fn into_future(mut self) -> SetMetadata {
17        Box::pin(async move {
18            let mut url = self.client.url()?;
19
20            url.query_pairs_mut().append_pair("comp", "metadata");
21
22            let mut headers = Headers::new();
23            headers.add(self.lease_id);
24            headers.add(self.if_modified_since);
25            headers.add(self.if_match);
26            headers.add(self.if_tags);
27            if let Some(metadata) = &self.metadata {
28                for m in metadata.iter() {
29                    headers.add(m);
30                }
31            }
32
33            let mut request = BlobClient::finalize_request(url, Method::Put, headers, None)?;
34
35            let response = self.client.send(&mut self.context, &mut request).await?;
36            response.headers().try_into()
37        })
38    }
39}
40
41#[derive(Debug, Clone)]
42pub struct SetMetadataResponse {
43    pub request_id: RequestId,
44    pub etag: String,
45    pub server: String,
46    pub date: OffsetDateTime,
47}
48
49impl TryFrom<&Headers> for SetMetadataResponse {
50    type Error = azure_core::Error;
51
52    fn try_from(headers: &Headers) -> Result<Self, Self::Error> {
53        Ok(SetMetadataResponse {
54            request_id: request_id_from_headers(headers)?,
55            etag: etag_from_headers(headers)?,
56            server: server_from_headers(headers)?,
57            date: date_from_headers(headers)?,
58        })
59    }
60}
azure_storage_blobs/blob/operations/set_metadata.rs

azure_storage_blobs/blob/operations/
set_metadata.rs
