grafana 0.1.3

Ergonomic Rust SDK for Grafana's HTTP API, with async and blocking clients.
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

use http::Method;

use crate::{
    BlockingClient, Result,
    types::{
        CreateServiceAccountRequest, CreateServiceAccountTokenRequest, NewApiKey, ServiceAccount,
        ServiceAccountId, ServiceAccountSearchParams, ServiceAccountSearchResult, SuccessResponse,
        Token, TokenId, UpdateServiceAccountRequest, UpdateServiceAccountResponse,
    },
};

#[derive(Clone)]
pub struct BlockingServiceAccountsService {
    client: BlockingClient,
}

impl BlockingServiceAccountsService {
    pub(crate) fn new(client: BlockingClient) -> Self {
        Self { client }
    }

    pub fn search(
        &self,
        params: &ServiceAccountSearchParams,
    ) -> Result<ServiceAccountSearchResult> {
        self.client
            .get_json(&["serviceaccounts", "search"], Some(params))
    }

    pub fn create(&self, request: &CreateServiceAccountRequest) -> Result<ServiceAccount> {
        self.client.post_json(&["serviceaccounts"], request)
    }

    pub fn get_by_id(
        &self,
        service_account_id: impl Into<ServiceAccountId>,
    ) -> Result<ServiceAccount> {
        let service_account_id: ServiceAccountId = service_account_id.into();
        let id_str = service_account_id.0.to_string();
        let segments = ["serviceaccounts", id_str.as_str()];
        self.client.get_json(&segments, Option::<&()>::None)
    }

    pub fn update(
        &self,
        service_account_id: impl Into<ServiceAccountId>,
        request: &UpdateServiceAccountRequest,
    ) -> Result<UpdateServiceAccountResponse> {
        let service_account_id: ServiceAccountId = service_account_id.into();
        let id_str = service_account_id.0.to_string();
        let segments = ["serviceaccounts", id_str.as_str()];
        self.client
            .request_json::<UpdateServiceAccountResponse, (), UpdateServiceAccountRequest>(
                Method::PATCH,
                &segments,
                None,
                Some(request),
            )
    }

    pub fn delete(
        &self,
        service_account_id: impl Into<ServiceAccountId>,
    ) -> Result<SuccessResponse> {
        let service_account_id: ServiceAccountId = service_account_id.into();
        let id_str = service_account_id.0.to_string();
        let segments = ["serviceaccounts", id_str.as_str()];
        self.client.delete_json(&segments)
    }

    pub fn tokens(&self, service_account_id: impl Into<ServiceAccountId>) -> Result<Vec<Token>> {
        let service_account_id: ServiceAccountId = service_account_id.into();
        let id_str = service_account_id.0.to_string();
        let segments = ["serviceaccounts", id_str.as_str(), "tokens"];
        self.client.get_json(&segments, Option::<&()>::None)
    }

    pub fn create_token(
        &self,
        service_account_id: impl Into<ServiceAccountId>,
        request: &CreateServiceAccountTokenRequest,
    ) -> Result<NewApiKey> {
        let service_account_id: ServiceAccountId = service_account_id.into();
        let id_str = service_account_id.0.to_string();
        let segments = ["serviceaccounts", id_str.as_str(), "tokens"];
        self.client.post_json(&segments, request)
    }

    pub fn delete_token(
        &self,
        service_account_id: impl Into<ServiceAccountId>,
        token_id: impl Into<TokenId>,
    ) -> Result<SuccessResponse> {
        let service_account_id: ServiceAccountId = service_account_id.into();
        let token_id: TokenId = token_id.into();
        let service_account_id_str = service_account_id.0.to_string();
        let token_id_str = token_id.0.to_string();
        let segments = [
            "serviceaccounts",
            service_account_id_str.as_str(),
            "tokens",
            token_id_str.as_str(),
        ];
        self.client.delete_json(&segments)
    }
}