Skip to main content

windmill_api/apis/
worker_api.rs

1/*
2 * Windmill API
3 *
4 * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
5 *
6 * The version of the OpenAPI document: 1.834.0
7 * Contact: contact@windmill.dev
8 * Generated by: https://openapi-generator.tech
9 */
10
11
12use reqwest;
13use serde::{Deserialize, Serialize};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration};
16
17
18/// struct for typed errors of method [`exists_workers_with_tags`]
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum ExistsWorkersWithTagsError {
22    UnknownValue(serde_json::Value),
23}
24
25/// struct for typed errors of method [`ge_default_tags`]
26#[derive(Debug, Clone, Serialize, Deserialize)]
27#[serde(untagged)]
28pub enum GeDefaultTagsError {
29    UnknownValue(serde_json::Value),
30}
31
32/// struct for typed errors of method [`get_counts_of_jobs_waiting_per_tag`]
33#[derive(Debug, Clone, Serialize, Deserialize)]
34#[serde(untagged)]
35pub enum GetCountsOfJobsWaitingPerTagError {
36    UnknownValue(serde_json::Value),
37}
38
39/// struct for typed errors of method [`get_counts_of_running_jobs_per_tag`]
40#[derive(Debug, Clone, Serialize, Deserialize)]
41#[serde(untagged)]
42pub enum GetCountsOfRunningJobsPerTagError {
43    UnknownValue(serde_json::Value),
44}
45
46/// struct for typed errors of method [`get_custom_tags`]
47#[derive(Debug, Clone, Serialize, Deserialize)]
48#[serde(untagged)]
49pub enum GetCustomTagsError {
50    UnknownValue(serde_json::Value),
51}
52
53/// struct for typed errors of method [`get_custom_tags_for_workspace`]
54#[derive(Debug, Clone, Serialize, Deserialize)]
55#[serde(untagged)]
56pub enum GetCustomTagsForWorkspaceError {
57    UnknownValue(serde_json::Value),
58}
59
60/// struct for typed errors of method [`get_queue_metrics`]
61#[derive(Debug, Clone, Serialize, Deserialize)]
62#[serde(untagged)]
63pub enum GetQueueMetricsError {
64    UnknownValue(serde_json::Value),
65}
66
67/// struct for typed errors of method [`get_queue_metrics_series`]
68#[derive(Debug, Clone, Serialize, Deserialize)]
69#[serde(untagged)]
70pub enum GetQueueMetricsSeriesError {
71    UnknownValue(serde_json::Value),
72}
73
74/// struct for typed errors of method [`get_queue_status`]
75#[derive(Debug, Clone, Serialize, Deserialize)]
76#[serde(untagged)]
77pub enum GetQueueStatusError {
78    UnknownValue(serde_json::Value),
79}
80
81/// struct for typed errors of method [`get_runnable_stats`]
82#[derive(Debug, Clone, Serialize, Deserialize)]
83#[serde(untagged)]
84pub enum GetRunnableStatsError {
85    UnknownValue(serde_json::Value),
86}
87
88/// struct for typed errors of method [`get_workspace_fairness_events`]
89#[derive(Debug, Clone, Serialize, Deserialize)]
90#[serde(untagged)]
91pub enum GetWorkspaceFairnessEventsError {
92    UnknownValue(serde_json::Value),
93}
94
95/// struct for typed errors of method [`is_default_tags_per_workspace`]
96#[derive(Debug, Clone, Serialize, Deserialize)]
97#[serde(untagged)]
98pub enum IsDefaultTagsPerWorkspaceError {
99    UnknownValue(serde_json::Value),
100}
101
102/// struct for typed errors of method [`list_workers`]
103#[derive(Debug, Clone, Serialize, Deserialize)]
104#[serde(untagged)]
105pub enum ListWorkersError {
106    UnknownValue(serde_json::Value),
107}
108
109
110pub async fn exists_workers_with_tags(configuration: &configuration::Configuration, tags: &str, workspace: Option<&str>) -> Result<std::collections::HashMap<String, bool>, Error<ExistsWorkersWithTagsError>> {
111    let local_var_configuration = configuration;
112
113    let local_var_client = &local_var_configuration.client;
114
115    let local_var_uri_str = format!("{}/workers/exists_workers_with_tags", local_var_configuration.base_path);
116    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
117
118    local_var_req_builder = local_var_req_builder.query(&[("tags", &tags.to_string())]);
119    if let Some(ref local_var_str) = workspace {
120        local_var_req_builder = local_var_req_builder.query(&[("workspace", &local_var_str.to_string())]);
121    }
122    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
123        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
124    }
125    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
126        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
127    };
128
129    let local_var_req = local_var_req_builder.build()?;
130    let local_var_resp = local_var_client.execute(local_var_req).await?;
131
132    let local_var_status = local_var_resp.status();
133    let local_var_content = local_var_resp.text().await?;
134
135    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
136        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
137    } else {
138        let local_var_entity: Option<ExistsWorkersWithTagsError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
139        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
140        Err(Error::ResponseError(local_var_error))
141    }
142}
143
144pub async fn ge_default_tags(configuration: &configuration::Configuration, ) -> Result<Vec<String>, Error<GeDefaultTagsError>> {
145    let local_var_configuration = configuration;
146
147    let local_var_client = &local_var_configuration.client;
148
149    let local_var_uri_str = format!("{}/workers/get_default_tags", local_var_configuration.base_path);
150    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
151
152    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
153        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
154    }
155    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
156        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
157    };
158
159    let local_var_req = local_var_req_builder.build()?;
160    let local_var_resp = local_var_client.execute(local_var_req).await?;
161
162    let local_var_status = local_var_resp.status();
163    let local_var_content = local_var_resp.text().await?;
164
165    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
166        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
167    } else {
168        let local_var_entity: Option<GeDefaultTagsError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
169        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
170        Err(Error::ResponseError(local_var_error))
171    }
172}
173
174pub async fn get_counts_of_jobs_waiting_per_tag(configuration: &configuration::Configuration, ) -> Result<std::collections::HashMap<String, i32>, Error<GetCountsOfJobsWaitingPerTagError>> {
175    let local_var_configuration = configuration;
176
177    let local_var_client = &local_var_configuration.client;
178
179    let local_var_uri_str = format!("{}/workers/queue_counts", local_var_configuration.base_path);
180    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
181
182    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
183        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
184    }
185    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
186        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
187    };
188
189    let local_var_req = local_var_req_builder.build()?;
190    let local_var_resp = local_var_client.execute(local_var_req).await?;
191
192    let local_var_status = local_var_resp.status();
193    let local_var_content = local_var_resp.text().await?;
194
195    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
196        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
197    } else {
198        let local_var_entity: Option<GetCountsOfJobsWaitingPerTagError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
199        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
200        Err(Error::ResponseError(local_var_error))
201    }
202}
203
204pub async fn get_counts_of_running_jobs_per_tag(configuration: &configuration::Configuration, ) -> Result<std::collections::HashMap<String, i32>, Error<GetCountsOfRunningJobsPerTagError>> {
205    let local_var_configuration = configuration;
206
207    let local_var_client = &local_var_configuration.client;
208
209    let local_var_uri_str = format!("{}/workers/queue_running_counts", local_var_configuration.base_path);
210    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
211
212    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
213        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
214    }
215    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
216        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
217    };
218
219    let local_var_req = local_var_req_builder.build()?;
220    let local_var_resp = local_var_client.execute(local_var_req).await?;
221
222    let local_var_status = local_var_resp.status();
223    let local_var_content = local_var_resp.text().await?;
224
225    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
226        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
227    } else {
228        let local_var_entity: Option<GetCountsOfRunningJobsPerTagError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
229        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
230        Err(Error::ResponseError(local_var_error))
231    }
232}
233
234pub async fn get_custom_tags(configuration: &configuration::Configuration, show_workspace_restriction: Option<bool>) -> Result<Vec<String>, Error<GetCustomTagsError>> {
235    let local_var_configuration = configuration;
236
237    let local_var_client = &local_var_configuration.client;
238
239    let local_var_uri_str = format!("{}/workers/custom_tags", local_var_configuration.base_path);
240    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
241
242    if let Some(ref local_var_str) = show_workspace_restriction {
243        local_var_req_builder = local_var_req_builder.query(&[("show_workspace_restriction", &local_var_str.to_string())]);
244    }
245    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
246        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
247    }
248    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
249        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
250    };
251
252    let local_var_req = local_var_req_builder.build()?;
253    let local_var_resp = local_var_client.execute(local_var_req).await?;
254
255    let local_var_status = local_var_resp.status();
256    let local_var_content = local_var_resp.text().await?;
257
258    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
259        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
260    } else {
261        let local_var_entity: Option<GetCustomTagsError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
262        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
263        Err(Error::ResponseError(local_var_error))
264    }
265}
266
267pub async fn get_custom_tags_for_workspace(configuration: &configuration::Configuration, workspace: &str) -> Result<Vec<String>, Error<GetCustomTagsForWorkspaceError>> {
268    let local_var_configuration = configuration;
269
270    let local_var_client = &local_var_configuration.client;
271
272    let local_var_uri_str = format!("{}/w/{workspace}/workers/custom_tags", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
273    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
274
275    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
276        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
277    }
278    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
279        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
280    };
281
282    let local_var_req = local_var_req_builder.build()?;
283    let local_var_resp = local_var_client.execute(local_var_req).await?;
284
285    let local_var_status = local_var_resp.status();
286    let local_var_content = local_var_resp.text().await?;
287
288    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
289        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
290    } else {
291        let local_var_entity: Option<GetCustomTagsForWorkspaceError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
292        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
293        Err(Error::ResponseError(local_var_error))
294    }
295}
296
297pub async fn get_queue_metrics(configuration: &configuration::Configuration, ) -> Result<Vec<models::GetQueueMetrics200ResponseInner>, Error<GetQueueMetricsError>> {
298    let local_var_configuration = configuration;
299
300    let local_var_client = &local_var_configuration.client;
301
302    let local_var_uri_str = format!("{}/workers/queue_metrics", local_var_configuration.base_path);
303    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
304
305    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
306        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
307    }
308    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
309        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
310    };
311
312    let local_var_req = local_var_req_builder.build()?;
313    let local_var_resp = local_var_client.execute(local_var_req).await?;
314
315    let local_var_status = local_var_resp.status();
316    let local_var_content = local_var_resp.text().await?;
317
318    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
319        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
320    } else {
321        let local_var_entity: Option<GetQueueMetricsError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
322        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
323        Err(Error::ResponseError(local_var_error))
324    }
325}
326
327pub async fn get_queue_metrics_series(configuration: &configuration::Configuration, window_secs: Option<i32>) -> Result<models::GetQueueMetricsSeries200Response, Error<GetQueueMetricsSeriesError>> {
328    let local_var_configuration = configuration;
329
330    let local_var_client = &local_var_configuration.client;
331
332    let local_var_uri_str = format!("{}/workers/queue_metrics_series", local_var_configuration.base_path);
333    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
334
335    if let Some(ref local_var_str) = window_secs {
336        local_var_req_builder = local_var_req_builder.query(&[("window_secs", &local_var_str.to_string())]);
337    }
338    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
339        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
340    }
341    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
342        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
343    };
344
345    let local_var_req = local_var_req_builder.build()?;
346    let local_var_resp = local_var_client.execute(local_var_req).await?;
347
348    let local_var_status = local_var_resp.status();
349    let local_var_content = local_var_resp.text().await?;
350
351    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
352        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
353    } else {
354        let local_var_entity: Option<GetQueueMetricsSeriesError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
355        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
356        Err(Error::ResponseError(local_var_error))
357    }
358}
359
360pub async fn get_queue_status(configuration: &configuration::Configuration, ) -> Result<Vec<models::GetQueueStatus200ResponseInner>, Error<GetQueueStatusError>> {
361    let local_var_configuration = configuration;
362
363    let local_var_client = &local_var_configuration.client;
364
365    let local_var_uri_str = format!("{}/workers/queue_status", local_var_configuration.base_path);
366    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
367
368    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
369        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
370    }
371    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
372        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
373    };
374
375    let local_var_req = local_var_req_builder.build()?;
376    let local_var_resp = local_var_client.execute(local_var_req).await?;
377
378    let local_var_status = local_var_resp.status();
379    let local_var_content = local_var_resp.text().await?;
380
381    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
382        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
383    } else {
384        let local_var_entity: Option<GetQueueStatusError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
385        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
386        Err(Error::ResponseError(local_var_error))
387    }
388}
389
390pub async fn get_runnable_stats(configuration: &configuration::Configuration, window_secs: Option<i32>, worker_group: Option<&str>, workspace: Option<&str>, order_by: Option<&str>, limit: Option<i32>) -> Result<Vec<models::RunnableStats>, Error<GetRunnableStatsError>> {
391    let local_var_configuration = configuration;
392
393    let local_var_client = &local_var_configuration.client;
394
395    let local_var_uri_str = format!("{}/workers/runnable_stats", local_var_configuration.base_path);
396    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
397
398    if let Some(ref local_var_str) = window_secs {
399        local_var_req_builder = local_var_req_builder.query(&[("window_secs", &local_var_str.to_string())]);
400    }
401    if let Some(ref local_var_str) = worker_group {
402        local_var_req_builder = local_var_req_builder.query(&[("worker_group", &local_var_str.to_string())]);
403    }
404    if let Some(ref local_var_str) = workspace {
405        local_var_req_builder = local_var_req_builder.query(&[("workspace", &local_var_str.to_string())]);
406    }
407    if let Some(ref local_var_str) = order_by {
408        local_var_req_builder = local_var_req_builder.query(&[("order_by", &local_var_str.to_string())]);
409    }
410    if let Some(ref local_var_str) = limit {
411        local_var_req_builder = local_var_req_builder.query(&[("limit", &local_var_str.to_string())]);
412    }
413    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
414        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
415    }
416    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
417        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
418    };
419
420    let local_var_req = local_var_req_builder.build()?;
421    let local_var_resp = local_var_client.execute(local_var_req).await?;
422
423    let local_var_status = local_var_resp.status();
424    let local_var_content = local_var_resp.text().await?;
425
426    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
427        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
428    } else {
429        let local_var_entity: Option<GetRunnableStatsError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
430        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
431        Err(Error::ResponseError(local_var_error))
432    }
433}
434
435pub async fn get_workspace_fairness_events(configuration: &configuration::Configuration, ) -> Result<Vec<models::GetWorkspaceFairnessEvents200ResponseInner>, Error<GetWorkspaceFairnessEventsError>> {
436    let local_var_configuration = configuration;
437
438    let local_var_client = &local_var_configuration.client;
439
440    let local_var_uri_str = format!("{}/workers/workspace_fairness_events", local_var_configuration.base_path);
441    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
442
443    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
444        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
445    }
446    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
447        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
448    };
449
450    let local_var_req = local_var_req_builder.build()?;
451    let local_var_resp = local_var_client.execute(local_var_req).await?;
452
453    let local_var_status = local_var_resp.status();
454    let local_var_content = local_var_resp.text().await?;
455
456    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
457        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
458    } else {
459        let local_var_entity: Option<GetWorkspaceFairnessEventsError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
460        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
461        Err(Error::ResponseError(local_var_error))
462    }
463}
464
465pub async fn is_default_tags_per_workspace(configuration: &configuration::Configuration, ) -> Result<bool, Error<IsDefaultTagsPerWorkspaceError>> {
466    let local_var_configuration = configuration;
467
468    let local_var_client = &local_var_configuration.client;
469
470    let local_var_uri_str = format!("{}/workers/is_default_tags_per_workspace", local_var_configuration.base_path);
471    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
472
473    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
474        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
475    }
476    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
477        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
478    };
479
480    let local_var_req = local_var_req_builder.build()?;
481    let local_var_resp = local_var_client.execute(local_var_req).await?;
482
483    let local_var_status = local_var_resp.status();
484    let local_var_content = local_var_resp.text().await?;
485
486    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
487        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
488    } else {
489        let local_var_entity: Option<IsDefaultTagsPerWorkspaceError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
490        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
491        Err(Error::ResponseError(local_var_error))
492    }
493}
494
495pub async fn list_workers(configuration: &configuration::Configuration, page: Option<i32>, per_page: Option<i32>, ping_since: Option<i32>) -> Result<Vec<models::WorkerPing>, Error<ListWorkersError>> {
496    let local_var_configuration = configuration;
497
498    let local_var_client = &local_var_configuration.client;
499
500    let local_var_uri_str = format!("{}/workers/list", local_var_configuration.base_path);
501    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
502
503    if let Some(ref local_var_str) = page {
504        local_var_req_builder = local_var_req_builder.query(&[("page", &local_var_str.to_string())]);
505    }
506    if let Some(ref local_var_str) = per_page {
507        local_var_req_builder = local_var_req_builder.query(&[("per_page", &local_var_str.to_string())]);
508    }
509    if let Some(ref local_var_str) = ping_since {
510        local_var_req_builder = local_var_req_builder.query(&[("ping_since", &local_var_str.to_string())]);
511    }
512    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
513        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
514    }
515    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
516        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
517    };
518
519    let local_var_req = local_var_req_builder.build()?;
520    let local_var_resp = local_var_client.execute(local_var_req).await?;
521
522    let local_var_status = local_var_resp.status();
523    let local_var_content = local_var_resp.text().await?;
524
525    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
526        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
527    } else {
528        let local_var_entity: Option<ListWorkersError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
529        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
530        Err(Error::ResponseError(local_var_error))
531    }
532}
533