opensearch_client/cluster/
cluster_api.rs

1/*
2 * opensearch-client
3 *
4 * Rust Client for OpenSearch
5 *
6 * The version of the OpenAPI document: 3.1.0
7 * Contact: alberto.paro@gmail.com
8 * Generated by Paro OpenAPI Generator
9 */
10use bon::bon;
11
12use crate::*;
13use reqwest;
14use serde::{Deserialize, Serialize, de::Error as OtherError};
15use std::sync::Arc;
16
17pub struct ClusterApiClient {
18    configuration: Arc<crate::Configuration>,
19}
20
21#[bon]
22impl ClusterApiClient {
23    pub fn new(configuration: Arc<crate::Configuration>) -> Self {
24        Self { configuration }
25    }
26
27    ///
28    /// Returns cluster settings.
29    #[builder]
30    pub async fn get_settings(
31        &self,
32        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
33        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
34        cluster_manager_timeout: Option<String>,
35        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
36        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
37        master_timeout: Option<String>,
38        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
39        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
40        timeout: Option<String>,
41        /// No description available
42        error_trace: Option<bool>,
43        /// No description available
44        filter_path: Option<common::FilterPath>,
45        /// No description available
46        flat_settings: Option<bool>,
47        /// No description available
48        human: Option<bool>,
49        /// No description available
50        include_defaults: Option<bool>,
51        /// No description available
52        pretty: Option<bool>,
53        /// No description available
54        source: Option<String>,
55    ) -> Result<crate::cluster::GetSettingsResponse, Error> {
56        let local_var_configuration = &self.configuration;
57
58        let local_var_client = &local_var_configuration.client;
59
60        let local_var_uri_str = format!("{}_cluster/settings", local_var_configuration.base_path);
61        let mut local_var_req_builder =
62            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
63
64        if let Some(ref local_var_str) = source {
65            local_var_req_builder =
66                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
67        }
68        if let Some(ref local_var_str) = filter_path {
69            local_var_req_builder =
70                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
71        }
72        if let Some(ref local_var_str) = error_trace {
73            local_var_req_builder =
74                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
75        }
76        if let Some(ref local_var_str) = timeout {
77            local_var_req_builder =
78                local_var_req_builder.query(&[("timeout", &local_var_str.to_string())]);
79        }
80        if let Some(ref local_var_str) = pretty {
81            local_var_req_builder =
82                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
83        }
84        if let Some(ref local_var_str) = master_timeout {
85            local_var_req_builder =
86                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
87        }
88        if let Some(ref local_var_str) = flat_settings {
89            local_var_req_builder =
90                local_var_req_builder.query(&[("flat_settings", &local_var_str.to_string())]);
91        }
92        if let Some(ref local_var_str) = cluster_manager_timeout {
93            local_var_req_builder = local_var_req_builder
94                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
95        }
96        if let Some(ref local_var_str) = include_defaults {
97            local_var_req_builder =
98                local_var_req_builder.query(&[("include_defaults", &local_var_str.to_string())]);
99        }
100        if let Some(ref local_var_str) = human {
101            local_var_req_builder =
102                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
103        }
104
105        let local_var_req = local_var_req_builder.build()?;
106        let local_var_resp = local_var_client.execute(local_var_req).await?;
107
108        let local_var_status = local_var_resp.status();
109        let local_var_content = local_var_resp.text().await?;
110
111        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
112            serde_json::from_str(&local_var_content).map_err(Error::from)
113        } else {
114            let local_var_error = ResponseContent {
115                status: local_var_status,
116                content: local_var_content,
117            };
118            Err(Error::ApiError(local_var_error))
119        }
120    }
121    ///
122    /// Retrieves the decommission status for all zones.
123    #[builder]
124    pub async fn get_decommission_awareness(
125        &self,
126        /// No description available
127        awareness_attribute_name: String,
128        /// No description available
129        error_trace: Option<bool>,
130        /// No description available
131        filter_path: Option<common::FilterPath>,
132        /// No description available
133        human: Option<bool>,
134        /// No description available
135        pretty: Option<bool>,
136        /// No description available
137        source: Option<String>,
138    ) -> Result<crate::cluster::decommission_awareness::DecommissionStatusResponse, Error> {
139        let local_var_configuration = &self.configuration;
140
141        let local_var_client = &local_var_configuration.client;
142
143        let local_var_uri_str = format!(
144            "{}_cluster/decommission/awareness/{awareness_attribute_name}/_status",
145            local_var_configuration.base_path,
146            awareness_attribute_name = awareness_attribute_name
147        );
148        let mut local_var_req_builder =
149            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
150
151        if let Some(ref local_var_str) = human {
152            local_var_req_builder =
153                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
154        }
155        if let Some(ref local_var_str) = pretty {
156            local_var_req_builder =
157                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
158        }
159        if let Some(ref local_var_str) = filter_path {
160            local_var_req_builder =
161                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
162        }
163        if let Some(ref local_var_str) = error_trace {
164            local_var_req_builder =
165                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
166        }
167        if let Some(ref local_var_str) = source {
168            local_var_req_builder =
169                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
170        }
171
172        let local_var_req = local_var_req_builder.build()?;
173        let local_var_resp = local_var_client.execute(local_var_req).await?;
174
175        let local_var_status = local_var_resp.status();
176        let local_var_content = local_var_resp.text().await?;
177
178        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
179            serde_json::from_str(&local_var_content).map_err(Error::from)
180        } else {
181            let local_var_error = ResponseContent {
182                status: local_var_status,
183                content: local_var_content,
184            };
185            Err(Error::ApiError(local_var_error))
186        }
187    }
188    ///
189    /// Updates the cluster settings.
190    #[builder]
191    pub async fn put_settings(
192        &self,
193        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
194        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
195        cluster_manager_timeout: Option<String>,
196        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
197        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
198        master_timeout: Option<String>,
199        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
200        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
201        timeout: Option<String>,
202        /// No description available
203        error_trace: Option<bool>,
204        /// No description available
205        filter_path: Option<common::FilterPath>,
206        /// No description available
207        flat_settings: Option<bool>,
208        /// No description available
209        human: Option<bool>,
210        /// No description available
211        pretty: Option<bool>,
212        /// No description available
213        source: Option<String>,
214        /// The cluster settings to update.
215        put_settings: cluster::PutSettings,
216    ) -> Result<crate::cluster::PutSettingsResponse, Error> {
217        let local_var_configuration = &self.configuration;
218
219        let local_var_client = &local_var_configuration.client;
220
221        let local_var_uri_str = format!("{}_cluster/settings", local_var_configuration.base_path);
222        let mut local_var_req_builder =
223            local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
224
225        if let Some(ref local_var_str) = human {
226            local_var_req_builder =
227                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
228        }
229        if let Some(ref local_var_str) = pretty {
230            local_var_req_builder =
231                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
232        }
233        if let Some(ref local_var_str) = source {
234            local_var_req_builder =
235                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
236        }
237        if let Some(ref local_var_str) = timeout {
238            local_var_req_builder =
239                local_var_req_builder.query(&[("timeout", &local_var_str.to_string())]);
240        }
241        if let Some(ref local_var_str) = flat_settings {
242            local_var_req_builder =
243                local_var_req_builder.query(&[("flat_settings", &local_var_str.to_string())]);
244        }
245        if let Some(ref local_var_str) = cluster_manager_timeout {
246            local_var_req_builder = local_var_req_builder
247                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
248        }
249        if let Some(ref local_var_str) = master_timeout {
250            local_var_req_builder =
251                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
252        }
253        if let Some(ref local_var_str) = error_trace {
254            local_var_req_builder =
255                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
256        }
257        if let Some(ref local_var_str) = filter_path {
258            local_var_req_builder =
259                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
260        }
261
262        local_var_req_builder = local_var_req_builder.json(&put_settings);
263
264        let local_var_req = local_var_req_builder.build()?;
265        let local_var_resp = local_var_client.execute(local_var_req).await?;
266
267        let local_var_status = local_var_resp.status();
268        let local_var_content = local_var_resp.text().await?;
269
270        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
271            serde_json::from_str(&local_var_content).map_err(Error::from)
272        } else {
273            let local_var_error = ResponseContent {
274                status: local_var_status,
275                content: local_var_content,
276            };
277            Err(Error::ApiError(local_var_error))
278        }
279    }
280    ///
281    /// Deletes a component template.
282    #[builder]
283    pub async fn delete_component_template(
284        &self,
285        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
286        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
287        cluster_manager_timeout: Option<String>,
288        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
289        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
290        master_timeout: Option<String>,
291        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
292        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
293        timeout: Option<String>,
294        /// No description available
295        error_trace: Option<bool>,
296        /// No description available
297        filter_path: Option<common::FilterPath>,
298        /// No description available
299        human: Option<bool>,
300        /// No description available
301        name: String,
302        /// No description available
303        pretty: Option<bool>,
304        /// No description available
305        source: Option<String>,
306    ) -> Result<crate::common::AcknowledgedResponseBase, Error> {
307        let local_var_configuration = &self.configuration;
308
309        let local_var_client = &local_var_configuration.client;
310
311        let local_var_uri_str = format!(
312            "{}_component_template/{name}",
313            local_var_configuration.base_path,
314            name = name
315        );
316        let mut local_var_req_builder =
317            local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
318
319        if let Some(ref local_var_str) = human {
320            local_var_req_builder =
321                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
322        }
323        if let Some(ref local_var_str) = filter_path {
324            local_var_req_builder =
325                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
326        }
327        if let Some(ref local_var_str) = pretty {
328            local_var_req_builder =
329                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
330        }
331        if let Some(ref local_var_str) = master_timeout {
332            local_var_req_builder =
333                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
334        }
335        if let Some(ref local_var_str) = error_trace {
336            local_var_req_builder =
337                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
338        }
339        if let Some(ref local_var_str) = cluster_manager_timeout {
340            local_var_req_builder = local_var_req_builder
341                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
342        }
343        if let Some(ref local_var_str) = source {
344            local_var_req_builder =
345                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
346        }
347        if let Some(ref local_var_str) = timeout {
348            local_var_req_builder =
349                local_var_req_builder.query(&[("timeout", &local_var_str.to_string())]);
350        }
351
352        let local_var_req = local_var_req_builder.build()?;
353        let local_var_resp = local_var_client.execute(local_var_req).await?;
354
355        let local_var_status = local_var_resp.status();
356        let local_var_content = local_var_resp.text().await?;
357
358        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
359            serde_json::from_str(&local_var_content).map_err(Error::from)
360        } else {
361            let local_var_error = ResponseContent {
362                status: local_var_status,
363                content: local_var_content,
364            };
365            Err(Error::ApiError(local_var_error))
366        }
367    }
368    ///
369    /// Returns information about whether a particular component template exist.
370    #[builder]
371    pub async fn exists_component_template(
372        &self,
373        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
374        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
375        cluster_manager_timeout: Option<String>,
376        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
377        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
378        master_timeout: Option<String>,
379        /// No description available
380        error_trace: Option<bool>,
381        /// No description available
382        filter_path: Option<common::FilterPath>,
383        /// No description available
384        human: Option<bool>,
385        /// No description available
386        local: Option<bool>,
387        /// No description available
388        name: String,
389        /// No description available
390        pretty: Option<bool>,
391        /// No description available
392        source: Option<String>,
393    ) -> Result<serde_json::Value, Error> {
394        let local_var_configuration = &self.configuration;
395
396        let local_var_client = &local_var_configuration.client;
397
398        let local_var_uri_str = format!(
399            "{}_component_template/{name}",
400            local_var_configuration.base_path,
401            name = name
402        );
403        let mut local_var_req_builder =
404            local_var_client.request(reqwest::Method::HEAD, local_var_uri_str.as_str());
405
406        if let Some(ref local_var_str) = filter_path {
407            local_var_req_builder =
408                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
409        }
410        if let Some(ref local_var_str) = local {
411            local_var_req_builder =
412                local_var_req_builder.query(&[("local", &local_var_str.to_string())]);
413        }
414        if let Some(ref local_var_str) = human {
415            local_var_req_builder =
416                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
417        }
418        if let Some(ref local_var_str) = cluster_manager_timeout {
419            local_var_req_builder = local_var_req_builder
420                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
421        }
422        if let Some(ref local_var_str) = master_timeout {
423            local_var_req_builder =
424                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
425        }
426        if let Some(ref local_var_str) = pretty {
427            local_var_req_builder =
428                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
429        }
430        if let Some(ref local_var_str) = source {
431            local_var_req_builder =
432                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
433        }
434        if let Some(ref local_var_str) = error_trace {
435            local_var_req_builder =
436                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
437        }
438
439        let local_var_req = local_var_req_builder.build()?;
440        let local_var_resp = local_var_client.execute(local_var_req).await?;
441
442        let local_var_status = local_var_resp.status();
443        let local_var_content = local_var_resp.text().await?;
444
445        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
446            serde_json::from_str(&local_var_content).map_err(Error::from)
447        } else {
448            let local_var_error = ResponseContent {
449                status: local_var_status,
450                content: local_var_content,
451            };
452            Err(Error::ApiError(local_var_error))
453        }
454    }
455    ///
456    /// Returns one or more component templates.
457    #[builder]
458    pub async fn get_component_template(
459        &self,
460        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
461        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
462        cluster_manager_timeout: Option<String>,
463        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
464        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
465        master_timeout: Option<String>,
466        /// No description available
467        error_trace: Option<bool>,
468        /// No description available
469        filter_path: Option<common::FilterPath>,
470        /// No description available
471        flat_settings: Option<bool>,
472        /// No description available
473        human: Option<bool>,
474        /// No description available
475        local: Option<bool>,
476        /// No description available
477        name: String,
478        /// No description available
479        pretty: Option<bool>,
480        /// No description available
481        source: Option<String>,
482    ) -> Result<crate::cluster::GetComponentTemplateResponse, Error> {
483        let local_var_configuration = &self.configuration;
484
485        let local_var_client = &local_var_configuration.client;
486
487        let local_var_uri_str = format!(
488            "{}_component_template/{name}",
489            local_var_configuration.base_path,
490            name = name
491        );
492        let mut local_var_req_builder =
493            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
494
495        if let Some(ref local_var_str) = filter_path {
496            local_var_req_builder =
497                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
498        }
499        if let Some(ref local_var_str) = master_timeout {
500            local_var_req_builder =
501                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
502        }
503        if let Some(ref local_var_str) = local {
504            local_var_req_builder =
505                local_var_req_builder.query(&[("local", &local_var_str.to_string())]);
506        }
507        if let Some(ref local_var_str) = source {
508            local_var_req_builder =
509                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
510        }
511        if let Some(ref local_var_str) = cluster_manager_timeout {
512            local_var_req_builder = local_var_req_builder
513                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
514        }
515        if let Some(ref local_var_str) = human {
516            local_var_req_builder =
517                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
518        }
519        if let Some(ref local_var_str) = pretty {
520            local_var_req_builder =
521                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
522        }
523        if let Some(ref local_var_str) = flat_settings {
524            local_var_req_builder =
525                local_var_req_builder.query(&[("flat_settings", &local_var_str.to_string())]);
526        }
527        if let Some(ref local_var_str) = error_trace {
528            local_var_req_builder =
529                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
530        }
531
532        let local_var_req = local_var_req_builder.build()?;
533        let local_var_resp = local_var_client.execute(local_var_req).await?;
534
535        let local_var_status = local_var_resp.status();
536        let local_var_content = local_var_resp.text().await?;
537
538        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
539            serde_json::from_str(&local_var_content).map_err(Error::from)
540        } else {
541            let local_var_error = ResponseContent {
542                status: local_var_status,
543                content: local_var_content,
544            };
545            Err(Error::ApiError(local_var_error))
546        }
547    }
548    ///
549    /// Recommissions a decommissioned zone.
550    #[builder]
551    pub async fn delete_decommission_awareness(
552        &self,
553        /// No description available
554        error_trace: Option<bool>,
555        /// No description available
556        filter_path: Option<common::FilterPath>,
557        /// No description available
558        human: Option<bool>,
559        /// No description available
560        pretty: Option<bool>,
561        /// No description available
562        source: Option<String>,
563    ) -> Result<crate::common::AcknowledgedResponseBase, Error> {
564        let local_var_configuration = &self.configuration;
565
566        let local_var_client = &local_var_configuration.client;
567
568        let local_var_uri_str = format!(
569            "{}_cluster/decommission/awareness",
570            local_var_configuration.base_path
571        );
572        let mut local_var_req_builder =
573            local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
574
575        if let Some(ref local_var_str) = source {
576            local_var_req_builder =
577                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
578        }
579        if let Some(ref local_var_str) = filter_path {
580            local_var_req_builder =
581                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
582        }
583        if let Some(ref local_var_str) = error_trace {
584            local_var_req_builder =
585                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
586        }
587        if let Some(ref local_var_str) = pretty {
588            local_var_req_builder =
589                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
590        }
591        if let Some(ref local_var_str) = human {
592            local_var_req_builder =
593                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
594        }
595
596        let local_var_req = local_var_req_builder.build()?;
597        let local_var_resp = local_var_client.execute(local_var_req).await?;
598
599        let local_var_status = local_var_resp.status();
600        let local_var_content = local_var_resp.text().await?;
601
602        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
603            serde_json::from_str(&local_var_content).map_err(Error::from)
604        } else {
605            let local_var_error = ResponseContent {
606                status: local_var_status,
607                content: local_var_content,
608            };
609            Err(Error::ApiError(local_var_error))
610        }
611    }
612    ///
613    /// Fetches weighted shard routing weights.
614    #[builder]
615    pub async fn get_weighted_routing(
616        &self,
617        /// No description available
618        attribute: String,
619        /// No description available
620        error_trace: Option<bool>,
621        /// No description available
622        filter_path: Option<common::FilterPath>,
623        /// No description available
624        human: Option<bool>,
625        /// No description available
626        pretty: Option<bool>,
627        /// No description available
628        source: Option<String>,
629    ) -> Result<crate::cluster::weighted_routing::WeightsResponse, Error> {
630        let local_var_configuration = &self.configuration;
631
632        let local_var_client = &local_var_configuration.client;
633
634        let local_var_uri_str = format!(
635            "{}_cluster/routing/awareness/{attribute}/weights",
636            local_var_configuration.base_path,
637            attribute = attribute
638        );
639        let mut local_var_req_builder =
640            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
641
642        if let Some(ref local_var_str) = human {
643            local_var_req_builder =
644                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
645        }
646        if let Some(ref local_var_str) = error_trace {
647            local_var_req_builder =
648                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
649        }
650        if let Some(ref local_var_str) = source {
651            local_var_req_builder =
652                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
653        }
654        if let Some(ref local_var_str) = pretty {
655            local_var_req_builder =
656                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
657        }
658        if let Some(ref local_var_str) = filter_path {
659            local_var_req_builder =
660                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
661        }
662
663        let local_var_req = local_var_req_builder.build()?;
664        let local_var_resp = local_var_client.execute(local_var_req).await?;
665
666        let local_var_status = local_var_resp.status();
667        let local_var_content = local_var_resp.text().await?;
668
669        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
670            serde_json::from_str(&local_var_content).map_err(Error::from)
671        } else {
672            let local_var_error = ResponseContent {
673                status: local_var_status,
674                content: local_var_content,
675            };
676            Err(Error::ApiError(local_var_error))
677        }
678    }
679    ///
680    /// Delete weighted shard routing weights.
681    #[builder]
682    pub async fn delete_weighted_routing(
683        &self,
684        delete_weighted_routing: cluster::DeleteWeightedRouting,
685        /// No description available
686        error_trace: Option<bool>,
687        /// No description available
688        filter_path: Option<common::FilterPath>,
689        /// No description available
690        human: Option<bool>,
691        /// No description available
692        pretty: Option<bool>,
693        /// No description available
694        source: Option<String>,
695    ) -> Result<crate::common::AcknowledgedResponseBase, Error> {
696        let local_var_configuration = &self.configuration;
697
698        let local_var_client = &local_var_configuration.client;
699
700        let local_var_uri_str = format!(
701            "{}_cluster/routing/awareness/weights",
702            local_var_configuration.base_path
703        );
704        let mut local_var_req_builder =
705            local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
706
707        if let Some(ref local_var_str) = pretty {
708            local_var_req_builder =
709                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
710        }
711        if let Some(ref local_var_str) = error_trace {
712            local_var_req_builder =
713                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
714        }
715        if let Some(ref local_var_str) = human {
716            local_var_req_builder =
717                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
718        }
719        if let Some(ref local_var_str) = source {
720            local_var_req_builder =
721                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
722        }
723        if let Some(ref local_var_str) = filter_path {
724            local_var_req_builder =
725                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
726        }
727
728        local_var_req_builder = local_var_req_builder.json(&delete_weighted_routing);
729
730        let local_var_req = local_var_req_builder.build()?;
731        let local_var_resp = local_var_client.execute(local_var_req).await?;
732
733        let local_var_status = local_var_resp.status();
734        let local_var_content = local_var_resp.text().await?;
735
736        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
737            serde_json::from_str(&local_var_content).map_err(Error::from)
738        } else {
739            let local_var_error = ResponseContent {
740                status: local_var_status,
741                content: local_var_content,
742            };
743            Err(Error::ApiError(local_var_error))
744        }
745    }
746    ///
747    /// Updates the cluster voting configuration by excluding certain node IDs or names.
748    #[builder]
749    pub async fn post_voting_config_exclusions(
750        &self,
751        /// A comma-separated list of aliases to retrieve. Supports wildcards (`*`).  To retrieve all aliases, omit this parameter or use `*` or `_all`.
752        node_names: Option<common::NodeNames>,
753        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
754        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
755        timeout: Option<String>,
756        /// No description available
757        error_trace: Option<bool>,
758        /// No description available
759        filter_path: Option<common::FilterPath>,
760        /// No description available
761        human: Option<bool>,
762        /// No description available
763        node_ids: Option<common::NodeIds>,
764        /// No description available
765        pretty: Option<bool>,
766        /// No description available
767        source: Option<String>,
768    ) -> Result<serde_json::Value, Error> {
769        let local_var_configuration = &self.configuration;
770
771        let local_var_client = &local_var_configuration.client;
772
773        let local_var_uri_str = format!(
774            "{}_cluster/voting_config_exclusions",
775            local_var_configuration.base_path
776        );
777        let mut local_var_req_builder =
778            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
779
780        if let Some(ref local_var_str) = pretty {
781            local_var_req_builder =
782                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
783        }
784        if let Some(ref local_var_str) = human {
785            local_var_req_builder =
786                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
787        }
788        if let Some(ref local_var_str) = node_ids {
789            local_var_req_builder =
790                local_var_req_builder.query(&[("node_ids", &local_var_str.to_string())]);
791        }
792        if let Some(ref local_var_str) = node_names {
793            local_var_req_builder =
794                local_var_req_builder.query(&[("node_names", &local_var_str.to_string())]);
795        }
796        if let Some(ref local_var_str) = error_trace {
797            local_var_req_builder =
798                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
799        }
800        if let Some(ref local_var_str) = timeout {
801            local_var_req_builder =
802                local_var_req_builder.query(&[("timeout", &local_var_str.to_string())]);
803        }
804        if let Some(ref local_var_str) = source {
805            local_var_req_builder =
806                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
807        }
808        if let Some(ref local_var_str) = filter_path {
809            local_var_req_builder =
810                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
811        }
812
813        let local_var_req = local_var_req_builder.build()?;
814        let local_var_resp = local_var_client.execute(local_var_req).await?;
815
816        let local_var_status = local_var_resp.status();
817        let local_var_content = local_var_resp.text().await?;
818
819        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
820            serde_json::from_str(&local_var_content).map_err(Error::from)
821        } else {
822            let local_var_error = ResponseContent {
823                status: local_var_status,
824                content: local_var_content,
825            };
826            Err(Error::ApiError(local_var_error))
827        }
828    }
829    ///
830    /// Returns a list of pending cluster-level tasks, such as index creation, mapping updates,
831    /// or new allocations.
832    #[builder]
833    pub async fn pending_tasks(
834        &self,
835        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
836        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
837        cluster_manager_timeout: Option<String>,
838        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
839        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
840        master_timeout: Option<String>,
841        /// No description available
842        error_trace: Option<bool>,
843        /// No description available
844        filter_path: Option<common::FilterPath>,
845        /// No description available
846        human: Option<bool>,
847        /// No description available
848        local: Option<bool>,
849        /// No description available
850        pretty: Option<bool>,
851        /// No description available
852        source: Option<String>,
853    ) -> Result<crate::cluster::PendingTasksResponse, Error> {
854        let local_var_configuration = &self.configuration;
855
856        let local_var_client = &local_var_configuration.client;
857
858        let local_var_uri_str = format!(
859            "{}_cluster/pending_tasks",
860            local_var_configuration.base_path
861        );
862        let mut local_var_req_builder =
863            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
864
865        if let Some(ref local_var_str) = source {
866            local_var_req_builder =
867                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
868        }
869        if let Some(ref local_var_str) = filter_path {
870            local_var_req_builder =
871                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
872        }
873        if let Some(ref local_var_str) = pretty {
874            local_var_req_builder =
875                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
876        }
877        if let Some(ref local_var_str) = cluster_manager_timeout {
878            local_var_req_builder = local_var_req_builder
879                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
880        }
881        if let Some(ref local_var_str) = human {
882            local_var_req_builder =
883                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
884        }
885        if let Some(ref local_var_str) = error_trace {
886            local_var_req_builder =
887                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
888        }
889        if let Some(ref local_var_str) = local {
890            local_var_req_builder =
891                local_var_req_builder.query(&[("local", &local_var_str.to_string())]);
892        }
893        if let Some(ref local_var_str) = master_timeout {
894            local_var_req_builder =
895                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
896        }
897
898        let local_var_req = local_var_req_builder.build()?;
899        let local_var_resp = local_var_client.execute(local_var_req).await?;
900
901        let local_var_status = local_var_resp.status();
902        let local_var_content = local_var_resp.text().await?;
903
904        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
905            serde_json::from_str(&local_var_content).map_err(Error::from)
906        } else {
907            let local_var_error = ResponseContent {
908                status: local_var_status,
909                content: local_var_content,
910            };
911            Err(Error::ApiError(local_var_error))
912        }
913    }
914    ///
915    /// Allows to manually change the allocation of individual shards in the cluster.
916    #[builder]
917    pub async fn reroute(
918        &self,
919        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
920        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
921        cluster_manager_timeout: Option<String>,
922        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
923        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
924        master_timeout: Option<String>,
925        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
926        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
927        timeout: Option<String>,
928        /// No description available
929        dry_run: Option<bool>,
930        /// No description available
931        error_trace: Option<bool>,
932        /// No description available
933        explain: Option<bool>,
934        /// No description available
935        filter_path: Option<common::FilterPath>,
936        /// No description available
937        human: Option<bool>,
938        /// No description available
939        metric: Option<common::Metric>,
940        /// No description available
941        pretty: Option<bool>,
942        /// No description available
943        retry_failed: Option<bool>,
944        /// No description available
945        source: Option<String>,
946        /// The definition of `commands` to perform (`move`, `cancel`, `allocate`)
947        reroute: cluster::Reroute,
948    ) -> Result<String, Error> {
949        let local_var_configuration = &self.configuration;
950
951        let local_var_client = &local_var_configuration.client;
952
953        let local_var_uri_str = format!("{}_cluster/reroute", local_var_configuration.base_path);
954        let mut local_var_req_builder =
955            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
956
957        if let Some(ref local_var_str) = filter_path {
958            local_var_req_builder =
959                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
960        }
961        if let Some(ref local_var_str) = master_timeout {
962            local_var_req_builder =
963                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
964        }
965        if let Some(ref local_var_str) = metric {
966            local_var_req_builder =
967                local_var_req_builder.query(&[("metric", &local_var_str.to_string())]);
968        }
969        if let Some(ref local_var_str) = timeout {
970            local_var_req_builder =
971                local_var_req_builder.query(&[("timeout", &local_var_str.to_string())]);
972        }
973        if let Some(ref local_var_str) = pretty {
974            local_var_req_builder =
975                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
976        }
977        if let Some(ref local_var_str) = source {
978            local_var_req_builder =
979                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
980        }
981        if let Some(ref local_var_str) = human {
982            local_var_req_builder =
983                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
984        }
985        if let Some(ref local_var_str) = cluster_manager_timeout {
986            local_var_req_builder = local_var_req_builder
987                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
988        }
989        if let Some(ref local_var_str) = explain {
990            local_var_req_builder =
991                local_var_req_builder.query(&[("explain", &local_var_str.to_string())]);
992        }
993        if let Some(ref local_var_str) = error_trace {
994            local_var_req_builder =
995                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
996        }
997        if let Some(ref local_var_str) = retry_failed {
998            local_var_req_builder =
999                local_var_req_builder.query(&[("retry_failed", &local_var_str.to_string())]);
1000        }
1001        if let Some(ref local_var_str) = dry_run {
1002            local_var_req_builder =
1003                local_var_req_builder.query(&[("dry_run", &local_var_str.to_string())]);
1004        }
1005
1006        local_var_req_builder = local_var_req_builder.json(&reroute);
1007
1008        let local_var_req = local_var_req_builder.build()?;
1009        let local_var_resp = local_var_client.execute(local_var_req).await?;
1010
1011        let local_var_status = local_var_resp.status();
1012        let local_var_content = local_var_resp.text().await?;
1013
1014        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1015            serde_json::from_str(&local_var_content).map_err(Error::from)
1016        } else {
1017            let local_var_error = ResponseContent {
1018                status: local_var_status,
1019                content: local_var_content,
1020            };
1021            Err(Error::ApiError(local_var_error))
1022        }
1023    }
1024    ///
1025    /// Explains how shards are allocated in the current cluster and provides an explanation for why unassigned shards can't be allocated to a node.
1026    #[builder]
1027    pub async fn allocation_explain(
1028        &self,
1029        /// No description available
1030        error_trace: Option<bool>,
1031        /// No description available
1032        filter_path: Option<common::FilterPath>,
1033        /// No description available
1034        human: Option<bool>,
1035        /// No description available
1036        include_disk_info: Option<bool>,
1037        /// No description available
1038        include_yes_decisions: Option<bool>,
1039        /// No description available
1040        pretty: Option<bool>,
1041        /// No description available
1042        source: Option<String>,
1043        /// The index, shard, and primary flag for which to generate an explanation. Leave this empty to generate an explanation for the first unassigned shard.
1044        allocation_explain: cluster::AllocationExplain,
1045    ) -> Result<crate::cluster::AllocationExplainResponse, Error> {
1046        let local_var_configuration = &self.configuration;
1047
1048        let local_var_client = &local_var_configuration.client;
1049
1050        let local_var_uri_str = format!(
1051            "{}_cluster/allocation/explain",
1052            local_var_configuration.base_path
1053        );
1054        let mut local_var_req_builder =
1055            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1056
1057        if let Some(ref local_var_str) = include_disk_info {
1058            local_var_req_builder =
1059                local_var_req_builder.query(&[("include_disk_info", &local_var_str.to_string())]);
1060        }
1061        if let Some(ref local_var_str) = pretty {
1062            local_var_req_builder =
1063                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1064        }
1065        if let Some(ref local_var_str) = human {
1066            local_var_req_builder =
1067                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1068        }
1069        if let Some(ref local_var_str) = filter_path {
1070            local_var_req_builder =
1071                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1072        }
1073        if let Some(ref local_var_str) = source {
1074            local_var_req_builder =
1075                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1076        }
1077        if let Some(ref local_var_str) = error_trace {
1078            local_var_req_builder =
1079                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1080        }
1081        if let Some(ref local_var_str) = include_yes_decisions {
1082            local_var_req_builder = local_var_req_builder
1083                .query(&[("include_yes_decisions", &local_var_str.to_string())]);
1084        }
1085
1086        local_var_req_builder = local_var_req_builder.json(&allocation_explain);
1087
1088        let local_var_req = local_var_req_builder.build()?;
1089        let local_var_resp = local_var_client.execute(local_var_req).await?;
1090
1091        let local_var_status = local_var_resp.status();
1092        let local_var_content = local_var_resp.text().await?;
1093
1094        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1095            serde_json::from_str(&local_var_content).map_err(Error::from)
1096        } else {
1097            let local_var_error = ResponseContent {
1098                status: local_var_status,
1099                content: local_var_content,
1100            };
1101            Err(Error::ApiError(local_var_error))
1102        }
1103    }
1104    ///
1105    /// Decommissions a cluster zone based on awareness. This can greatly benefit multi-zone deployments, where awareness attributes can aid in applying new upgrades to a cluster in a controlled fashion.
1106    #[builder]
1107    pub async fn put_decommission_awareness(
1108        &self,
1109        /// No description available
1110        awareness_attribute_name: String,
1111        /// No description available
1112        awareness_attribute_value: String,
1113        /// No description available
1114        error_trace: Option<bool>,
1115        /// No description available
1116        filter_path: Option<common::FilterPath>,
1117        /// No description available
1118        human: Option<bool>,
1119        /// No description available
1120        pretty: Option<bool>,
1121        /// No description available
1122        source: Option<String>,
1123    ) -> Result<crate::common::AcknowledgedResponseBase, Error> {
1124        let local_var_configuration = &self.configuration;
1125
1126        let local_var_client = &local_var_configuration.client;
1127
1128        let local_var_uri_str = format!(
1129            "{}_cluster/decommission/awareness/{awareness_attribute_name}/{awareness_attribute_value}",
1130            local_var_configuration.base_path,
1131            awareness_attribute_name = awareness_attribute_name,
1132            awareness_attribute_value = awareness_attribute_value
1133        );
1134        let mut local_var_req_builder =
1135            local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
1136
1137        if let Some(ref local_var_str) = pretty {
1138            local_var_req_builder =
1139                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1140        }
1141        if let Some(ref local_var_str) = source {
1142            local_var_req_builder =
1143                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1144        }
1145        if let Some(ref local_var_str) = filter_path {
1146            local_var_req_builder =
1147                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1148        }
1149        if let Some(ref local_var_str) = human {
1150            local_var_req_builder =
1151                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1152        }
1153        if let Some(ref local_var_str) = error_trace {
1154            local_var_req_builder =
1155                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1156        }
1157
1158        let local_var_req = local_var_req_builder.build()?;
1159        let local_var_resp = local_var_client.execute(local_var_req).await?;
1160
1161        let local_var_status = local_var_resp.status();
1162        let local_var_content = local_var_resp.text().await?;
1163
1164        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1165            serde_json::from_str(&local_var_content).map_err(Error::from)
1166        } else {
1167            let local_var_error = ResponseContent {
1168                status: local_var_status,
1169                content: local_var_content,
1170            };
1171            Err(Error::ApiError(local_var_error))
1172        }
1173    }
1174    ///
1175    /// Returns basic information about the health of the cluster.
1176    #[builder]
1177    pub async fn health(
1178        &self,
1179        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1180        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1181        cluster_manager_timeout: Option<String>,
1182        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1183        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1184        master_timeout: Option<String>,
1185        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1186        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1187        timeout: Option<String>,
1188        /// Controls the amount of detail included in the cluster health response.
1189        level: Option<String>,
1190        /// No description available
1191        error_trace: Option<bool>,
1192        /// No description available
1193        filter_path: Option<common::FilterPath>,
1194        /// No description available
1195        human: Option<bool>,
1196        /// No description available
1197        index: String,
1198        /// No description available
1199        local: Option<bool>,
1200        /// No description available
1201        pretty: Option<bool>,
1202        /// No description available
1203        source: Option<String>,
1204        /// No description available
1205        wait_for_no_initializing_shards: Option<bool>,
1206        /// No description available
1207        wait_for_no_relocating_shards: Option<bool>,
1208        /// No description available
1209        wait_for_nodes: Option<common::WaitForNodes>,
1210        /// No description available
1211        wait_for_status: Option<common::WaitForStatus>,
1212        /// Specifies the type of index that wildcard expressions can match. Supports comma-separated values.
1213        expand_wildcards: Option<common::ExpandWildcards>,
1214        /// The name of the awareness attribute for which to return the cluster health status (for example, `zone`). Applicable only if `level` is set to `awareness_attributes`.
1215        awareness_attribute: Option<String>,
1216        /// Waits until all currently queued events with the given priority are processed.
1217        wait_for_events: Option<String>,
1218        /// Waits until the specified number of shards is active before returning a response. Use `all` for all shards.
1219        wait_for_active_shards: Option<common::wait_for_active_shards::WaitForActiveShards>,
1220    ) -> Result<crate::cluster::health::HealthResponseBody, Error> {
1221        let local_var_configuration = &self.configuration;
1222
1223        let local_var_client = &local_var_configuration.client;
1224
1225        let local_var_uri_str = format!(
1226            "{}_cluster/health/{index}",
1227            local_var_configuration.base_path,
1228            index = index
1229        );
1230        let mut local_var_req_builder =
1231            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1232
1233        if let Some(ref local_var_str) = error_trace {
1234            local_var_req_builder =
1235                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1236        }
1237        if let Some(ref local_var_str) = wait_for_no_relocating_shards {
1238            local_var_req_builder = local_var_req_builder
1239                .query(&[("wait_for_no_relocating_shards", &local_var_str.to_string())]);
1240        }
1241        if let Some(ref local_var_str) = wait_for_no_initializing_shards {
1242            local_var_req_builder = local_var_req_builder.query(&[(
1243                "wait_for_no_initializing_shards",
1244                &local_var_str.to_string(),
1245            )]);
1246        }
1247        if let Some(ref local_var_str) = master_timeout {
1248            local_var_req_builder =
1249                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
1250        }
1251        if let Some(ref local_var_str) = level {
1252            local_var_req_builder =
1253                local_var_req_builder.query(&[("level", &local_var_str.to_string())]);
1254        }
1255        if let Some(ref local_var_str) = human {
1256            local_var_req_builder =
1257                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1258        }
1259        if let Some(ref local_var_str) = expand_wildcards {
1260            local_var_req_builder =
1261                local_var_req_builder.query(&[("expand_wildcards", &local_var_str.to_string())]);
1262        }
1263        if let Some(ref local_var_str) = wait_for_nodes {
1264            local_var_req_builder =
1265                local_var_req_builder.query(&[("wait_for_nodes", &local_var_str.to_string())]);
1266        }
1267        if let Some(ref local_var_str) = filter_path {
1268            local_var_req_builder =
1269                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1270        }
1271        if let Some(ref local_var_str) = wait_for_active_shards {
1272            local_var_req_builder = local_var_req_builder
1273                .query(&[("wait_for_active_shards", &local_var_str.to_string())]);
1274        }
1275        if let Some(ref local_var_str) = source {
1276            local_var_req_builder =
1277                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1278        }
1279        if let Some(ref local_var_str) = wait_for_events {
1280            local_var_req_builder =
1281                local_var_req_builder.query(&[("wait_for_events", &local_var_str.to_string())]);
1282        }
1283        if let Some(ref local_var_str) = awareness_attribute {
1284            local_var_req_builder =
1285                local_var_req_builder.query(&[("awareness_attribute", &local_var_str.to_string())]);
1286        }
1287        if let Some(ref local_var_str) = timeout {
1288            local_var_req_builder =
1289                local_var_req_builder.query(&[("timeout", &local_var_str.to_string())]);
1290        }
1291        if let Some(ref local_var_str) = pretty {
1292            local_var_req_builder =
1293                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1294        }
1295        if let Some(ref local_var_str) = cluster_manager_timeout {
1296            local_var_req_builder = local_var_req_builder
1297                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
1298        }
1299        if let Some(ref local_var_str) = local {
1300            local_var_req_builder =
1301                local_var_req_builder.query(&[("local", &local_var_str.to_string())]);
1302        }
1303        if let Some(ref local_var_str) = wait_for_status {
1304            local_var_req_builder =
1305                local_var_req_builder.query(&[("wait_for_status", &local_var_str.to_string())]);
1306        }
1307
1308        let local_var_req = local_var_req_builder.build()?;
1309        let local_var_resp = local_var_client.execute(local_var_req).await?;
1310
1311        let local_var_status = local_var_resp.status();
1312        let local_var_content = local_var_resp.text().await?;
1313
1314        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1315            serde_json::from_str(&local_var_content).map_err(Error::from)
1316        } else {
1317            let local_var_error = ResponseContent {
1318                status: local_var_status,
1319                content: local_var_content,
1320            };
1321            Err(Error::ApiError(local_var_error))
1322        }
1323    }
1324    ///
1325    /// Returns the information about configured remote clusters.
1326    #[builder]
1327    pub async fn remote_info(
1328        &self,
1329        /// No description available
1330        error_trace: Option<bool>,
1331        /// No description available
1332        filter_path: Option<common::FilterPath>,
1333        /// No description available
1334        human: Option<bool>,
1335        /// No description available
1336        pretty: Option<bool>,
1337        /// No description available
1338        source: Option<String>,
1339    ) -> Result<crate::cluster::RemoteInfoResponse, Error> {
1340        let local_var_configuration = &self.configuration;
1341
1342        let local_var_client = &local_var_configuration.client;
1343
1344        let local_var_uri_str = format!("{}_remote/info", local_var_configuration.base_path);
1345        let mut local_var_req_builder =
1346            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1347
1348        if let Some(ref local_var_str) = pretty {
1349            local_var_req_builder =
1350                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1351        }
1352        if let Some(ref local_var_str) = source {
1353            local_var_req_builder =
1354                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1355        }
1356        if let Some(ref local_var_str) = filter_path {
1357            local_var_req_builder =
1358                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1359        }
1360        if let Some(ref local_var_str) = human {
1361            local_var_req_builder =
1362                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1363        }
1364        if let Some(ref local_var_str) = error_trace {
1365            local_var_req_builder =
1366                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1367        }
1368
1369        let local_var_req = local_var_req_builder.build()?;
1370        let local_var_resp = local_var_client.execute(local_var_req).await?;
1371
1372        let local_var_status = local_var_resp.status();
1373        let local_var_content = local_var_resp.text().await?;
1374
1375        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1376            serde_json::from_str(&local_var_content).map_err(Error::from)
1377        } else {
1378            let local_var_error = ResponseContent {
1379                status: local_var_status,
1380                content: local_var_content,
1381            };
1382            Err(Error::ApiError(local_var_error))
1383        }
1384    }
1385    ///
1386    /// Returns a high-level overview of cluster statistics.
1387    #[builder]
1388    pub async fn stats(
1389        &self,
1390        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1391        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1392        timeout: Option<String>,
1393        /// No description available
1394        error_trace: Option<bool>,
1395        /// No description available
1396        filter_path: Option<common::FilterPath>,
1397        /// No description available
1398        flat_settings: Option<bool>,
1399        /// No description available
1400        human: Option<bool>,
1401        /// No description available
1402        node_id: String,
1403        /// No description available
1404        pretty: Option<bool>,
1405        /// No description available
1406        source: Option<String>,
1407    ) -> Result<String, Error> {
1408        let local_var_configuration = &self.configuration;
1409
1410        let local_var_client = &local_var_configuration.client;
1411
1412        let local_var_uri_str = format!(
1413            "{}_cluster/stats/nodes/{node_id}",
1414            local_var_configuration.base_path,
1415            node_id = node_id
1416        );
1417        let mut local_var_req_builder =
1418            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1419
1420        if let Some(ref local_var_str) = flat_settings {
1421            local_var_req_builder =
1422                local_var_req_builder.query(&[("flat_settings", &local_var_str.to_string())]);
1423        }
1424        if let Some(ref local_var_str) = timeout {
1425            local_var_req_builder =
1426                local_var_req_builder.query(&[("timeout", &local_var_str.to_string())]);
1427        }
1428        if let Some(ref local_var_str) = filter_path {
1429            local_var_req_builder =
1430                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1431        }
1432        if let Some(ref local_var_str) = error_trace {
1433            local_var_req_builder =
1434                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1435        }
1436        if let Some(ref local_var_str) = human {
1437            local_var_req_builder =
1438                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1439        }
1440        if let Some(ref local_var_str) = source {
1441            local_var_req_builder =
1442                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1443        }
1444        if let Some(ref local_var_str) = pretty {
1445            local_var_req_builder =
1446                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1447        }
1448
1449        let local_var_req = local_var_req_builder.build()?;
1450        let local_var_resp = local_var_client.execute(local_var_req).await?;
1451
1452        let local_var_status = local_var_resp.status();
1453        let local_var_content = local_var_resp.text().await?;
1454
1455        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1456            serde_json::from_str(&local_var_content).map_err(Error::from)
1457        } else {
1458            let local_var_error = ResponseContent {
1459                status: local_var_status,
1460                content: local_var_content,
1461            };
1462            Err(Error::ApiError(local_var_error))
1463        }
1464    }
1465    ///
1466    /// Updates weighted shard routing weights.
1467    #[builder]
1468    pub async fn put_weighted_routing(
1469        &self,
1470        /// No description available
1471        attribute: String,
1472        /// No description available
1473        error_trace: Option<bool>,
1474        /// No description available
1475        filter_path: Option<common::FilterPath>,
1476        /// No description available
1477        human: Option<bool>,
1478        /// No description available
1479        pretty: Option<bool>,
1480        /// No description available
1481        source: Option<String>,
1482    ) -> Result<crate::cluster::PutWeightedRoutingResponse, Error> {
1483        let local_var_configuration = &self.configuration;
1484
1485        let local_var_client = &local_var_configuration.client;
1486
1487        let local_var_uri_str = format!(
1488            "{}_cluster/routing/awareness/{attribute}/weights",
1489            local_var_configuration.base_path,
1490            attribute = attribute
1491        );
1492        let mut local_var_req_builder =
1493            local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
1494
1495        if let Some(ref local_var_str) = filter_path {
1496            local_var_req_builder =
1497                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1498        }
1499        if let Some(ref local_var_str) = pretty {
1500            local_var_req_builder =
1501                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1502        }
1503        if let Some(ref local_var_str) = error_trace {
1504            local_var_req_builder =
1505                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1506        }
1507        if let Some(ref local_var_str) = human {
1508            local_var_req_builder =
1509                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1510        }
1511        if let Some(ref local_var_str) = source {
1512            local_var_req_builder =
1513                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1514        }
1515
1516        let local_var_req = local_var_req_builder.build()?;
1517        let local_var_resp = local_var_client.execute(local_var_req).await?;
1518
1519        let local_var_status = local_var_resp.status();
1520        let local_var_content = local_var_resp.text().await?;
1521
1522        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1523            serde_json::from_str(&local_var_content).map_err(Error::from)
1524        } else {
1525            let local_var_error = ResponseContent {
1526                status: local_var_status,
1527                content: local_var_content,
1528            };
1529            Err(Error::ApiError(local_var_error))
1530        }
1531    }
1532    ///
1533    /// Creates or updates a component template.
1534    #[builder]
1535    pub async fn put_component_template(
1536        &self,
1537        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1538        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1539        cluster_manager_timeout: Option<String>,
1540        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1541        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1542        master_timeout: Option<String>,
1543        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1544        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1545        timeout: Option<String>,
1546        /// No description available
1547        create: Option<bool>,
1548        /// No description available
1549        error_trace: Option<bool>,
1550        /// No description available
1551        filter_path: Option<common::FilterPath>,
1552        /// No description available
1553        human: Option<bool>,
1554        /// No description available
1555        name: String,
1556        /// No description available
1557        pretty: Option<bool>,
1558        /// No description available
1559        source: Option<String>,
1560        /// The template definition.
1561        put_component_template: cluster::PutComponentTemplate,
1562    ) -> Result<crate::common::AcknowledgedResponseBase, Error> {
1563        let local_var_configuration = &self.configuration;
1564
1565        let local_var_client = &local_var_configuration.client;
1566
1567        let local_var_uri_str = format!(
1568            "{}_component_template/{name}",
1569            local_var_configuration.base_path,
1570            name = name
1571        );
1572        let mut local_var_req_builder =
1573            local_var_client.request(reqwest::Method::PUT, local_var_uri_str.as_str());
1574
1575        if let Some(ref local_var_str) = create {
1576            local_var_req_builder =
1577                local_var_req_builder.query(&[("create", &local_var_str.to_string())]);
1578        }
1579        if let Some(ref local_var_str) = cluster_manager_timeout {
1580            local_var_req_builder = local_var_req_builder
1581                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
1582        }
1583        if let Some(ref local_var_str) = human {
1584            local_var_req_builder =
1585                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1586        }
1587        if let Some(ref local_var_str) = error_trace {
1588            local_var_req_builder =
1589                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1590        }
1591        if let Some(ref local_var_str) = timeout {
1592            local_var_req_builder =
1593                local_var_req_builder.query(&[("timeout", &local_var_str.to_string())]);
1594        }
1595        if let Some(ref local_var_str) = pretty {
1596            local_var_req_builder =
1597                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1598        }
1599        if let Some(ref local_var_str) = master_timeout {
1600            local_var_req_builder =
1601                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
1602        }
1603        if let Some(ref local_var_str) = filter_path {
1604            local_var_req_builder =
1605                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1606        }
1607        if let Some(ref local_var_str) = source {
1608            local_var_req_builder =
1609                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1610        }
1611
1612        local_var_req_builder = local_var_req_builder.json(&put_component_template);
1613
1614        let local_var_req = local_var_req_builder.build()?;
1615        let local_var_resp = local_var_client.execute(local_var_req).await?;
1616
1617        let local_var_status = local_var_resp.status();
1618        let local_var_content = local_var_resp.text().await?;
1619
1620        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1621            serde_json::from_str(&local_var_content).map_err(Error::from)
1622        } else {
1623            let local_var_error = ResponseContent {
1624                status: local_var_status,
1625                content: local_var_content,
1626            };
1627            Err(Error::ApiError(local_var_error))
1628        }
1629    }
1630    ///
1631    /// Clears any cluster voting configuration exclusions.
1632    #[builder]
1633    pub async fn delete_voting_config_exclusions(
1634        &self,
1635        /// No description available
1636        error_trace: Option<bool>,
1637        /// No description available
1638        filter_path: Option<common::FilterPath>,
1639        /// No description available
1640        human: Option<bool>,
1641        /// No description available
1642        pretty: Option<bool>,
1643        /// No description available
1644        source: Option<String>,
1645        /// No description available
1646        wait_for_removal: Option<bool>,
1647    ) -> Result<serde_json::Value, Error> {
1648        let local_var_configuration = &self.configuration;
1649
1650        let local_var_client = &local_var_configuration.client;
1651
1652        let local_var_uri_str = format!(
1653            "{}_cluster/voting_config_exclusions",
1654            local_var_configuration.base_path
1655        );
1656        let mut local_var_req_builder =
1657            local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
1658
1659        if let Some(ref local_var_str) = pretty {
1660            local_var_req_builder =
1661                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1662        }
1663        if let Some(ref local_var_str) = error_trace {
1664            local_var_req_builder =
1665                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1666        }
1667        if let Some(ref local_var_str) = source {
1668            local_var_req_builder =
1669                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1670        }
1671        if let Some(ref local_var_str) = filter_path {
1672            local_var_req_builder =
1673                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1674        }
1675        if let Some(ref local_var_str) = wait_for_removal {
1676            local_var_req_builder =
1677                local_var_req_builder.query(&[("wait_for_removal", &local_var_str.to_string())]);
1678        }
1679        if let Some(ref local_var_str) = human {
1680            local_var_req_builder =
1681                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1682        }
1683
1684        let local_var_req = local_var_req_builder.build()?;
1685        let local_var_resp = local_var_client.execute(local_var_req).await?;
1686
1687        let local_var_status = local_var_resp.status();
1688        let local_var_content = local_var_resp.text().await?;
1689
1690        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1691            serde_json::from_str(&local_var_content).map_err(Error::from)
1692        } else {
1693            let local_var_error = ResponseContent {
1694                status: local_var_status,
1695                content: local_var_content,
1696            };
1697            Err(Error::ApiError(local_var_error))
1698        }
1699    }
1700    ///
1701    /// Returns comprehensive information about the state of the cluster.
1702    #[builder]
1703    pub async fn state(
1704        &self,
1705        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1706        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1707        cluster_manager_timeout: Option<String>,
1708        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1709        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1710        master_timeout: Option<String>,
1711        /// A duration. Units can be `nanos`, `micros`, `ms` (milliseconds), `s` (seconds), `m` (minutes), `h` (hours) and
1712        /// `d` (days). Also accepts "0" without a unit and "-1" to indicate an unspecified value.
1713        wait_for_timeout: Option<String>,
1714        /// No description available
1715        allow_no_indices: Option<bool>,
1716        /// No description available
1717        error_trace: Option<bool>,
1718        /// No description available
1719        filter_path: Option<common::FilterPath>,
1720        /// No description available
1721        flat_settings: Option<bool>,
1722        /// No description available
1723        human: Option<bool>,
1724        /// No description available
1725        ignore_unavailable: Option<bool>,
1726        /// No description available
1727        index: String,
1728        /// No description available
1729        local: Option<bool>,
1730        /// No description available
1731        metric: String,
1732        /// No description available
1733        pretty: Option<bool>,
1734        /// No description available
1735        source: Option<String>,
1736        /// No description available
1737        wait_for_metadata_version: Option<i32>,
1738        /// Specifies the type of index that wildcard expressions can match. Supports comma-separated values.
1739        expand_wildcards: Option<common::ExpandWildcards>,
1740    ) -> Result<serde_json::Value, Error> {
1741        let local_var_configuration = &self.configuration;
1742
1743        let local_var_client = &local_var_configuration.client;
1744
1745        let local_var_uri_str = format!(
1746            "{}_cluster/state/{metric}/{index}",
1747            local_var_configuration.base_path,
1748            index = index,
1749            metric = metric
1750        );
1751        let mut local_var_req_builder =
1752            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1753
1754        if let Some(ref local_var_str) = pretty {
1755            local_var_req_builder =
1756                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1757        }
1758        if let Some(ref local_var_str) = allow_no_indices {
1759            local_var_req_builder =
1760                local_var_req_builder.query(&[("allow_no_indices", &local_var_str.to_string())]);
1761        }
1762        if let Some(ref local_var_str) = local {
1763            local_var_req_builder =
1764                local_var_req_builder.query(&[("local", &local_var_str.to_string())]);
1765        }
1766        if let Some(ref local_var_str) = human {
1767            local_var_req_builder =
1768                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1769        }
1770        if let Some(ref local_var_str) = error_trace {
1771            local_var_req_builder =
1772                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1773        }
1774        if let Some(ref local_var_str) = source {
1775            local_var_req_builder =
1776                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1777        }
1778        if let Some(ref local_var_str) = filter_path {
1779            local_var_req_builder =
1780                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1781        }
1782        if let Some(ref local_var_str) = cluster_manager_timeout {
1783            local_var_req_builder = local_var_req_builder
1784                .query(&[("cluster_manager_timeout", &local_var_str.to_string())]);
1785        }
1786        if let Some(ref local_var_str) = flat_settings {
1787            local_var_req_builder =
1788                local_var_req_builder.query(&[("flat_settings", &local_var_str.to_string())]);
1789        }
1790        if let Some(ref local_var_str) = expand_wildcards {
1791            local_var_req_builder =
1792                local_var_req_builder.query(&[("expand_wildcards", &local_var_str.to_string())]);
1793        }
1794        if let Some(ref local_var_str) = wait_for_metadata_version {
1795            local_var_req_builder = local_var_req_builder
1796                .query(&[("wait_for_metadata_version", &local_var_str.to_string())]);
1797        }
1798        if let Some(ref local_var_str) = ignore_unavailable {
1799            local_var_req_builder =
1800                local_var_req_builder.query(&[("ignore_unavailable", &local_var_str.to_string())]);
1801        }
1802        if let Some(ref local_var_str) = master_timeout {
1803            local_var_req_builder =
1804                local_var_req_builder.query(&[("master_timeout", &local_var_str.to_string())]);
1805        }
1806        if let Some(ref local_var_str) = wait_for_timeout {
1807            local_var_req_builder =
1808                local_var_req_builder.query(&[("wait_for_timeout", &local_var_str.to_string())]);
1809        }
1810
1811        let local_var_req = local_var_req_builder.build()?;
1812        let local_var_resp = local_var_client.execute(local_var_req).await?;
1813
1814        let local_var_status = local_var_resp.status();
1815        let local_var_content = local_var_resp.text().await?;
1816
1817        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1818            serde_json::from_str(&local_var_content).map_err(Error::from)
1819        } else {
1820            let local_var_error = ResponseContent {
1821                status: local_var_status,
1822                content: local_var_content,
1823            };
1824            Err(Error::ApiError(local_var_error))
1825        }
1826    }
1827}
opensearch_client/cluster/cluster_api.rs

opensearch_client/cluster/
cluster_api.rs
