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

windmill_api/apis/
worker_api.rs
