argo_workflows_rs/apis/
archived_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 [`archived_workflow_service_delete_archived_workflow`]
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum ArchivedWorkflowServiceDeleteArchivedWorkflowError {
22    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
23    UnknownValue(serde_json::Value),
24}
25
26/// struct for typed errors of method [`archived_workflow_service_get_archived_workflow`]
27#[derive(Debug, Clone, Serialize, Deserialize)]
28#[serde(untagged)]
29pub enum ArchivedWorkflowServiceGetArchivedWorkflowError {
30    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
31    UnknownValue(serde_json::Value),
32}
33
34/// struct for typed errors of method [`archived_workflow_service_list_archived_workflow_label_keys`]
35#[derive(Debug, Clone, Serialize, Deserialize)]
36#[serde(untagged)]
37pub enum ArchivedWorkflowServiceListArchivedWorkflowLabelKeysError {
38    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
39    UnknownValue(serde_json::Value),
40}
41
42/// struct for typed errors of method [`archived_workflow_service_list_archived_workflow_label_values`]
43#[derive(Debug, Clone, Serialize, Deserialize)]
44#[serde(untagged)]
45pub enum ArchivedWorkflowServiceListArchivedWorkflowLabelValuesError {
46    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
47    UnknownValue(serde_json::Value),
48}
49
50/// struct for typed errors of method [`archived_workflow_service_list_archived_workflows`]
51#[derive(Debug, Clone, Serialize, Deserialize)]
52#[serde(untagged)]
53pub enum ArchivedWorkflowServiceListArchivedWorkflowsError {
54    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
55    UnknownValue(serde_json::Value),
56}
57
58/// struct for typed errors of method [`archived_workflow_service_resubmit_archived_workflow`]
59#[derive(Debug, Clone, Serialize, Deserialize)]
60#[serde(untagged)]
61pub enum ArchivedWorkflowServiceResubmitArchivedWorkflowError {
62    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
63    UnknownValue(serde_json::Value),
64}
65
66/// struct for typed errors of method [`archived_workflow_service_retry_archived_workflow`]
67#[derive(Debug, Clone, Serialize, Deserialize)]
68#[serde(untagged)]
69pub enum ArchivedWorkflowServiceRetryArchivedWorkflowError {
70    DefaultResponse(crate::models::GrpcPeriodGatewayPeriodRuntimePeriodError),
71    UnknownValue(serde_json::Value),
72}
73
74
75pub async fn archived_workflow_service_delete_archived_workflow(configuration: &configuration::Configuration, uid: &str, namespace: Option<&str>) -> Result<serde_json::Value, Error<ArchivedWorkflowServiceDeleteArchivedWorkflowError>> {
76    let local_var_configuration = configuration;
77
78    let local_var_client = &local_var_configuration.client;
79
80    let local_var_uri_str = format!("{}/api/v1/archived-workflows/{uid}", local_var_configuration.base_path, uid=crate::apis::urlencode(uid));
81    let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
82
83    if let Some(ref local_var_str) = namespace {
84        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
85    }
86    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
87        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
88    }
89    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
90        let local_var_key = local_var_apikey.key.clone();
91        let local_var_value = match local_var_apikey.prefix {
92            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
93            None => local_var_key,
94        };
95        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
96    };
97
98    let local_var_req = local_var_req_builder.build()?;
99    let local_var_resp = local_var_client.execute(local_var_req).await?;
100
101    let local_var_status = local_var_resp.status();
102    let local_var_content = local_var_resp.text().await?;
103
104    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
105        serde_json::from_str(&local_var_content).map_err(Error::from)
106    } else {
107        let local_var_entity: Option<ArchivedWorkflowServiceDeleteArchivedWorkflowError> = serde_json::from_str(&local_var_content).ok();
108        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
109        Err(Error::ResponseError(local_var_error))
110    }
111}
112
113pub async fn archived_workflow_service_get_archived_workflow(configuration: &configuration::Configuration, uid: &str, namespace: Option<&str>, name: Option<&str>) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<ArchivedWorkflowServiceGetArchivedWorkflowError>> {
114    let local_var_configuration = configuration;
115
116    let local_var_client = &local_var_configuration.client;
117
118    let local_var_uri_str = format!("{}/api/v1/archived-workflows/{uid}", local_var_configuration.base_path, uid=crate::apis::urlencode(uid));
119    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
120
121    if let Some(ref local_var_str) = namespace {
122        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
123    }
124    if let Some(ref local_var_str) = name {
125        local_var_req_builder = local_var_req_builder.query(&[("name", &local_var_str.to_string())]);
126    }
127    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
128        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
129    }
130    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
131        let local_var_key = local_var_apikey.key.clone();
132        let local_var_value = match local_var_apikey.prefix {
133            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
134            None => local_var_key,
135        };
136        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
137    };
138
139    let local_var_req = local_var_req_builder.build()?;
140    let local_var_resp = local_var_client.execute(local_var_req).await?;
141
142    let local_var_status = local_var_resp.status();
143    let local_var_content = local_var_resp.text().await?;
144
145    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
146        serde_json::from_str(&local_var_content).map_err(Error::from)
147    } else {
148        let local_var_entity: Option<ArchivedWorkflowServiceGetArchivedWorkflowError> = serde_json::from_str(&local_var_content).ok();
149        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
150        Err(Error::ResponseError(local_var_error))
151    }
152}
153
154pub async fn archived_workflow_service_list_archived_workflow_label_keys(configuration: &configuration::Configuration, namespace: Option<&str>) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodLabelKeys, Error<ArchivedWorkflowServiceListArchivedWorkflowLabelKeysError>> {
155    let local_var_configuration = configuration;
156
157    let local_var_client = &local_var_configuration.client;
158
159    let local_var_uri_str = format!("{}/api/v1/archived-workflows-label-keys", local_var_configuration.base_path);
160    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
161
162    if let Some(ref local_var_str) = namespace {
163        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
164    }
165    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
166        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
167    }
168    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
169        let local_var_key = local_var_apikey.key.clone();
170        let local_var_value = match local_var_apikey.prefix {
171            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
172            None => local_var_key,
173        };
174        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
175    };
176
177    let local_var_req = local_var_req_builder.build()?;
178    let local_var_resp = local_var_client.execute(local_var_req).await?;
179
180    let local_var_status = local_var_resp.status();
181    let local_var_content = local_var_resp.text().await?;
182
183    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
184        serde_json::from_str(&local_var_content).map_err(Error::from)
185    } else {
186        let local_var_entity: Option<ArchivedWorkflowServiceListArchivedWorkflowLabelKeysError> = serde_json::from_str(&local_var_content).ok();
187        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
188        Err(Error::ResponseError(local_var_error))
189    }
190}
191
192pub async fn archived_workflow_service_list_archived_workflow_label_values(configuration: &configuration::Configuration, 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>, namespace: Option<&str>) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodLabelValues, Error<ArchivedWorkflowServiceListArchivedWorkflowLabelValuesError>> {
193    let local_var_configuration = configuration;
194
195    let local_var_client = &local_var_configuration.client;
196
197    let local_var_uri_str = format!("{}/api/v1/archived-workflows-label-values", local_var_configuration.base_path);
198    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
199
200    if let Some(ref local_var_str) = list_options_period_label_selector {
201        local_var_req_builder = local_var_req_builder.query(&[("listOptions.labelSelector", &local_var_str.to_string())]);
202    }
203    if let Some(ref local_var_str) = list_options_period_field_selector {
204        local_var_req_builder = local_var_req_builder.query(&[("listOptions.fieldSelector", &local_var_str.to_string())]);
205    }
206    if let Some(ref local_var_str) = list_options_period_watch {
207        local_var_req_builder = local_var_req_builder.query(&[("listOptions.watch", &local_var_str.to_string())]);
208    }
209    if let Some(ref local_var_str) = list_options_period_allow_watch_bookmarks {
210        local_var_req_builder = local_var_req_builder.query(&[("listOptions.allowWatchBookmarks", &local_var_str.to_string())]);
211    }
212    if let Some(ref local_var_str) = list_options_period_resource_version {
213        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersion", &local_var_str.to_string())]);
214    }
215    if let Some(ref local_var_str) = list_options_period_resource_version_match {
216        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersionMatch", &local_var_str.to_string())]);
217    }
218    if let Some(ref local_var_str) = list_options_period_timeout_seconds {
219        local_var_req_builder = local_var_req_builder.query(&[("listOptions.timeoutSeconds", &local_var_str.to_string())]);
220    }
221    if let Some(ref local_var_str) = list_options_period_limit {
222        local_var_req_builder = local_var_req_builder.query(&[("listOptions.limit", &local_var_str.to_string())]);
223    }
224    if let Some(ref local_var_str) = list_options_period_continue {
225        local_var_req_builder = local_var_req_builder.query(&[("listOptions.continue", &local_var_str.to_string())]);
226    }
227    if let Some(ref local_var_str) = namespace {
228        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
229    }
230    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
231        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
232    }
233    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
234        let local_var_key = local_var_apikey.key.clone();
235        let local_var_value = match local_var_apikey.prefix {
236            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
237            None => local_var_key,
238        };
239        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
240    };
241
242    let local_var_req = local_var_req_builder.build()?;
243    let local_var_resp = local_var_client.execute(local_var_req).await?;
244
245    let local_var_status = local_var_resp.status();
246    let local_var_content = local_var_resp.text().await?;
247
248    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
249        serde_json::from_str(&local_var_content).map_err(Error::from)
250    } else {
251        let local_var_entity: Option<ArchivedWorkflowServiceListArchivedWorkflowLabelValuesError> = serde_json::from_str(&local_var_content).ok();
252        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
253        Err(Error::ResponseError(local_var_error))
254    }
255}
256
257pub async fn archived_workflow_service_list_archived_workflows(configuration: &configuration::Configuration, 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>, name_prefix: Option<&str>, namespace: Option<&str>) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflowList, Error<ArchivedWorkflowServiceListArchivedWorkflowsError>> {
258    let local_var_configuration = configuration;
259
260    let local_var_client = &local_var_configuration.client;
261
262    let local_var_uri_str = format!("{}/api/v1/archived-workflows", local_var_configuration.base_path);
263    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
264
265    if let Some(ref local_var_str) = list_options_period_label_selector {
266        local_var_req_builder = local_var_req_builder.query(&[("listOptions.labelSelector", &local_var_str.to_string())]);
267    }
268    if let Some(ref local_var_str) = list_options_period_field_selector {
269        local_var_req_builder = local_var_req_builder.query(&[("listOptions.fieldSelector", &local_var_str.to_string())]);
270    }
271    if let Some(ref local_var_str) = list_options_period_watch {
272        local_var_req_builder = local_var_req_builder.query(&[("listOptions.watch", &local_var_str.to_string())]);
273    }
274    if let Some(ref local_var_str) = list_options_period_allow_watch_bookmarks {
275        local_var_req_builder = local_var_req_builder.query(&[("listOptions.allowWatchBookmarks", &local_var_str.to_string())]);
276    }
277    if let Some(ref local_var_str) = list_options_period_resource_version {
278        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersion", &local_var_str.to_string())]);
279    }
280    if let Some(ref local_var_str) = list_options_period_resource_version_match {
281        local_var_req_builder = local_var_req_builder.query(&[("listOptions.resourceVersionMatch", &local_var_str.to_string())]);
282    }
283    if let Some(ref local_var_str) = list_options_period_timeout_seconds {
284        local_var_req_builder = local_var_req_builder.query(&[("listOptions.timeoutSeconds", &local_var_str.to_string())]);
285    }
286    if let Some(ref local_var_str) = list_options_period_limit {
287        local_var_req_builder = local_var_req_builder.query(&[("listOptions.limit", &local_var_str.to_string())]);
288    }
289    if let Some(ref local_var_str) = list_options_period_continue {
290        local_var_req_builder = local_var_req_builder.query(&[("listOptions.continue", &local_var_str.to_string())]);
291    }
292    if let Some(ref local_var_str) = name_prefix {
293        local_var_req_builder = local_var_req_builder.query(&[("namePrefix", &local_var_str.to_string())]);
294    }
295    if let Some(ref local_var_str) = namespace {
296        local_var_req_builder = local_var_req_builder.query(&[("namespace", &local_var_str.to_string())]);
297    }
298    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
299        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
300    }
301    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
302        let local_var_key = local_var_apikey.key.clone();
303        let local_var_value = match local_var_apikey.prefix {
304            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
305            None => local_var_key,
306        };
307        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
308    };
309
310    let local_var_req = local_var_req_builder.build()?;
311    let local_var_resp = local_var_client.execute(local_var_req).await?;
312
313    let local_var_status = local_var_resp.status();
314    let local_var_content = local_var_resp.text().await?;
315
316    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
317        serde_json::from_str(&local_var_content).map_err(Error::from)
318    } else {
319        let local_var_entity: Option<ArchivedWorkflowServiceListArchivedWorkflowsError> = serde_json::from_str(&local_var_content).ok();
320        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
321        Err(Error::ResponseError(local_var_error))
322    }
323}
324
325pub async fn archived_workflow_service_resubmit_archived_workflow(configuration: &configuration::Configuration, uid: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodResubmitArchivedWorkflowRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<ArchivedWorkflowServiceResubmitArchivedWorkflowError>> {
326    let local_var_configuration = configuration;
327
328    let local_var_client = &local_var_configuration.client;
329
330    let local_var_uri_str = format!("{}/api/v1/archived-workflows/{uid}/resubmit", local_var_configuration.base_path, uid=crate::apis::urlencode(uid));
331    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
332
333    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
334        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
335    }
336    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
337        let local_var_key = local_var_apikey.key.clone();
338        let local_var_value = match local_var_apikey.prefix {
339            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
340            None => local_var_key,
341        };
342        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
343    };
344    local_var_req_builder = local_var_req_builder.json(&body);
345
346    let local_var_req = local_var_req_builder.build()?;
347    let local_var_resp = local_var_client.execute(local_var_req).await?;
348
349    let local_var_status = local_var_resp.status();
350    let local_var_content = local_var_resp.text().await?;
351
352    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
353        serde_json::from_str(&local_var_content).map_err(Error::from)
354    } else {
355        let local_var_entity: Option<ArchivedWorkflowServiceResubmitArchivedWorkflowError> = serde_json::from_str(&local_var_content).ok();
356        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
357        Err(Error::ResponseError(local_var_error))
358    }
359}
360
361pub async fn archived_workflow_service_retry_archived_workflow(configuration: &configuration::Configuration, uid: &str, body: crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodRetryArchivedWorkflowRequest) -> Result<crate::models::IoPeriodArgoprojPeriodWorkflowPeriodV1alpha1PeriodWorkflow, Error<ArchivedWorkflowServiceRetryArchivedWorkflowError>> {
362    let local_var_configuration = configuration;
363
364    let local_var_client = &local_var_configuration.client;
365
366    let local_var_uri_str = format!("{}/api/v1/archived-workflows/{uid}/retry", local_var_configuration.base_path, uid=crate::apis::urlencode(uid));
367    let mut local_var_req_builder = local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
368
369    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
370        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
371    }
372    if let Some(ref local_var_apikey) = local_var_configuration.api_key {
373        let local_var_key = local_var_apikey.key.clone();
374        let local_var_value = match local_var_apikey.prefix {
375            Some(ref local_var_prefix) => format!("{} {}", local_var_prefix, local_var_key),
376            None => local_var_key,
377        };
378        local_var_req_builder = local_var_req_builder.header("Authorization", local_var_value);
379    };
380    local_var_req_builder = local_var_req_builder.json(&body);
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        serde_json::from_str(&local_var_content).map_err(Error::from)
390    } else {
391        let local_var_entity: Option<ArchivedWorkflowServiceRetryArchivedWorkflowError> = serde_json::from_str(&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
argo_workflows_rs/apis/archived_workflow_service_api.rs

argo_workflows_rs/apis/
archived_workflow_service_api.rs
