argo_workflows_rs/apis/
workflow_service_api.rs

1/*
2 * Argo Workflows API
3 *
4 * Argo Workflows is an open source container-native workflow engine for orchestrating parallel jobs on Kubernetes. For more information, please see https://argoproj.github.io/argo-workflows/
5 *
6 * The version of the OpenAPI document: VERSION
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 [`workflow_service_create_workflow`]
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum WorkflowServiceCreateWorkflowError {
22    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
23    UnknownValue(serde_json::Value),
24}
25
26/// struct for typed errors of method [`workflow_service_delete_workflow`]
27#[derive(Debug, Clone, Serialize, Deserialize)]
28#[serde(untagged)]
29pub enum WorkflowServiceDeleteWorkflowError {
30    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
31    UnknownValue(serde_json::Value),
32}
33
34/// struct for typed errors of method [`workflow_service_get_workflow`]
35#[derive(Debug, Clone, Serialize, Deserialize)]
36#[serde(untagged)]
37pub enum WorkflowServiceGetWorkflowError {
38    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
39    UnknownValue(serde_json::Value),
40}
41
42/// struct for typed errors of method [`workflow_service_lint_workflow`]
43#[derive(Debug, Clone, Serialize, Deserialize)]
44#[serde(untagged)]
45pub enum WorkflowServiceLintWorkflowError {
46    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
47    UnknownValue(serde_json::Value),
48}
49
50/// struct for typed errors of method [`workflow_service_list_workflows`]
51#[derive(Debug, Clone, Serialize, Deserialize)]
52#[serde(untagged)]
53pub enum WorkflowServiceListWorkflowsError {
54    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
55    UnknownValue(serde_json::Value),
56}
57
58/// struct for typed errors of method [`workflow_service_pod_logs`]
59#[derive(Debug, Clone, Serialize, Deserialize)]
60#[serde(untagged)]
61pub enum WorkflowServicePodLogsError {
62    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
63    UnknownValue(serde_json::Value),
64}
65
66/// struct for typed errors of method [`workflow_service_resubmit_workflow`]
67#[derive(Debug, Clone, Serialize, Deserialize)]
68#[serde(untagged)]
69pub enum WorkflowServiceResubmitWorkflowError {
70    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
71    UnknownValue(serde_json::Value),
72}
73
74/// struct for typed errors of method [`workflow_service_resume_workflow`]
75#[derive(Debug, Clone, Serialize, Deserialize)]
76#[serde(untagged)]
77pub enum WorkflowServiceResumeWorkflowError {
78    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
79    UnknownValue(serde_json::Value),
80}
81
82/// struct for typed errors of method [`workflow_service_retry_workflow`]
83#[derive(Debug, Clone, Serialize, Deserialize)]
84#[serde(untagged)]
85pub enum WorkflowServiceRetryWorkflowError {
86    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
87    UnknownValue(serde_json::Value),
88}
89
90/// struct for typed errors of method [`workflow_service_set_workflow`]
91#[derive(Debug, Clone, Serialize, Deserialize)]
92#[serde(untagged)]
93pub enum WorkflowServiceSetWorkflowError {
94    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
95    UnknownValue(serde_json::Value),
96}
97
98/// struct for typed errors of method [`workflow_service_stop_workflow`]
99#[derive(Debug, Clone, Serialize, Deserialize)]
100#[serde(untagged)]
101pub enum WorkflowServiceStopWorkflowError {
102    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
103    UnknownValue(serde_json::Value),
104}
105
106/// struct for typed errors of method [`workflow_service_submit_workflow`]
107#[derive(Debug, Clone, Serialize, Deserialize)]
108#[serde(untagged)]
109pub enum WorkflowServiceSubmitWorkflowError {
110    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
111    UnknownValue(serde_json::Value),
112}
113
114/// struct for typed errors of method [`workflow_service_suspend_workflow`]
115#[derive(Debug, Clone, Serialize, Deserialize)]
116#[serde(untagged)]
117pub enum WorkflowServiceSuspendWorkflowError {
118    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
119    UnknownValue(serde_json::Value),
120}
121
122/// struct for typed errors of method [`workflow_service_terminate_workflow`]
123#[derive(Debug, Clone, Serialize, Deserialize)]
124#[serde(untagged)]
125pub enum WorkflowServiceTerminateWorkflowError {
126    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
127    UnknownValue(serde_json::Value),
128}
129
130/// struct for typed errors of method [`workflow_service_watch_events`]
131#[derive(Debug, Clone, Serialize, Deserialize)]
132#[serde(untagged)]
133pub enum WorkflowServiceWatchEventsError {
134    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
135    UnknownValue(serde_json::Value),
136}
137
138/// struct for typed errors of method [`workflow_service_watch_workflows`]
139#[derive(Debug, Clone, Serialize, Deserialize)]
140#[serde(untagged)]
141pub enum WorkflowServiceWatchWorkflowsError {
142    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
143    UnknownValue(serde_json::Value),
144}
145
146/// struct for typed errors of method [`workflow_service_workflow_logs`]
147#[derive(Debug, Clone, Serialize, Deserialize)]
148#[serde(untagged)]
149pub enum WorkflowServiceWorkflowLogsError {
150    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
151    UnknownValue(serde_json::Value),
152}
153
154
155pub async fn workflow_service_create_workflow(configuration: &configuration::Configuration, namespace: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowCreateRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceCreateWorkflowError>> {
156    let local_var_configuration = configuration;
157
158    let local_var_client = &local_var_configuration.client;
159
160    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace));
161    let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
162
163    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
164        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
165    }
166    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
167        let local_var_key = local_var_apikey.key.clone();
168        let local_var_value = match local_var_apikey.prefix {
169            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
170            None => local_var_key,
171        };
172        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
173    };
174    local_var_req_builder = local_var_req_builder.json(&body);
175
176    let local_var_req = local_var_req_builder.build()?;
177    let local_var_resp = local_var_client.execute(local_var_req).await?;
178
179    let local_var_status = local_var_resp.status();
180    let local_var_content = local_var_resp.text().await?;
181
182    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
183        serde_json::from_str(&local_var_content).map_err(Error::from)
184    } else {
185        let local_var_entity: Option<WorkflowServiceCreateWorkflowError> = serde_json::from_str(&local_var_content).ok();
186        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
187        Err(Error::ResponseError(local_var_error))
188    }
189}
190
191pub async fn workflow_service_delete_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, delete_options_period_grace_period_seconds: Option<&str>, delete_options_period_preconditions_period_uid: Option<&str>, delete_options_period_preconditions_period_resource_version: Option<&str>, delete_options_period_orphan_dependents: Option<bool>, delete_options_period_propagation_policy: Option<&str>, delete_options_period_dry_run: Option<Vec<String>>, force: Option<bool>) -> Result<serde_json::Value, Error<WorkflowServiceDeleteWorkflowError>> {
192    let local_var_configuration = configuration;
193
194    let local_var_client = &local_var_configuration.client;
195
196    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
197    let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
198
199    if let Some(ref local_var_str) = delete_options_period_grace_period_seconds {
200        local_var_req_builder = local_var_req_builder.query(&[("deleteOptions.gracePeriodSeconds", &local_var_str.to_string())]);
201    }
202    if let Some(ref local_var_str) = delete_options_period_preconditions_period_uid {
203        local_var_req_builder = local_var_req_builder.query(&[("deleteOptions.preconditions.uid", &local_var_str.to_string())]);
204    }
205    if let Some(ref local_var_str) = delete_options_period_preconditions_period_resource_version {
206        local_var_req_builder = local_var_req_builder.query(&[("deleteOptions.preconditions.resourceVersion", &local_var_str.to_string())]);
207    }
208    if let Some(ref local_var_str) = delete_options_period_orphan_dependents {
209        local_var_req_builder = local_var_req_builder.query(&[("deleteOptions.orphanDependents", &local_var_str.to_string())]);
210    }
211    if let Some(ref local_var_str) = delete_options_period_propagation_policy {
212        local_var_req_builder = local_var_req_builder.query(&[("deleteOptions.propagationPolicy", &local_var_str.to_string())]);
213    }
214    if let Some(ref local_var_str) = delete_options_period_dry_run {
215        local_var_req_builder = match "multi" {
216            "multi" => local_var_req_builder.query(&local_var_str.into_iter().map(|p| ("deleteOptions.dryRun".to_owned(), p.to_string())).collect::<Vec<(std::string::String, std::string::String)>>()),
217            _ => local_var_req_builder.query(&[("deleteOptions.dryRun", &local_var_str.into_iter().map(|p| p.to_string()).collect::<Vec<String>>().join(",").to_string())]),
218        };
219    }
220    if let Some(ref local_var_str) = force {
221        local_var_req_builder = local_var_req_builder.query(&[("force", &local_var_str.to_string())]);
222    }
223    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
224        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
225    }
226    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
227        let local_var_key = local_var_apikey.key.clone();
228        let local_var_value = match local_var_apikey.prefix {
229            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
230            None => local_var_key,
231        };
232        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
233    };
234
235    let local_var_req = local_var_req_builder.build()?;
236    let local_var_resp = local_var_client.execute(local_var_req).await?;
237
238    let local_var_status = local_var_resp.status();
239    let local_var_content = local_var_resp.text().await?;
240
241    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
242        serde_json::from_str(&local_var_content).map_err(Error::from)
243    } else {
244        let local_var_entity: Option<WorkflowServiceDeleteWorkflowError> = serde_json::from_str(&local_var_content).ok();
245        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
246        Err(Error::ResponseError(local_var_error))
247    }
248}
249
250pub async fn workflow_service_get_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, get_options_period_resource_version: Option<&str>, fields: Option<&str>) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceGetWorkflowError>> {
251    let local_var_configuration = configuration;
252
253    let local_var_client = &local_var_configuration.client;
254
255    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
256    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
257
258    if let Some(ref local_var_str) = get_options_period_resource_version {
259        local_var_req_builder = local_var_req_builder.query(&[("getOptions.resourceVersion", &local_var_str.to_string())]);
260    }
261    if let Some(ref local_var_str) = fields {
262        local_var_req_builder = local_var_req_builder.query(&[("fields", &local_var_str.to_string())]);
263    }
264    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
265        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
266    }
267    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
268        let local_var_key = local_var_apikey.key.clone();
269        let local_var_value = match local_var_apikey.prefix {
270            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
271            None => local_var_key,
272        };
273        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
274    };
275
276    let local_var_req = local_var_req_builder.build()?;
277    let local_var_resp = local_var_client.execute(local_var_req).await?;
278
279    let local_var_status = local_var_resp.status();
280    let local_var_content = local_var_resp.text().await?;
281
282    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
283        serde_json::from_str(&local_var_content).map_err(Error::from)
284    } else {
285        let local_var_entity: Option<WorkflowServiceGetWorkflowError> = serde_json::from_str(&local_var_content).ok();
286        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
287        Err(Error::ResponseError(local_var_error))
288    }
289}
290
291pub async fn workflow_service_lint_workflow(configuration: &configuration::Configuration, namespace: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowLintRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceLintWorkflowError>> {
292    let local_var_configuration = configuration;
293
294    let local_var_client = &local_var_configuration.client;
295
296    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/lint", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace));
297    let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
298
299    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
300        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
301    }
302    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
303        let local_var_key = local_var_apikey.key.clone();
304        let local_var_value = match local_var_apikey.prefix {
305            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
306            None => local_var_key,
307        };
308        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
309    };
310    local_var_req_builder = local_var_req_builder.json(&body);
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        serde_json::from_str(&local_var_content).map_err(Error::from)
320    } else {
321        let local_var_entity: Option<WorkflowServiceLintWorkflowError> = serde_json::from_str(&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 workflow_service_list_workflows(configuration: &configuration::Configuration, namespace: &str, list_options_period_label_selector: Option<&str>, list_options_period_field_selector: Option<&str>, list_options_period_watch: Option<bool>, list_options_period_allow_watch_bookmarks: Option<bool>, list_options_period_resource_version: Option<&str>, list_options_period_resource_version_match: Option<&str>, list_options_period_timeout_seconds: Option<&str>, list_options_period_limit: Option<&str>, list_options_period_continue: Option<&str>, fields: Option<&str>) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowList, Error<WorkflowServiceListWorkflowsError>> {
328    let local_var_configuration = configuration;
329
330    let local_var_client = &local_var_configuration.client;
331
332    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace));
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) = list_options_period_label_selector {
336        local_var_req_builder = local_var_req_builder.query(&[("listOptions.labelSelector", &local_var_str.to_string())]);
337    }
338    if let Some(ref local_var_str) = list_options_period_field_selector {
339        local_var_req_builder = local_var_req_builder.query(&[("listOptions.fieldSelector", &local_var_str.to_string())]);
340    }
341    if let Some(ref local_var_str) = list_options_period_watch {
342        local_var_req_builder = local_var_req_builder.query(&[("listOptions.watch", &local_var_str.to_string())]);
343    }
344    if let Some(ref local_var_str) = list_options_period_allow_watch_bookmarks {
345        local_var_req_builder = local_var_req_builder.query(&[("listOptions.allowWatchBookmarks", &local_var_str.to_string())]);
346    }
347    if let Some(ref local_var_str) = list_options_period_resource_version {
348        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersion", &local_var_str.to_string())]);
349    }
350    if let Some(ref local_var_str) = list_options_period_resource_version_match {
351        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersionMatch", &local_var_str.to_string())]);
352    }
353    if let Some(ref local_var_str) = list_options_period_timeout_seconds {
354        local_var_req_builder = local_var_req_builder.query(&[("listOptions.timeoutSeconds", &local_var_str.to_string())]);
355    }
356    if let Some(ref local_var_str) = list_options_period_limit {
357        local_var_req_builder = local_var_req_builder.query(&[("listOptions.limit", &local_var_str.to_string())]);
358    }
359    if let Some(ref local_var_str) = list_options_period_continue {
360        local_var_req_builder = local_var_req_builder.query(&[("listOptions.continue", &local_var_str.to_string())]);
361    }
362    if let Some(ref local_var_str) = fields {
363        local_var_req_builder = local_var_req_builder.query(&[("fields", &local_var_str.to_string())]);
364    }
365    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
366        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
367    }
368    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
369        let local_var_key = local_var_apikey.key.clone();
370        let local_var_value = match local_var_apikey.prefix {
371            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
372            None => local_var_key,
373        };
374        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
375    };
376
377    let local_var_req = local_var_req_builder.build()?;
378    let local_var_resp = local_var_client.execute(local_var_req).await?;
379
380    let local_var_status = local_var_resp.status();
381    let local_var_content = local_var_resp.text().await?;
382
383    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
384        serde_json::from_str(&local_var_content).map_err(Error::from)
385    } else {
386        let local_var_entity: Option<WorkflowServiceListWorkflowsError> = serde_json::from_str(&local_var_content).ok();
387        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
388        Err(Error::ResponseError(local_var_error))
389    }
390}
391
392pub async fn workflow_service_pod_logs(configuration: &configuration::Configuration, namespace: &str, name: &str, pod_name: &str, log_options_period_container: Option<&str>, log_options_period_follow: Option<bool>, log_options_period_previous: Option<bool>, log_options_period_since_seconds: Option<&str>, log_options_period_since_time_period_seconds: Option<&str>, log_options_period_since_time_period_nanos: Option<i32>, log_options_period_timestamps: Option<bool>, log_options_period_tail_lines: Option<&str>, log_options_period_limit_bytes: Option<&str>, log_options_period_insecure_skip_tls_verify_backend: Option<bool>, grep: Option<&str>, selector: Option<&str>) -> Result<crate::models::StreamResultOfIoArgoprojWorkflowV1alpha1LogEntry, Error<WorkflowServicePodLogsError>> {
393    let local_var_configuration = configuration;
394
395    let local_var_client = &local_var_configuration.client;
396
397    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/{podName}/log", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name), podName=crate::apis::urlencode(pod_name));
398    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
399
400    if let Some(ref local_var_str) = log_options_period_container {
401        local_var_req_builder = local_var_req_builder.query(&[("logOptions.container", &local_var_str.to_string())]);
402    }
403    if let Some(ref local_var_str) = log_options_period_follow {
404        local_var_req_builder = local_var_req_builder.query(&[("logOptions.follow", &local_var_str.to_string())]);
405    }
406    if let Some(ref local_var_str) = log_options_period_previous {
407        local_var_req_builder = local_var_req_builder.query(&[("logOptions.previous", &local_var_str.to_string())]);
408    }
409    if let Some(ref local_var_str) = log_options_period_since_seconds {
410        local_var_req_builder = local_var_req_builder.query(&[("logOptions.sinceSeconds", &local_var_str.to_string())]);
411    }
412    if let Some(ref local_var_str) = log_options_period_since_time_period_seconds {
413        local_var_req_builder = local_var_req_builder.query(&[("logOptions.sinceTime.seconds", &local_var_str.to_string())]);
414    }
415    if let Some(ref local_var_str) = log_options_period_since_time_period_nanos {
416        local_var_req_builder = local_var_req_builder.query(&[("logOptions.sinceTime.nanos", &local_var_str.to_string())]);
417    }
418    if let Some(ref local_var_str) = log_options_period_timestamps {
419        local_var_req_builder = local_var_req_builder.query(&[("logOptions.timestamps", &local_var_str.to_string())]);
420    }
421    if let Some(ref local_var_str) = log_options_period_tail_lines {
422        local_var_req_builder = local_var_req_builder.query(&[("logOptions.tailLines", &local_var_str.to_string())]);
423    }
424    if let Some(ref local_var_str) = log_options_period_limit_bytes {
425        local_var_req_builder = local_var_req_builder.query(&[("logOptions.limitBytes", &local_var_str.to_string())]);
426    }
427    if let Some(ref local_var_str) = log_options_period_insecure_skip_tls_verify_backend {
428        local_var_req_builder = local_var_req_builder.query(&[("logOptions.insecureSkipTLSVerifyBackend", &local_var_str.to_string())]);
429    }
430    if let Some(ref local_var_str) = grep {
431        local_var_req_builder = local_var_req_builder.query(&[("grep", &local_var_str.to_string())]);
432    }
433    if let Some(ref local_var_str) = selector {
434        local_var_req_builder = local_var_req_builder.query(&[("selector", &local_var_str.to_string())]);
435    }
436    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
437        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
438    }
439    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
440        let local_var_key = local_var_apikey.key.clone();
441        let local_var_value = match local_var_apikey.prefix {
442            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
443            None => local_var_key,
444        };
445        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
446    };
447
448    let local_var_req = local_var_req_builder.build()?;
449    let local_var_resp = local_var_client.execute(local_var_req).await?;
450
451    let local_var_status = local_var_resp.status();
452    let local_var_content = local_var_resp.text().await?;
453
454    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
455        serde_json::from_str(&local_var_content).map_err(Error::from)
456    } else {
457        let local_var_entity: Option<WorkflowServicePodLogsError> = serde_json::from_str(&local_var_content).ok();
458        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
459        Err(Error::ResponseError(local_var_error))
460    }
461}
462
463pub async fn workflow_service_resubmit_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowResubmitRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceResubmitWorkflowError>> {
464    let local_var_configuration = configuration;
465
466    let local_var_client = &local_var_configuration.client;
467
468    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/resubmit", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
469    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
470
471    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
472        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
473    }
474    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
475        let local_var_key = local_var_apikey.key.clone();
476        let local_var_value = match local_var_apikey.prefix {
477            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
478            None => local_var_key,
479        };
480        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
481    };
482    local_var_req_builder = local_var_req_builder.json(&body);
483
484    let local_var_req = local_var_req_builder.build()?;
485    let local_var_resp = local_var_client.execute(local_var_req).await?;
486
487    let local_var_status = local_var_resp.status();
488    let local_var_content = local_var_resp.text().await?;
489
490    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
491        serde_json::from_str(&local_var_content).map_err(Error::from)
492    } else {
493        let local_var_entity: Option<WorkflowServiceResubmitWorkflowError> = serde_json::from_str(&local_var_content).ok();
494        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
495        Err(Error::ResponseError(local_var_error))
496    }
497}
498
499pub async fn workflow_service_resume_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowResumeRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceResumeWorkflowError>> {
500    let local_var_configuration = configuration;
501
502    let local_var_client = &local_var_configuration.client;
503
504    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/resume", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
505    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
506
507    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
508        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
509    }
510    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
511        let local_var_key = local_var_apikey.key.clone();
512        let local_var_value = match local_var_apikey.prefix {
513            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
514            None => local_var_key,
515        };
516        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
517    };
518    local_var_req_builder = local_var_req_builder.json(&body);
519
520    let local_var_req = local_var_req_builder.build()?;
521    let local_var_resp = local_var_client.execute(local_var_req).await?;
522
523    let local_var_status = local_var_resp.status();
524    let local_var_content = local_var_resp.text().await?;
525
526    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
527        serde_json::from_str(&local_var_content).map_err(Error::from)
528    } else {
529        let local_var_entity: Option<WorkflowServiceResumeWorkflowError> = serde_json::from_str(&local_var_content).ok();
530        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
531        Err(Error::ResponseError(local_var_error))
532    }
533}
534
535pub async fn workflow_service_retry_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowRetryRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceRetryWorkflowError>> {
536    let local_var_configuration = configuration;
537
538    let local_var_client = &local_var_configuration.client;
539
540    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/retry", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
541    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
542
543    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
544        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
545    }
546    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
547        let local_var_key = local_var_apikey.key.clone();
548        let local_var_value = match local_var_apikey.prefix {
549            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
550            None => local_var_key,
551        };
552        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
553    };
554    local_var_req_builder = local_var_req_builder.json(&body);
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        serde_json::from_str(&local_var_content).map_err(Error::from)
564    } else {
565        let local_var_entity: Option<WorkflowServiceRetryWorkflowError> = serde_json::from_str(&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
571pub async fn workflow_service_set_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowSetRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceSetWorkflowError>> {
572    let local_var_configuration = configuration;
573
574    let local_var_client = &local_var_configuration.client;
575
576    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/set", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
577    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
578
579    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
580        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
581    }
582    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
583        let local_var_key = local_var_apikey.key.clone();
584        let local_var_value = match local_var_apikey.prefix {
585            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
586            None => local_var_key,
587        };
588        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
589    };
590    local_var_req_builder = local_var_req_builder.json(&body);
591
592    let local_var_req = local_var_req_builder.build()?;
593    let local_var_resp = local_var_client.execute(local_var_req).await?;
594
595    let local_var_status = local_var_resp.status();
596    let local_var_content = local_var_resp.text().await?;
597
598    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
599        serde_json::from_str(&local_var_content).map_err(Error::from)
600    } else {
601        let local_var_entity: Option<WorkflowServiceSetWorkflowError> = serde_json::from_str(&local_var_content).ok();
602        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
603        Err(Error::ResponseError(local_var_error))
604    }
605}
606
607pub async fn workflow_service_stop_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowStopRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceStopWorkflowError>> {
608    let local_var_configuration = configuration;
609
610    let local_var_client = &local_var_configuration.client;
611
612    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/stop", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
613    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
614
615    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
616        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
617    }
618    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
619        let local_var_key = local_var_apikey.key.clone();
620        let local_var_value = match local_var_apikey.prefix {
621            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
622            None => local_var_key,
623        };
624        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
625    };
626    local_var_req_builder = local_var_req_builder.json(&body);
627
628    let local_var_req = local_var_req_builder.build()?;
629    let local_var_resp = local_var_client.execute(local_var_req).await?;
630
631    let local_var_status = local_var_resp.status();
632    let local_var_content = local_var_resp.text().await?;
633
634    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
635        serde_json::from_str(&local_var_content).map_err(Error::from)
636    } else {
637        let local_var_entity: Option<WorkflowServiceStopWorkflowError> = serde_json::from_str(&local_var_content).ok();
638        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
639        Err(Error::ResponseError(local_var_error))
640    }
641}
642
643pub async fn workflow_service_submit_workflow(configuration: &configuration::Configuration, namespace: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowSubmitRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceSubmitWorkflowError>> {
644    let local_var_configuration = configuration;
645
646    let local_var_client = &local_var_configuration.client;
647
648    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/submit", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace));
649    let mut local_var_req_builder = local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
650
651    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
652        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
653    }
654    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
655        let local_var_key = local_var_apikey.key.clone();
656        let local_var_value = match local_var_apikey.prefix {
657            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
658            None => local_var_key,
659        };
660        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
661    };
662    local_var_req_builder = local_var_req_builder.json(&body);
663
664    let local_var_req = local_var_req_builder.build()?;
665    let local_var_resp = local_var_client.execute(local_var_req).await?;
666
667    let local_var_status = local_var_resp.status();
668    let local_var_content = local_var_resp.text().await?;
669
670    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
671        serde_json::from_str(&local_var_content).map_err(Error::from)
672    } else {
673        let local_var_entity: Option<WorkflowServiceSubmitWorkflowError> = serde_json::from_str(&local_var_content).ok();
674        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
675        Err(Error::ResponseError(local_var_error))
676    }
677}
678
679pub async fn workflow_service_suspend_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowSuspendRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceSuspendWorkflowError>> {
680    let local_var_configuration = configuration;
681
682    let local_var_client = &local_var_configuration.client;
683
684    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/suspend", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
685    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
686
687    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
688        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
689    }
690    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
691        let local_var_key = local_var_apikey.key.clone();
692        let local_var_value = match local_var_apikey.prefix {
693            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
694            None => local_var_key,
695        };
696        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
697    };
698    local_var_req_builder = local_var_req_builder.json(&body);
699
700    let local_var_req = local_var_req_builder.build()?;
701    let local_var_resp = local_var_client.execute(local_var_req).await?;
702
703    let local_var_status = local_var_resp.status();
704    let local_var_content = local_var_resp.text().await?;
705
706    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
707        serde_json::from_str(&local_var_content).map_err(Error::from)
708    } else {
709        let local_var_entity: Option<WorkflowServiceSuspendWorkflowError> = serde_json::from_str(&local_var_content).ok();
710        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
711        Err(Error::ResponseError(local_var_error))
712    }
713}
714
715pub async fn workflow_service_terminate_workflow(configuration: &configuration::Configuration, namespace: &str, name: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowTerminateRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<WorkflowServiceTerminateWorkflowError>> {
716    let local_var_configuration = configuration;
717
718    let local_var_client = &local_var_configuration.client;
719
720    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/terminate", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
721    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
722
723    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
724        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
725    }
726    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
727        let local_var_key = local_var_apikey.key.clone();
728        let local_var_value = match local_var_apikey.prefix {
729            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
730            None => local_var_key,
731        };
732        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
733    };
734    local_var_req_builder = local_var_req_builder.json(&body);
735
736    let local_var_req = local_var_req_builder.build()?;
737    let local_var_resp = local_var_client.execute(local_var_req).await?;
738
739    let local_var_status = local_var_resp.status();
740    let local_var_content = local_var_resp.text().await?;
741
742    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
743        serde_json::from_str(&local_var_content).map_err(Error::from)
744    } else {
745        let local_var_entity: Option<WorkflowServiceTerminateWorkflowError> = serde_json::from_str(&local_var_content).ok();
746        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
747        Err(Error::ResponseError(local_var_error))
748    }
749}
750
751pub async fn workflow_service_watch_events(configuration: &configuration::Configuration, namespace: &str, list_options_period_label_selector: Option<&str>, list_options_period_field_selector: Option<&str>, list_options_period_watch: Option<bool>, list_options_period_allow_watch_bookmarks: Option<bool>, list_options_period_resource_version: Option<&str>, list_options_period_resource_version_match: Option<&str>, list_options_period_timeout_seconds: Option<&str>, list_options_period_limit: Option<&str>, list_options_period_continue: Option<&str>) -> Result<crate::models::StreamResultOfIoK8sApiCoreV1Event, Error<WorkflowServiceWatchEventsError>> {
752    let local_var_configuration = configuration;
753
754    let local_var_client = &local_var_configuration.client;
755
756    let local_var_uri_str = format!("{}/api/v1/stream/events/{namespace}", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace));
757    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
758
759    if let Some(ref local_var_str) = list_options_period_label_selector {
760        local_var_req_builder = local_var_req_builder.query(&[("listOptions.labelSelector", &local_var_str.to_string())]);
761    }
762    if let Some(ref local_var_str) = list_options_period_field_selector {
763        local_var_req_builder = local_var_req_builder.query(&[("listOptions.fieldSelector", &local_var_str.to_string())]);
764    }
765    if let Some(ref local_var_str) = list_options_period_watch {
766        local_var_req_builder = local_var_req_builder.query(&[("listOptions.watch", &local_var_str.to_string())]);
767    }
768    if let Some(ref local_var_str) = list_options_period_allow_watch_bookmarks {
769        local_var_req_builder = local_var_req_builder.query(&[("listOptions.allowWatchBookmarks", &local_var_str.to_string())]);
770    }
771    if let Some(ref local_var_str) = list_options_period_resource_version {
772        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersion", &local_var_str.to_string())]);
773    }
774    if let Some(ref local_var_str) = list_options_period_resource_version_match {
775        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersionMatch", &local_var_str.to_string())]);
776    }
777    if let Some(ref local_var_str) = list_options_period_timeout_seconds {
778        local_var_req_builder = local_var_req_builder.query(&[("listOptions.timeoutSeconds", &local_var_str.to_string())]);
779    }
780    if let Some(ref local_var_str) = list_options_period_limit {
781        local_var_req_builder = local_var_req_builder.query(&[("listOptions.limit", &local_var_str.to_string())]);
782    }
783    if let Some(ref local_var_str) = list_options_period_continue {
784        local_var_req_builder = local_var_req_builder.query(&[("listOptions.continue", &local_var_str.to_string())]);
785    }
786    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
787        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
788    }
789    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
790        let local_var_key = local_var_apikey.key.clone();
791        let local_var_value = match local_var_apikey.prefix {
792            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
793            None => local_var_key,
794        };
795        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
796    };
797
798    let local_var_req = local_var_req_builder.build()?;
799    let local_var_resp = local_var_client.execute(local_var_req).await?;
800
801    let local_var_status = local_var_resp.status();
802    let local_var_content = local_var_resp.text().await?;
803
804    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
805        serde_json::from_str(&local_var_content).map_err(Error::from)
806    } else {
807        let local_var_entity: Option<WorkflowServiceWatchEventsError> = serde_json::from_str(&local_var_content).ok();
808        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
809        Err(Error::ResponseError(local_var_error))
810    }
811}
812
813pub async fn workflow_service_watch_workflows(configuration: &configuration::Configuration, namespace: &str, list_options_period_label_selector: Option<&str>, list_options_period_field_selector: Option<&str>, list_options_period_watch: Option<bool>, list_options_period_allow_watch_bookmarks: Option<bool>, list_options_period_resource_version: Option<&str>, list_options_period_resource_version_match: Option<&str>, list_options_period_timeout_seconds: Option<&str>, list_options_period_limit: Option<&str>, list_options_period_continue: Option<&str>, fields: Option<&str>) -> Result<crate::models::StreamResultOfIoArgoprojWorkflowV1alpha1WorkflowWatchEvent, Error<WorkflowServiceWatchWorkflowsError>> {
814    let local_var_configuration = configuration;
815
816    let local_var_client = &local_var_configuration.client;
817
818    let local_var_uri_str = format!("{}/api/v1/workflow-events/{namespace}", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace));
819    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
820
821    if let Some(ref local_var_str) = list_options_period_label_selector {
822        local_var_req_builder = local_var_req_builder.query(&[("listOptions.labelSelector", &local_var_str.to_string())]);
823    }
824    if let Some(ref local_var_str) = list_options_period_field_selector {
825        local_var_req_builder = local_var_req_builder.query(&[("listOptions.fieldSelector", &local_var_str.to_string())]);
826    }
827    if let Some(ref local_var_str) = list_options_period_watch {
828        local_var_req_builder = local_var_req_builder.query(&[("listOptions.watch", &local_var_str.to_string())]);
829    }
830    if let Some(ref local_var_str) = list_options_period_allow_watch_bookmarks {
831        local_var_req_builder = local_var_req_builder.query(&[("listOptions.allowWatchBookmarks", &local_var_str.to_string())]);
832    }
833    if let Some(ref local_var_str) = list_options_period_resource_version {
834        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersion", &local_var_str.to_string())]);
835    }
836    if let Some(ref local_var_str) = list_options_period_resource_version_match {
837        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersionMatch", &local_var_str.to_string())]);
838    }
839    if let Some(ref local_var_str) = list_options_period_timeout_seconds {
840        local_var_req_builder = local_var_req_builder.query(&[("listOptions.timeoutSeconds", &local_var_str.to_string())]);
841    }
842    if let Some(ref local_var_str) = list_options_period_limit {
843        local_var_req_builder = local_var_req_builder.query(&[("listOptions.limit", &local_var_str.to_string())]);
844    }
845    if let Some(ref local_var_str) = list_options_period_continue {
846        local_var_req_builder = local_var_req_builder.query(&[("listOptions.continue", &local_var_str.to_string())]);
847    }
848    if let Some(ref local_var_str) = fields {
849        local_var_req_builder = local_var_req_builder.query(&[("fields", &local_var_str.to_string())]);
850    }
851    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
852        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
853    }
854    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
855        let local_var_key = local_var_apikey.key.clone();
856        let local_var_value = match local_var_apikey.prefix {
857            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
858            None => local_var_key,
859        };
860        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
861    };
862
863    let local_var_req = local_var_req_builder.build()?;
864    let local_var_resp = local_var_client.execute(local_var_req).await?;
865
866    let local_var_status = local_var_resp.status();
867    let local_var_content = local_var_resp.text().await?;
868
869    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
870        serde_json::from_str(&local_var_content).map_err(Error::from)
871    } else {
872        let local_var_entity: Option<WorkflowServiceWatchWorkflowsError> = serde_json::from_str(&local_var_content).ok();
873        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
874        Err(Error::ResponseError(local_var_error))
875    }
876}
877
878pub async fn workflow_service_workflow_logs(configuration: &configuration::Configuration, namespace: &str, name: &str, pod_name: Option<&str>, log_options_period_container: Option<&str>, log_options_period_follow: Option<bool>, log_options_period_previous: Option<bool>, log_options_period_since_seconds: Option<&str>, log_options_period_since_time_period_seconds: Option<&str>, log_options_period_since_time_period_nanos: Option<i32>, log_options_period_timestamps: Option<bool>, log_options_period_tail_lines: Option<&str>, log_options_period_limit_bytes: Option<&str>, log_options_period_insecure_skip_tls_verify_backend: Option<bool>, grep: Option<&str>, selector: Option<&str>) -> Result<crate::models::StreamResultOfIoArgoprojWorkflowV1alpha1LogEntry, Error<WorkflowServiceWorkflowLogsError>> {
879    let local_var_configuration = configuration;
880
881    let local_var_client = &local_var_configuration.client;
882
883    let local_var_uri_str = format!("{}/api/v1/workflows/{namespace}/{name}/log", local_var_configuration.base_path, namespace=crate::apis::urlencode(namespace), name=crate::apis::urlencode(name));
884    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
885
886    if let Some(ref local_var_str) = pod_name {
887        local_var_req_builder = local_var_req_builder.query(&[("podName", &local_var_str.to_string())]);
888    }
889    if let Some(ref local_var_str) = log_options_period_container {
890        local_var_req_builder = local_var_req_builder.query(&[("logOptions.container", &local_var_str.to_string())]);
891    }
892    if let Some(ref local_var_str) = log_options_period_follow {
893        local_var_req_builder = local_var_req_builder.query(&[("logOptions.follow", &local_var_str.to_string())]);
894    }
895    if let Some(ref local_var_str) = log_options_period_previous {
896        local_var_req_builder = local_var_req_builder.query(&[("logOptions.previous", &local_var_str.to_string())]);
897    }
898    if let Some(ref local_var_str) = log_options_period_since_seconds {
899        local_var_req_builder = local_var_req_builder.query(&[("logOptions.sinceSeconds", &local_var_str.to_string())]);
900    }
901    if let Some(ref local_var_str) = log_options_period_since_time_period_seconds {
902        local_var_req_builder = local_var_req_builder.query(&[("logOptions.sinceTime.seconds", &local_var_str.to_string())]);
903    }
904    if let Some(ref local_var_str) = log_options_period_since_time_period_nanos {
905        local_var_req_builder = local_var_req_builder.query(&[("logOptions.sinceTime.nanos", &local_var_str.to_string())]);
906    }
907    if let Some(ref local_var_str) = log_options_period_timestamps {
908        local_var_req_builder = local_var_req_builder.query(&[("logOptions.timestamps", &local_var_str.to_string())]);
909    }
910    if let Some(ref local_var_str) = log_options_period_tail_lines {
911        local_var_req_builder = local_var_req_builder.query(&[("logOptions.tailLines", &local_var_str.to_string())]);
912    }
913    if let Some(ref local_var_str) = log_options_period_limit_bytes {
914        local_var_req_builder = local_var_req_builder.query(&[("logOptions.limitBytes", &local_var_str.to_string())]);
915    }
916    if let Some(ref local_var_str) = log_options_period_insecure_skip_tls_verify_backend {
917        local_var_req_builder = local_var_req_builder.query(&[("logOptions.insecureSkipTLSVerifyBackend", &local_var_str.to_string())]);
918    }
919    if let Some(ref local_var_str) = grep {
920        local_var_req_builder = local_var_req_builder.query(&[("grep", &local_var_str.to_string())]);
921    }
922    if let Some(ref local_var_str) = selector {
923        local_var_req_builder = local_var_req_builder.query(&[("selector", &local_var_str.to_string())]);
924    }
925    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
926        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
927    }
928    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
929        let local_var_key = local_var_apikey.key.clone();
930        let local_var_value = match local_var_apikey.prefix {
931            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
932            None => local_var_key,
933        };
934        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
935    };
936
937    let local_var_req = local_var_req_builder.build()?;
938    let local_var_resp = local_var_client.execute(local_var_req).await?;
939
940    let local_var_status = local_var_resp.status();
941    let local_var_content = local_var_resp.text().await?;
942
943    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
944        serde_json::from_str(&local_var_content).map_err(Error::from)
945    } else {
946        let local_var_entity: Option<WorkflowServiceWorkflowLogsError> = serde_json::from_str(&local_var_content).ok();
947        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
948        Err(Error::ResponseError(local_var_error))
949    }
950}
951
argo_workflows_rs/apis/workflow_service_api.rs

argo_workflows_rs/apis/
workflow_service_api.rs
