azure_core 0.8.0

Rust wrappers around Microsoft Azure REST APIs - Core crate
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

use super::*;
use crate::prelude::Continuation;
use crate::request_options::LeaseId;
use crate::{date, RequestId, SessionToken};
use time::OffsetDateTime;

pub fn lease_id_from_headers(headers: &Headers) -> crate::Result<LeaseId> {
    headers.get_as(&LEASE_ID)
}

pub fn request_id_from_headers(headers: &Headers) -> crate::Result<RequestId> {
    headers.get_as(&REQUEST_ID)
}

pub fn client_request_id_from_headers_optional(headers: &Headers) -> Option<String> {
    headers.get_optional_string(&CLIENT_REQUEST_ID)
}

pub fn last_modified_from_headers_optional(
    headers: &Headers,
) -> crate::Result<Option<OffsetDateTime>> {
    headers
        .get_optional_str(&LAST_MODIFIED)
        .map(date::parse_rfc1123)
        .transpose()
}

pub fn date_from_headers(headers: &Headers) -> crate::Result<OffsetDateTime> {
    rfc1123_from_headers_mandatory(headers, &DATE)
}

pub fn last_modified_from_headers(headers: &Headers) -> crate::Result<OffsetDateTime> {
    rfc1123_from_headers_mandatory(headers, &LAST_MODIFIED)
}

pub fn rfc1123_from_headers_mandatory(
    headers: &Headers,
    header_name: &HeaderName,
) -> crate::Result<OffsetDateTime> {
    let date = headers.get_str(header_name)?;
    date::parse_rfc1123(date)
}

pub fn continuation_token_from_headers_optional(
    headers: &Headers,
) -> crate::Result<Option<Continuation>> {
    Ok(headers
        .get_optional_string(&CONTINUATION)
        .map(Continuation::from))
}

pub fn sku_name_from_headers(headers: &Headers) -> crate::Result<String> {
    headers.get_as(&SKU_NAME)
}

pub fn account_kind_from_headers(headers: &Headers) -> crate::Result<String> {
    headers.get_as(&ACCOUNT_KIND)
}

pub fn etag_from_headers_optional(headers: &Headers) -> crate::Result<Option<String>> {
    Ok(headers.get_optional_string(&ETAG))
}

pub fn etag_from_headers(headers: &Headers) -> crate::Result<String> {
    headers.get_as(&ETAG)
}

pub fn lease_time_from_headers(headers: &Headers) -> crate::Result<u8> {
    headers.get_as(&LEASE_TIME)
}

#[cfg(not(feature = "azurite_workaround"))]
pub fn delete_type_permanent_from_headers(headers: &Headers) -> crate::Result<bool> {
    headers.get_as(&DELETE_TYPE_PERMANENT)
}

#[cfg(feature = "azurite_workaround")]
pub fn delete_type_permanent_from_headers(headers: &Headers) -> crate::Result<Option<bool>> {
    headers.get_optional_as(&DELETE_TYPE_PERMANENT)
}

pub fn sequence_number_from_headers(headers: &Headers) -> crate::Result<u64> {
    headers.get_as(&BLOB_SEQUENCE_NUMBER)
}

pub fn session_token_from_headers(headers: &Headers) -> crate::Result<SessionToken> {
    headers.get_as(&SESSION_TOKEN)
}

pub fn server_from_headers(headers: &Headers) -> crate::Result<String> {
    headers.get_as(&SERVER)
}

pub fn version_from_headers(headers: &Headers) -> crate::Result<String> {
    headers.get_as(&VERSION)
}

pub fn request_server_encrypted_from_headers(headers: &Headers) -> crate::Result<bool> {
    headers.get_as(&REQUEST_SERVER_ENCRYPTED)
}

pub fn content_type_from_headers(headers: &Headers) -> crate::Result<String> {
    headers.get_as(&CONTENT_TYPE)
}

pub fn item_count_from_headers(headers: &Headers) -> crate::Result<u32> {
    headers.get_as(&ITEM_COUNT)
}