1#[derive(Clone, Debug, PartialEq, Default, Serialize, Deserialize)]
12pub struct BackgroundTask {
13 #[serde(rename = "id")]
14 pub id: String,
15 #[serde(rename = "url", skip_serializing_if = "Option::is_none")]
16 pub url: Option<String>,
17 #[serde(rename = "description")]
18 pub description: String,
19 #[serde(rename = "origin")]
20 pub origin: String,
21 #[serde(rename = "func_name")]
22 pub func_name: String,
23 #[serde(rename = "args", skip_serializing_if = "Option::is_none")]
24 pub args: Option<Vec<serde_json::Value>>,
25 #[serde(rename = "kwargs", skip_serializing_if = "Option::is_none")]
26 pub kwargs: Option<::std::collections::HashMap<String, serde_json::Value>>,
27 #[serde(rename = "result")]
28 pub result: String,
29 #[serde(rename = "timeout")]
30 pub timeout: i32,
31 #[serde(rename = "result_ttl")]
32 pub result_ttl: i32,
33 #[serde(rename = "created_at")]
34 pub created_at: String,
35 #[serde(rename = "enqueued_at")]
36 pub enqueued_at: String,
37 #[serde(rename = "started_at")]
38 pub started_at: String,
39 #[serde(rename = "ended_at")]
40 pub ended_at: String,
41 #[serde(rename = "worker_name")]
42 pub worker_name: String,
43 #[serde(rename = "position", skip_serializing_if = "Option::is_none")]
44 pub position: Option<i32>,
45 #[serde(rename = "status", skip_serializing_if = "Option::is_none")]
46 pub status: Option<String>,
47 #[serde(rename = "meta")]
48 pub meta: ::std::collections::HashMap<String, serde_json::Value>,
49 #[serde(rename = "last_heartbeat")]
50 pub last_heartbeat: String,
51 #[serde(rename = "is_finished")]
52 pub is_finished: bool,
53 #[serde(rename = "is_queued")]
54 pub is_queued: bool,
55 #[serde(rename = "is_failed")]
56 pub is_failed: bool,
57 #[serde(rename = "is_started")]
58 pub is_started: bool,
59 #[serde(rename = "is_deferred")]
60 pub is_deferred: bool,
61 #[serde(rename = "is_canceled")]
62 pub is_canceled: bool,
63 #[serde(rename = "is_scheduled")]
64 pub is_scheduled: bool,
65 #[serde(rename = "is_stopped")]
66 pub is_stopped: bool,
67}
68
69impl BackgroundTask {
70 pub fn new(
71 id: String,
72 description: String,
73 origin: String,
74 func_name: String,
75 result: String,
76 timeout: i32,
77 result_ttl: i32,
78 created_at: String,
79 enqueued_at: String,
80 started_at: String,
81 ended_at: String,
82 worker_name: String,
83 meta: ::std::collections::HashMap<String, serde_json::Value>,
84 last_heartbeat: String,
85 is_finished: bool,
86 is_queued: bool,
87 is_failed: bool,
88 is_started: bool,
89 is_deferred: bool,
90 is_canceled: bool,
91 is_scheduled: bool,
92 is_stopped: bool,
93 ) -> BackgroundTask {
94 BackgroundTask {
95 id,
96 url: None,
97 description,
98 origin,
99 func_name,
100 args: None,
101 kwargs: None,
102 result,
103 timeout,
104 result_ttl,
105 created_at,
106 enqueued_at,
107 started_at,
108 ended_at,
109 worker_name,
110 position: None,
111 status: None,
112 meta,
113 last_heartbeat,
114 is_finished,
115 is_queued,
116 is_failed,
117 is_started,
118 is_deferred,
119 is_canceled,
120 is_scheduled,
121 is_stopped,
122 }
123 }
124}