azure_data_cosmos 0.32.0

Rust wrappers around Microsoft Azure REST APIs - Azure Cosmos DB
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

// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.

use azure_core::http::{request::options::ContentType, Method};

use crate::constants;

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
#[allow(dead_code)] // For the variants. Can be removed when we have them all implemented.
pub enum OperationType {
    Create,
    Read,
    ReadFeed,
    Replace,
    Delete,
    Upsert,
    Query,
    SqlQuery,
    QueryPlan,
    Batch,
    Patch,
    Head,
    HeadFeed,
    Execute,
}

impl OperationType {
    /// Returns the content type of the body for this operation type, if any.
    ///
    /// If `None` is returned, no body content type header should be set and the request is expected to have no body.
    pub fn body_content_type(&self) -> Option<ContentType> {
        match self {
            OperationType::Query | OperationType::SqlQuery => Some(constants::QUERY_CONTENT_TYPE),
            OperationType::Create
            | OperationType::Replace
            | OperationType::Upsert
            | OperationType::Batch
            | OperationType::Patch
            | OperationType::QueryPlan
            | OperationType::Execute => Some(ContentType::APPLICATION_JSON),
            OperationType::Read
            | OperationType::ReadFeed
            | OperationType::Delete
            | OperationType::Head
            | OperationType::HeadFeed => None,
        }
    }

    /// Returns true if the operation does not modify server state and can be
    /// treated as read-only for caching / retry heuristics.
    pub fn is_read_only(&self) -> bool {
        matches!(
            self,
            OperationType::Read
                | OperationType::Query
                | OperationType::SqlQuery
                | OperationType::QueryPlan
                | OperationType::Head
                | OperationType::HeadFeed
        )
    }

    /// Maps the `OperationType` to its corresponding HTTP verb.
    pub fn http_method(self) -> Method {
        match self {
            OperationType::Create
            | OperationType::Upsert
            | OperationType::Query
            | OperationType::SqlQuery
            | OperationType::Batch
            | OperationType::QueryPlan
            | OperationType::Execute => Method::Post,
            OperationType::Delete => Method::Delete,
            OperationType::Read => Method::Get,
            OperationType::ReadFeed => Method::Get,
            OperationType::Replace => Method::Put,
            OperationType::Patch => Method::Patch,
            OperationType::Head | OperationType::HeadFeed => Method::Head,
        }
    }
}