nomad_client/apis/
client_api.rs

1/*
2 * Nomad
3 *
4 * Nomad OpenApi specification
5 *
6 * The version of the OpenAPI document: 0.11.0
7 * 
8 * Generated by: https://openapi-generator.tech
9 */
10
11
12use reqwest;
13
14use crate::apis::ResponseContent;
15use super::{Error, configuration};
16
17
18/// struct for typed errors of method `garbage_collect_allocation`
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum GarbageCollectAllocationError {
22    UnknownValue(serde_json::Value),
23}
24
25/// struct for typed errors of method `garbage_collect_allocation_0`
26#[derive(Debug, Clone, Serialize, Deserialize)]
27#[serde(untagged)]
28pub enum GarbageCollectAllocation0Error {
29    UnknownValue(serde_json::Value),
30}
31
32/// struct for typed errors of method `get_client_allocation_stats`
33#[derive(Debug, Clone, Serialize, Deserialize)]
34#[serde(untagged)]
35pub enum GetClientAllocationStatsError {
36    UnknownValue(serde_json::Value),
37}
38
39/// struct for typed errors of method `get_client_file`
40#[derive(Debug, Clone, Serialize, Deserialize)]
41#[serde(untagged)]
42pub enum GetClientFileError {
43    UnknownValue(serde_json::Value),
44}
45
46/// struct for typed errors of method `get_client_file_at_offest`
47#[derive(Debug, Clone, Serialize, Deserialize)]
48#[serde(untagged)]
49pub enum GetClientFileAtOffestError {
50    UnknownValue(serde_json::Value),
51}
52
53/// struct for typed errors of method `get_client_stats`
54#[derive(Debug, Clone, Serialize, Deserialize)]
55#[serde(untagged)]
56pub enum GetClientStatsError {
57    UnknownValue(serde_json::Value),
58}
59
60/// struct for typed errors of method `list_client_files`
61#[derive(Debug, Clone, Serialize, Deserialize)]
62#[serde(untagged)]
63pub enum ListClientFilesError {
64    UnknownValue(serde_json::Value),
65}
66
67/// struct for typed errors of method `stat_client_file`
68#[derive(Debug, Clone, Serialize, Deserialize)]
69#[serde(untagged)]
70pub enum StatClientFileError {
71    UnknownValue(serde_json::Value),
72}
73
74/// struct for typed errors of method `stream_client_file`
75#[derive(Debug, Clone, Serialize, Deserialize)]
76#[serde(untagged)]
77pub enum StreamClientFileError {
78    UnknownValue(serde_json::Value),
79}
80
81/// struct for typed errors of method `stream_client_logs`
82#[derive(Debug, Clone, Serialize, Deserialize)]
83#[serde(untagged)]
84pub enum StreamClientLogsError {
85    UnknownValue(serde_json::Value),
86}
87
88
89pub async fn garbage_collect_allocation(configuration: &configuration::Configuration, alloc_id: &str, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>) -> Result<(), Error<GarbageCollectAllocationError>> {
90
91    let local_var_client = &configuration.client;
92
93    let local_var_uri_str = format!("{}/client/allocation/{alloc_id}/gc", configuration.base_path, alloc_id=crate::apis::urlencode(alloc_id));
94    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
95
96    if let Some(ref local_var_str) = namespace {
97        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
98    }
99    if let Some(ref local_var_str) = region {
100        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
101    }
102    if let Some(ref local_var_str) = index {
103        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
104    }
105    if let Some(ref local_var_str) = wait {
106        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
107    }
108    if let Some(ref local_var_user_agent) = configuration.user_agent {
109        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
110    }
111
112    let local_var_req = local_var_req_builder.build()?;
113    let local_var_resp = local_var_client.execute(local_var_req).await?;
114
115    let local_var_status = local_var_resp.status();
116    let local_var_content = local_var_resp.text().await?;
117
118    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
119        Ok(())
120    } else {
121        let local_var_entity: Option<GarbageCollectAllocationError> = serde_json::from_str(&local_var_content).ok();
122        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
123        Err(Error::ResponseError(local_var_error))
124    }
125}
126
127pub async fn garbage_collect_allocation_0(configuration: &configuration::Configuration, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>, node_id: Option<&str>) -> Result<(), Error<GarbageCollectAllocation0Error>> {
128
129    let local_var_client = &configuration.client;
130
131    let local_var_uri_str = format!("{}/client/gc", configuration.base_path);
132    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
133
134    if let Some(ref local_var_str) = namespace {
135        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
136    }
137    if let Some(ref local_var_str) = region {
138        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
139    }
140    if let Some(ref local_var_str) = index {
141        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
142    }
143    if let Some(ref local_var_str) = wait {
144        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
145    }
146    if let Some(ref local_var_str) = node_id {
147        local_var_req_builder = local_var_req_builder.query(&[("node_id", &local_var_str.to_string())]);
148    }
149    if let Some(ref local_var_user_agent) = configuration.user_agent {
150        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
151    }
152
153    let local_var_req = local_var_req_builder.build()?;
154    let local_var_resp = local_var_client.execute(local_var_req).await?;
155
156    let local_var_status = local_var_resp.status();
157    let local_var_content = local_var_resp.text().await?;
158
159    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
160        Ok(())
161    } else {
162        let local_var_entity: Option<GarbageCollectAllocation0Error> = serde_json::from_str(&local_var_content).ok();
163        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
164        Err(Error::ResponseError(local_var_error))
165    }
166}
167
168pub async fn get_client_allocation_stats(configuration: &configuration::Configuration, alloc_id: &str, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>) -> Result<crate::models::AllocResourceUsage, Error<GetClientAllocationStatsError>> {
169
170    let local_var_client = &configuration.client;
171
172    let local_var_uri_str = format!("{}/client/allocation/{alloc_id}/stats", configuration.base_path, alloc_id=crate::apis::urlencode(alloc_id));
173    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
174
175    if let Some(ref local_var_str) = namespace {
176        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
177    }
178    if let Some(ref local_var_str) = region {
179        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
180    }
181    if let Some(ref local_var_str) = index {
182        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
183    }
184    if let Some(ref local_var_str) = wait {
185        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
186    }
187    if let Some(ref local_var_user_agent) = configuration.user_agent {
188        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
189    }
190
191    let local_var_req = local_var_req_builder.build()?;
192    let local_var_resp = local_var_client.execute(local_var_req).await?;
193
194    let local_var_status = local_var_resp.status();
195    let local_var_content = local_var_resp.text().await?;
196
197    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
198        serde_json::from_str(&local_var_content).map_err(Error::from)
199    } else {
200        let local_var_entity: Option<GetClientAllocationStatsError> = serde_json::from_str(&local_var_content).ok();
201        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
202        Err(Error::ResponseError(local_var_error))
203    }
204}
205
206pub async fn get_client_file(configuration: &configuration::Configuration, alloc_id: &str, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>, path: Option<&str>) -> Result<String, Error<GetClientFileError>> {
207
208    let local_var_client = &configuration.client;
209
210    let local_var_uri_str = format!("{}/client/fs/cat/{alloc_id}", configuration.base_path, alloc_id=crate::apis::urlencode(alloc_id));
211    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
212
213    if let Some(ref local_var_str) = namespace {
214        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
215    }
216    if let Some(ref local_var_str) = region {
217        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
218    }
219    if let Some(ref local_var_str) = index {
220        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
221    }
222    if let Some(ref local_var_str) = wait {
223        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
224    }
225    if let Some(ref local_var_str) = path {
226        local_var_req_builder = local_var_req_builder.query(&[("path", &local_var_str.to_string())]);
227    }
228    if let Some(ref local_var_user_agent) = configuration.user_agent {
229        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
230    }
231
232    let local_var_req = local_var_req_builder.build()?;
233    let local_var_resp = local_var_client.execute(local_var_req).await?;
234
235    let local_var_status = local_var_resp.status();
236    let local_var_content = local_var_resp.text().await?;
237
238    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
239        serde_json::from_str(&local_var_content).map_err(Error::from)
240    } else {
241        let local_var_entity: Option<GetClientFileError> = serde_json::from_str(&local_var_content).ok();
242        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
243        Err(Error::ResponseError(local_var_error))
244    }
245}
246
247pub async fn get_client_file_at_offest(configuration: &configuration::Configuration, alloc_id: &str, offset: i64, limit: i64, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>, path: Option<&str>) -> Result<String, Error<GetClientFileAtOffestError>> {
248
249    let local_var_client = &configuration.client;
250
251    let local_var_uri_str = format!("{}/client/fs/readat/{alloc_id}", configuration.base_path, alloc_id=crate::apis::urlencode(alloc_id));
252    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
253
254    if let Some(ref local_var_str) = namespace {
255        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
256    }
257    if let Some(ref local_var_str) = region {
258        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
259    }
260    if let Some(ref local_var_str) = index {
261        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
262    }
263    if let Some(ref local_var_str) = wait {
264        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
265    }
266    if let Some(ref local_var_str) = path {
267        local_var_req_builder = local_var_req_builder.query(&[("path", &local_var_str.to_string())]);
268    }
269    local_var_req_builder = local_var_req_builder.query(&[("offset", &offset.to_string())]);
270    local_var_req_builder = local_var_req_builder.query(&[("limit", &limit.to_string())]);
271    if let Some(ref local_var_user_agent) = configuration.user_agent {
272        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
273    }
274
275    let local_var_req = local_var_req_builder.build()?;
276    let local_var_resp = local_var_client.execute(local_var_req).await?;
277
278    let local_var_status = local_var_resp.status();
279    let local_var_content = local_var_resp.text().await?;
280
281    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
282        serde_json::from_str(&local_var_content).map_err(Error::from)
283    } else {
284        let local_var_entity: Option<GetClientFileAtOffestError> = serde_json::from_str(&local_var_content).ok();
285        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
286        Err(Error::ResponseError(local_var_error))
287    }
288}
289
290pub async fn get_client_stats(configuration: &configuration::Configuration, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>, node_id: Option<&str>) -> Result<Vec<crate::models::HostStats>, Error<GetClientStatsError>> {
291
292    let local_var_client = &configuration.client;
293
294    let local_var_uri_str = format!("{}/client/stats", configuration.base_path);
295    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
296
297    if let Some(ref local_var_str) = namespace {
298        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
299    }
300    if let Some(ref local_var_str) = region {
301        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
302    }
303    if let Some(ref local_var_str) = index {
304        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
305    }
306    if let Some(ref local_var_str) = wait {
307        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
308    }
309    if let Some(ref local_var_str) = node_id {
310        local_var_req_builder = local_var_req_builder.query(&[("node_id", &local_var_str.to_string())]);
311    }
312    if let Some(ref local_var_user_agent) = configuration.user_agent {
313        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
314    }
315
316    let local_var_req = local_var_req_builder.build()?;
317    let local_var_resp = local_var_client.execute(local_var_req).await?;
318
319    let local_var_status = local_var_resp.status();
320    let local_var_content = local_var_resp.text().await?;
321
322    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
323        serde_json::from_str(&local_var_content).map_err(Error::from)
324    } else {
325        let local_var_entity: Option<GetClientStatsError> = serde_json::from_str(&local_var_content).ok();
326        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
327        Err(Error::ResponseError(local_var_error))
328    }
329}
330
331pub async fn list_client_files(configuration: &configuration::Configuration, alloc_id: &str, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>, path: Option<&str>) -> Result<Vec<crate::models::AllocFileInfo>, Error<ListClientFilesError>> {
332
333    let local_var_client = &configuration.client;
334
335    let local_var_uri_str = format!("{}/client/fs/ls/{alloc_id}", configuration.base_path, alloc_id=crate::apis::urlencode(alloc_id));
336    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
337
338    if let Some(ref local_var_str) = namespace {
339        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
340    }
341    if let Some(ref local_var_str) = region {
342        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
343    }
344    if let Some(ref local_var_str) = index {
345        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
346    }
347    if let Some(ref local_var_str) = wait {
348        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
349    }
350    if let Some(ref local_var_str) = path {
351        local_var_req_builder = local_var_req_builder.query(&[("path", &local_var_str.to_string())]);
352    }
353    if let Some(ref local_var_user_agent) = configuration.user_agent {
354        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
355    }
356
357    let local_var_req = local_var_req_builder.build()?;
358    let local_var_resp = local_var_client.execute(local_var_req).await?;
359
360    let local_var_status = local_var_resp.status();
361    let local_var_content = local_var_resp.text().await?;
362
363    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
364        serde_json::from_str(&local_var_content).map_err(Error::from)
365    } else {
366        let local_var_entity: Option<ListClientFilesError> = serde_json::from_str(&local_var_content).ok();
367        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
368        Err(Error::ResponseError(local_var_error))
369    }
370}
371
372pub async fn stat_client_file(configuration: &configuration::Configuration, alloc_id: &str, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>, path: Option<&str>) -> Result<crate::models::AllocFileInfo, Error<StatClientFileError>> {
373
374    let local_var_client = &configuration.client;
375
376    let local_var_uri_str = format!("{}/client/fs/stat/{alloc_id}", configuration.base_path, alloc_id=crate::apis::urlencode(alloc_id));
377    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
378
379    if let Some(ref local_var_str) = namespace {
380        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
381    }
382    if let Some(ref local_var_str) = region {
383        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
384    }
385    if let Some(ref local_var_str) = index {
386        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
387    }
388    if let Some(ref local_var_str) = wait {
389        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
390    }
391    if let Some(ref local_var_str) = path {
392        local_var_req_builder = local_var_req_builder.query(&[("path", &local_var_str.to_string())]);
393    }
394    if let Some(ref local_var_user_agent) = configuration.user_agent {
395        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
396    }
397
398    let local_var_req = local_var_req_builder.build()?;
399    let local_var_resp = local_var_client.execute(local_var_req).await?;
400
401    let local_var_status = local_var_resp.status();
402    let local_var_content = local_var_resp.text().await?;
403
404    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
405        serde_json::from_str(&local_var_content).map_err(Error::from)
406    } else {
407        let local_var_entity: Option<StatClientFileError> = serde_json::from_str(&local_var_content).ok();
408        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
409        Err(Error::ResponseError(local_var_error))
410    }
411}
412
413pub async fn stream_client_file(configuration: &configuration::Configuration, alloc_id: &str, offset: i64, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>, path: Option<&str>, follow: Option<bool>, origin: Option<&str>) -> Result<String, Error<StreamClientFileError>> {
414
415    let local_var_client = &configuration.client;
416
417    let local_var_uri_str = format!("{}/client/fs/stream/{alloc_id}", configuration.base_path, alloc_id=crate::apis::urlencode(alloc_id));
418    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
419
420    if let Some(ref local_var_str) = namespace {
421        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
422    }
423    if let Some(ref local_var_str) = region {
424        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
425    }
426    if let Some(ref local_var_str) = index {
427        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
428    }
429    if let Some(ref local_var_str) = wait {
430        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
431    }
432    if let Some(ref local_var_str) = path {
433        local_var_req_builder = local_var_req_builder.query(&[("path", &local_var_str.to_string())]);
434    }
435    if let Some(ref local_var_str) = follow {
436        local_var_req_builder = local_var_req_builder.query(&[("follow", &local_var_str.to_string())]);
437    }
438    local_var_req_builder = local_var_req_builder.query(&[("offset", &offset.to_string())]);
439    if let Some(ref local_var_str) = origin {
440        local_var_req_builder = local_var_req_builder.query(&[("origin", &local_var_str.to_string())]);
441    }
442    if let Some(ref local_var_user_agent) = configuration.user_agent {
443        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
444    }
445
446    let local_var_req = local_var_req_builder.build()?;
447    let local_var_resp = local_var_client.execute(local_var_req).await?;
448
449    let local_var_status = local_var_resp.status();
450    let local_var_content = local_var_resp.text().await?;
451
452    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
453        serde_json::from_str(&local_var_content).map_err(Error::from)
454    } else {
455        let local_var_entity: Option<StreamClientFileError> = serde_json::from_str(&local_var_content).ok();
456        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
457        Err(Error::ResponseError(local_var_error))
458    }
459}
460
461pub async fn stream_client_logs(configuration: &configuration::Configuration, alloc_id: &str, task: &str, offset: i64, namespace: Option<&str>, region: Option<&str>, index: Option<i64>, wait: Option<&str>, follow: Option<bool>, _type: Option<&str>, origin: Option<&str>, plain: Option<bool>) -> Result<String, Error<StreamClientLogsError>> {
462
463    let local_var_client = &configuration.client;
464
465    let local_var_uri_str = format!("{}/client/fs/logs/{alloc_id}", configuration.base_path, alloc_id=crate::apis::urlencode(alloc_id));
466    let mut local_var_req_builder = local_var_client.get(local_var_uri_str.as_str());
467
468    if let Some(ref local_var_str) = namespace {
469        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
470    }
471    if let Some(ref local_var_str) = region {
472        local_var_req_builder = local_var_req_builder.query(&[("region", &local_var_str.to_string())]);
473    }
474    if let Some(ref local_var_str) = index {
475        local_var_req_builder = local_var_req_builder.query(&[("index", &local_var_str.to_string())]);
476    }
477    if let Some(ref local_var_str) = wait {
478        local_var_req_builder = local_var_req_builder.query(&[("wait", &local_var_str.to_string())]);
479    }
480    local_var_req_builder = local_var_req_builder.query(&[("task", &task.to_string())]);
481    if let Some(ref local_var_str) = follow {
482        local_var_req_builder = local_var_req_builder.query(&[("follow", &local_var_str.to_string())]);
483    }
484    if let Some(ref local_var_str) = _type {
485        local_var_req_builder = local_var_req_builder.query(&[("type", &local_var_str.to_string())]);
486    }
487    local_var_req_builder = local_var_req_builder.query(&[("offset", &offset.to_string())]);
488    if let Some(ref local_var_str) = origin {
489        local_var_req_builder = local_var_req_builder.query(&[("origin", &local_var_str.to_string())]);
490    }
491    if let Some(ref local_var_str) = plain {
492        local_var_req_builder = local_var_req_builder.query(&[("plain", &local_var_str.to_string())]);
493    }
494    if let Some(ref local_var_user_agent) = configuration.user_agent {
495        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
496    }
497
498    let local_var_req = local_var_req_builder.build()?;
499    let local_var_resp = local_var_client.execute(local_var_req).await?;
500
501    let local_var_status = local_var_resp.status();
502    let local_var_content = local_var_resp.text().await?;
503
504    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
505        serde_json::from_str(&local_var_content).map_err(Error::from)
506    } else {
507        let local_var_entity: Option<StreamClientLogsError> = serde_json::from_str(&local_var_content).ok();
508        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
509        Err(Error::ResponseError(local_var_error))
510    }
511}
512
nomad_client/apis/client_api.rs

nomad_client/apis/
client_api.rs
