alibabacloud-imm 0.1.0

A modern, easy-to-use, and reqwest-powered Rust SDK for Alibaba Cloud Intelligent Media Management (IMM)
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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158

//! Task operations.

use std::future::Future;

use serde::{Deserialize, Serialize};

use crate::error::Result;
use crate::response::BodyResponseProcessor;
use crate::{Client, Ops, Request};

#[derive(Debug, Clone, Default, Serialize)]
#[serde(rename_all = "PascalCase")]
pub struct GetTaskQuery {
    pub project_name: String,
    pub task_type: String,
    pub task_id: String,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub request_definition: Option<bool>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct GetTaskResponse {
    #[serde(default)]
    pub request_id: String,
    #[serde(default)]
    pub project_name: Option<String>,
    #[serde(default)]
    pub event_id: Option<String>,
    #[serde(default)]
    pub status: Option<String>,
    #[serde(default)]
    pub code: Option<String>,
    #[serde(default)]
    pub message: Option<String>,
    #[serde(default)]
    pub start_time: Option<String>,
    #[serde(default)]
    pub end_time: Option<String>,
    #[serde(default)]
    pub user_data: Option<String>,
    #[serde(default)]
    pub task_type: Option<String>,
    #[serde(default)]
    pub task_id: Option<String>,
    #[serde(default)]
    pub tags: Option<serde_json::Value>,
    #[serde(default)]
    pub task_request_definition: Option<String>,
    #[serde(default)]
    pub progress: Option<i64>,
}

/// Get asynchronous task information by task ID and type.
///
/// Official documentation: <https://www.alibabacloud.com/help/en/imm/developer-reference/api-imm-2020-09-30-gettask>
pub struct GetTask {
    pub query: GetTaskQuery,
}

impl Ops for GetTask {
    const ACTION: &'static str = "GetTask";
    type Query = GetTaskQuery;
    type Body = ();
    type Response = BodyResponseProcessor<GetTaskResponse>;

    fn into_parts(self) -> (Self::Query, Self::Body) {
        (self.query, ())
    }
}

pub trait GetTaskOps {
    /// Get asynchronous task information by task ID and type.
    ///
    /// Official documentation: <https://www.alibabacloud.com/help/en/imm/developer-reference/api-imm-2020-09-30-gettask>
    fn get_task(&self, query: GetTaskQuery) -> impl Future<Output = Result<GetTaskResponse>>;
}

impl GetTaskOps for Client {
    async fn get_task(&self, query: GetTaskQuery) -> Result<GetTaskResponse> {
        self.request(GetTask { query }).await
    }
}

#[derive(Debug, Clone, Default, Serialize)]
#[serde(rename_all = "PascalCase")]
pub struct ListTasksQuery {
    pub project_name: String,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub task_types: Option<serde_json::Value>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub next_token: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub max_results: Option<i64>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub tag_selector: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub sort: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub order: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub status: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub start_time_range: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub end_time_range: Option<String>,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub request_definition: Option<bool>,
}

#[derive(Debug, Clone, Deserialize)]
#[serde(rename_all = "PascalCase")]
pub struct ListTasksResponse {
    #[serde(default)]
    pub request_id: String,
    #[serde(default)]
    pub project_name: Option<String>,
    #[serde(default)]
    pub next_token: Option<String>,
    #[serde(default)]
    pub max_results: Option<String>,
    #[serde(default)]
    pub tasks: Vec<serde_json::Value>,
}

/// List tasks with filtering by time range, status, type, and tags.
///
/// Official documentation: <https://www.alibabacloud.com/help/en/imm/developer-reference/api-imm-2020-09-30-listtasks>
pub struct ListTasks {
    pub query: ListTasksQuery,
}

impl Ops for ListTasks {
    const ACTION: &'static str = "ListTasks";
    type Query = ListTasksQuery;
    type Body = ();
    type Response = BodyResponseProcessor<ListTasksResponse>;

    fn into_parts(self) -> (Self::Query, Self::Body) {
        (self.query, ())
    }
}

pub trait ListTasksOps {
    /// List tasks with filtering by time range, status, type, and tags.
    ///
    /// Official documentation: <https://www.alibabacloud.com/help/en/imm/developer-reference/api-imm-2020-09-30-listtasks>
    fn list_tasks(&self, query: ListTasksQuery) -> impl Future<Output = Result<ListTasksResponse>>;
}

impl ListTasksOps for Client {
    async fn list_tasks(&self, query: ListTasksQuery) -> Result<ListTasksResponse> {
        self.request(ListTasks { query }).await
    }
}

pub trait TaskOperations: GetTaskOps + ListTasksOps {}
impl<T> TaskOperations for T where T: GetTaskOps + ListTasksOps {}