2
2
use progenitor_client::{encode_path, RequestBuilderExt};
3
3
pub use progenitor_client::{generate_websocket_key, ByteStream, Error, ResponseValue};
4
4
pub mod types {
5
+ #[allow(unused_imports)]
6
+ use super::*;
5
7
use serde::{Deserialize, Serialize};
6
8
#[allow(unused_imports)]
7
9
use std::convert::TryFrom;
8
10
#[derive(Clone, Debug, Deserialize, Serialize)]
11
+ #[serde(crate = "progenitor_client::deps::serde")]
9
12
pub struct Task {
10
13
pub id: String,
11
14
pub name: String,
@@ -21,6 +24,7 @@ pub mod types {
21
24
}
22
25
23
26
#[derive(Clone, Debug, Deserialize, Serialize)]
27
+ #[serde(crate = "progenitor_client::deps::serde")]
24
28
pub struct TaskEvent {
25
29
pub payload: String,
26
30
pub seq: u32,
@@ -35,6 +39,7 @@ pub mod types {
35
39
}
36
40
37
41
#[derive(Clone, Debug, Deserialize, Serialize)]
42
+ #[serde(crate = "progenitor_client::deps::serde")]
38
43
pub struct TaskOutput {
39
44
pub id: String,
40
45
pub path: String,
@@ -48,6 +53,7 @@ pub mod types {
48
53
}
49
54
50
55
#[derive(Clone, Debug, Deserialize, Serialize)]
56
+ #[serde(crate = "progenitor_client::deps::serde")]
51
57
pub struct TaskSubmit {
52
58
pub name: String,
53
59
#[serde(default, skip_serializing_if = "Vec::is_empty")]
@@ -62,6 +68,7 @@ pub mod types {
62
68
}
63
69
64
70
#[derive(Clone, Debug, Deserialize, Serialize)]
71
+ #[serde(crate = "progenitor_client::deps::serde")]
65
72
pub struct TaskSubmitResult {
66
73
pub id: String,
67
74
}
@@ -73,6 +80,7 @@ pub mod types {
73
80
}
74
81
75
82
#[derive(Clone, Debug, Deserialize, Serialize)]
83
+ #[serde(crate = "progenitor_client::deps::serde")]
76
84
pub struct UploadedChunk {
77
85
pub id: String,
78
86
}
@@ -84,6 +92,7 @@ pub mod types {
84
92
}
85
93
86
94
#[derive(Clone, Debug, Deserialize, Serialize)]
95
+ #[serde(crate = "progenitor_client::deps::serde")]
87
96
pub struct UserCreate {
88
97
pub name: String,
89
98
}
@@ -95,6 +104,7 @@ pub mod types {
95
104
}
96
105
97
106
#[derive(Clone, Debug, Deserialize, Serialize)]
107
+ #[serde(crate = "progenitor_client::deps::serde")]
98
108
pub struct UserCreateResult {
99
109
pub id: String,
100
110
pub name: String,
@@ -108,6 +118,7 @@ pub mod types {
108
118
}
109
119
110
120
#[derive(Clone, Debug, Deserialize, Serialize)]
121
+ #[serde(crate = "progenitor_client::deps::serde")]
111
122
pub struct WhoamiResult {
112
123
pub id: String,
113
124
pub name: String,
@@ -120,6 +131,7 @@ pub mod types {
120
131
}
121
132
122
133
#[derive(Clone, Debug, Deserialize, Serialize)]
134
+ #[serde(crate = "progenitor_client::deps::serde")]
123
135
pub struct Worker {
124
136
pub deleted: bool,
125
137
pub id: String,
@@ -138,6 +150,7 @@ pub mod types {
138
150
}
139
151
140
152
#[derive(Clone, Debug, Deserialize, Serialize)]
153
+ #[serde(crate = "progenitor_client::deps::serde")]
141
154
pub struct WorkerAddOutput {
142
155
pub chunks: Vec<String>,
143
156
pub path: String,
@@ -151,6 +164,7 @@ pub mod types {
151
164
}
152
165
153
166
#[derive(Clone, Debug, Deserialize, Serialize)]
167
+ #[serde(crate = "progenitor_client::deps::serde")]
154
168
pub struct WorkerAppendTask {
155
169
pub payload: String,
156
170
pub stream: String,
@@ -164,6 +178,7 @@ pub mod types {
164
178
}
165
179
166
180
#[derive(Clone, Debug, Deserialize, Serialize)]
181
+ #[serde(crate = "progenitor_client::deps::serde")]
167
182
pub struct WorkerBootstrap {
168
183
pub bootstrap: String,
169
184
pub token: String,
@@ -176,6 +191,7 @@ pub mod types {
176
191
}
177
192
178
193
#[derive(Clone, Debug, Deserialize, Serialize)]
194
+ #[serde(crate = "progenitor_client::deps::serde")]
179
195
pub struct WorkerBootstrapResult {
180
196
pub id: String,
181
197
}
@@ -187,6 +203,7 @@ pub mod types {
187
203
}
188
204
189
205
#[derive(Clone, Debug, Deserialize, Serialize)]
206
+ #[serde(crate = "progenitor_client::deps::serde")]
190
207
pub struct WorkerCompleteTask {
191
208
pub failed: bool,
192
209
}
@@ -198,6 +215,7 @@ pub mod types {
198
215
}
199
216
200
217
#[derive(Clone, Debug, Deserialize, Serialize)]
218
+ #[serde(crate = "progenitor_client::deps::serde")]
201
219
pub struct WorkerPingResult {
202
220
pub poweroff: bool,
203
221
#[serde(default, skip_serializing_if = "Option::is_none")]
@@ -211,6 +229,7 @@ pub mod types {
211
229
}
212
230
213
231
#[derive(Clone, Debug, Deserialize, Serialize)]
232
+ #[serde(crate = "progenitor_client::deps::serde")]
214
233
pub struct WorkerPingTask {
215
234
pub id: String,
216
235
pub output_rules: Vec<String>,
@@ -224,6 +243,7 @@ pub mod types {
224
243
}
225
244
226
245
#[derive(Clone, Debug, Deserialize, Serialize)]
246
+ #[serde(crate = "progenitor_client::deps::serde")]
227
247
pub struct WorkerTask {
228
248
pub id: String,
229
249
pub name: String,
@@ -237,6 +257,7 @@ pub mod types {
237
257
}
238
258
239
259
#[derive(Clone, Debug, Deserialize, Serialize)]
260
+ #[serde(crate = "progenitor_client::deps::serde")]
240
261
pub struct WorkersResult {
241
262
pub workers: Vec<Worker>,
242
263
}
0 commit comments