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
107
108
109
110
111

use crate::{
    Client, Result,
    types::{
        AddTeamMemberRequest, CreateTeamRequest, CreateTeamResponse, SuccessResponse, Team, TeamId,
        TeamMember, TeamSearchParams, TeamSearchResult, UpdateTeamMemberRequest, UpdateTeamRequest,
        UserId,
    },
};

#[derive(Clone)]
pub struct TeamsService {
    client: Client,
}

impl TeamsService {
    pub(crate) fn new(client: Client) -> Self {
        Self { client }
    }

    pub async fn search(&self, params: &TeamSearchParams) -> Result<TeamSearchResult> {
        self.client
            .get_json(&["teams", "search"], Some(params))
            .await
    }

    pub async fn create(&self, request: &CreateTeamRequest) -> Result<CreateTeamResponse> {
        self.client.post_json(&["teams"], request).await
    }

    pub async fn get_by_id(&self, team_id: impl Into<TeamId>) -> Result<Team> {
        let team_id: TeamId = team_id.into();
        let team_id_str = team_id.0.to_string();
        let segments = ["teams", team_id_str.as_str()];
        self.client.get_json(&segments, Option::<&()>::None).await
    }

    pub async fn update(
        &self,
        team_id: impl Into<TeamId>,
        request: &UpdateTeamRequest,
    ) -> Result<SuccessResponse> {
        let team_id: TeamId = team_id.into();
        let team_id_str = team_id.0.to_string();
        let segments = ["teams", team_id_str.as_str()];
        self.client.put_json(&segments, request).await
    }

    pub async fn delete(&self, team_id: impl Into<TeamId>) -> Result<SuccessResponse> {
        let team_id: TeamId = team_id.into();
        let team_id_str = team_id.0.to_string();
        let segments = ["teams", team_id_str.as_str()];
        self.client.delete_json(&segments).await
    }

    pub async fn members(&self, team_id: impl Into<TeamId>) -> Result<Vec<TeamMember>> {
        let team_id: TeamId = team_id.into();
        let team_id_str = team_id.0.to_string();
        let segments = ["teams", team_id_str.as_str(), "members"];
        self.client.get_json(&segments, Option::<&()>::None).await
    }

    pub async fn add_member(
        &self,
        team_id: impl Into<TeamId>,
        user_id: impl Into<UserId>,
    ) -> Result<SuccessResponse> {
        let user_id: UserId = user_id.into();
        let request = AddTeamMemberRequest::new(user_id.0);
        let team_id: TeamId = team_id.into();
        let team_id_str = team_id.0.to_string();
        let segments = ["teams", team_id_str.as_str(), "members"];
        self.client.post_json(&segments, &request).await
    }

    pub async fn update_member_permission(
        &self,
        team_id: impl Into<TeamId>,
        user_id: impl Into<UserId>,
        request: &UpdateTeamMemberRequest,
    ) -> Result<SuccessResponse> {
        let team_id: TeamId = team_id.into();
        let user_id: UserId = user_id.into();
        let team_id_str = team_id.0.to_string();
        let user_id_str = user_id.0.to_string();
        let segments = [
            "teams",
            team_id_str.as_str(),
            "members",
            user_id_str.as_str(),
        ];
        self.client.put_json(&segments, request).await
    }

    pub async fn remove_member(
        &self,
        team_id: impl Into<TeamId>,
        user_id: impl Into<UserId>,
    ) -> Result<SuccessResponse> {
        let team_id: TeamId = team_id.into();
        let user_id: UserId = user_id.into();
        let team_id_str = team_id.0.to_string();
        let user_id_str = user_id.0.to_string();
        let segments = [
            "teams",
            team_id_str.as_str(),
            "members",
            user_id_str.as_str(),
        ];
        self.client.delete_json(&segments).await
    }
}