@@ -24,16 +24,7 @@ use cron::Schedule;
24
24
use crate :: background:: BackgroundTaskType ;
25
25
use crate :: principal:: UserIdentity ;
26
26
27
- #[ derive(
28
- serde:: Serialize ,
29
- serde:: Deserialize ,
30
- Clone ,
31
- Debug ,
32
- Default ,
33
- Eq ,
34
- PartialEq ,
35
- num_derive:: FromPrimitive ,
36
- ) ]
27
+ #[ derive( Clone , Debug , Default , Eq , PartialEq , num_derive:: FromPrimitive ) ]
37
28
pub enum BackgroundJobState {
38
29
#[ default]
39
30
RUNNING = 0 ,
@@ -47,16 +38,7 @@ impl Display for BackgroundJobState {
47
38
}
48
39
}
49
40
50
- #[ derive(
51
- serde:: Serialize ,
52
- serde:: Deserialize ,
53
- Clone ,
54
- Debug ,
55
- Default ,
56
- Eq ,
57
- PartialEq ,
58
- num_derive:: FromPrimitive ,
59
- ) ]
41
+ #[ derive( Clone , Debug , Default , Eq , PartialEq , num_derive:: FromPrimitive ) ]
60
42
pub enum BackgroundJobType {
61
43
#[ default]
62
44
ONESHOT = 0 ,
@@ -87,7 +69,7 @@ impl ManualTriggerParams {
87
69
}
88
70
}
89
71
90
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Default , Eq , PartialEq ) ]
72
+ #[ derive( Clone , Debug , Default , Eq , PartialEq ) ]
91
73
pub struct BackgroundJobParams {
92
74
pub job_type : BackgroundJobType ,
93
75
pub scheduled_job_interval : std:: time:: Duration ,
@@ -159,7 +141,7 @@ impl Display for BackgroundJobParams {
159
141
}
160
142
}
161
143
162
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Default , Eq , PartialEq ) ]
144
+ #[ derive( Clone , Debug , Default , Eq , PartialEq ) ]
163
145
pub struct BackgroundJobStatus {
164
146
pub job_state : BackgroundJobState ,
165
147
pub last_task_id : Option < String > ,
@@ -216,7 +198,7 @@ impl Display for BackgroundJobIdent {
216
198
}
217
199
218
200
// Info
219
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Default , Eq , PartialEq ) ]
201
+ #[ derive( Clone , Debug , Default , Eq , PartialEq ) ]
220
202
pub struct BackgroundJobInfo {
221
203
pub job_params : Option < BackgroundJobParams > ,
222
204
pub job_status : Option < BackgroundJobStatus > ,
@@ -244,12 +226,12 @@ impl BackgroundJobInfo {
244
226
}
245
227
}
246
228
247
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , Default , Eq , PartialEq ) ]
229
+ #[ derive( Clone , Debug , Default , Eq , PartialEq ) ]
248
230
pub struct BackgroundJobId {
249
231
pub id : u64 ,
250
232
}
251
233
252
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
234
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
253
235
pub struct CreateBackgroundJobReq {
254
236
pub if_not_exists : bool ,
255
237
pub job_name : BackgroundJobIdent ,
@@ -271,12 +253,12 @@ impl Display for CreateBackgroundJobReq {
271
253
}
272
254
}
273
255
274
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
256
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
275
257
pub struct CreateBackgroundJobReply {
276
258
pub id : u64 ,
277
259
}
278
260
279
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
261
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
280
262
pub struct GetBackgroundJobReq {
281
263
pub name : BackgroundJobIdent ,
282
264
}
@@ -287,13 +269,13 @@ impl Display for GetBackgroundJobReq {
287
269
}
288
270
}
289
271
290
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
272
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
291
273
pub struct GetBackgroundJobReply {
292
274
pub id : u64 ,
293
275
pub info : BackgroundJobInfo ,
294
276
}
295
277
296
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
278
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
297
279
pub struct UpdateBackgroundJobStatusReq {
298
280
pub job_name : BackgroundJobIdent ,
299
281
pub status : BackgroundJobStatus ,
@@ -309,7 +291,7 @@ impl Display for UpdateBackgroundJobStatusReq {
309
291
}
310
292
}
311
293
312
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
294
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
313
295
pub struct UpdateBackgroundJobParamsReq {
314
296
pub job_name : BackgroundJobIdent ,
315
297
pub params : BackgroundJobParams ,
@@ -325,7 +307,7 @@ impl Display for UpdateBackgroundJobParamsReq {
325
307
}
326
308
}
327
309
328
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
310
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
329
311
pub struct UpdateBackgroundJobReq {
330
312
pub job_name : BackgroundJobIdent ,
331
313
pub info : BackgroundJobInfo ,
@@ -347,12 +329,12 @@ impl Display for UpdateBackgroundJobReq {
347
329
}
348
330
}
349
331
350
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
332
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
351
333
pub struct UpdateBackgroundJobReply {
352
334
pub id : u64 ,
353
335
}
354
336
355
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
337
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
356
338
pub struct DeleteBackgroundJobReq {
357
339
pub name : BackgroundJobIdent ,
358
340
}
@@ -363,10 +345,10 @@ impl Display for DeleteBackgroundJobReq {
363
345
}
364
346
}
365
347
366
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
348
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
367
349
pub struct DeleteBackgroundJobReply { }
368
350
// list
369
- #[ derive( serde :: Serialize , serde :: Deserialize , Clone , Debug , PartialEq , Eq ) ]
351
+ #[ derive( Clone , Debug , PartialEq , Eq ) ]
370
352
pub struct ListBackgroundJobsReq {
371
353
pub tenant : String ,
372
354
}
0 commit comments