opensearch_client/ml/
ml_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 MlApiClient {
18    configuration: Arc<crate::Configuration>,
19}
20
21#[bon]
22impl MlApiClient {
23    pub fn new(configuration: Arc<crate::Configuration>) -> Self {
24        Self { configuration }
25    }
26
27    ///
28    /// Trains a model and predicts against the same training dataset.
29    #[builder]
30    pub async fn train_predict(
31        &self,
32        train_predict: ml::TrainPredict,
33        /// No description available
34        algorithm_name: String,
35        /// No description available
36        error_trace: Option<bool>,
37        /// No description available
38        filter_path: Option<common::FilterPath>,
39        /// No description available
40        human: Option<bool>,
41        /// No description available
42        pretty: Option<bool>,
43        /// No description available
44        source: Option<String>,
45    ) -> Result<crate::ml::TrainPredictResponse, Error> {
46        let local_var_configuration = &self.configuration;
47
48        let local_var_client = &local_var_configuration.client;
49
50        let local_var_uri_str = format!(
51            "{}_plugins/_ml/_train_predict/{algorithm_name}",
52            local_var_configuration.base_path,
53            algorithm_name = algorithm_name
54        );
55        let mut local_var_req_builder =
56            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
57
58        if let Some(ref local_var_str) = error_trace {
59            local_var_req_builder =
60                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
61        }
62        if let Some(ref local_var_str) = filter_path {
63            local_var_req_builder =
64                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
65        }
66        if let Some(ref local_var_str) = human {
67            local_var_req_builder =
68                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
69        }
70        if let Some(ref local_var_str) = pretty {
71            local_var_req_builder =
72                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
73        }
74        if let Some(ref local_var_str) = source {
75            local_var_req_builder =
76                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
77        }
78
79        local_var_req_builder = local_var_req_builder.json(&train_predict);
80
81        let local_var_req = local_var_req_builder.build()?;
82        let local_var_resp = local_var_client.execute(local_var_req).await?;
83
84        let local_var_status = local_var_resp.status();
85        let local_var_content = local_var_resp.text().await?;
86
87        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
88            serde_json::from_str(&local_var_content).map_err(Error::from)
89        } else {
90            let local_var_error = ResponseContent {
91                status: local_var_status,
92                content: local_var_content,
93            };
94            Err(Error::ApiError(local_var_error))
95        }
96    }
97    ///
98    /// Retrieves a model.
99    #[builder]
100    pub async fn get_model(
101        &self,
102        /// No description available
103        error_trace: Option<bool>,
104        /// No description available
105        filter_path: Option<common::FilterPath>,
106        /// No description available
107        human: Option<bool>,
108        /// No description available
109        model_id: String,
110        /// No description available
111        pretty: Option<bool>,
112        /// No description available
113        source: Option<String>,
114    ) -> Result<crate::ml::Model, Error> {
115        let local_var_configuration = &self.configuration;
116
117        let local_var_client = &local_var_configuration.client;
118
119        let local_var_uri_str = format!(
120            "{}_plugins/_ml/models/{model_id}",
121            local_var_configuration.base_path,
122            model_id = model_id
123        );
124        let mut local_var_req_builder =
125            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
126
127        if let Some(ref local_var_str) = source {
128            local_var_req_builder =
129                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
130        }
131        if let Some(ref local_var_str) = error_trace {
132            local_var_req_builder =
133                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
134        }
135        if let Some(ref local_var_str) = filter_path {
136            local_var_req_builder =
137                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
138        }
139        if let Some(ref local_var_str) = human {
140            local_var_req_builder =
141                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
142        }
143        if let Some(ref local_var_str) = pretty {
144            local_var_req_builder =
145                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
146        }
147
148        let local_var_req = local_var_req_builder.build()?;
149        let local_var_resp = local_var_client.execute(local_var_req).await?;
150
151        let local_var_status = local_var_resp.status();
152        let local_var_content = local_var_resp.text().await?;
153
154        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
155            serde_json::from_str(&local_var_content).map_err(Error::from)
156        } else {
157            let local_var_error = ResponseContent {
158                status: local_var_status,
159                content: local_var_content,
160            };
161            Err(Error::ApiError(local_var_error))
162        }
163    }
164    ///
165    /// Unloads a model.
166    #[builder]
167    pub async fn unload_model(
168        &self,
169        unload_model: ml::UnloadModel,
170        /// No description available
171        error_trace: Option<bool>,
172        /// No description available
173        filter_path: Option<common::FilterPath>,
174        /// No description available
175        human: Option<bool>,
176        /// No description available
177        model_id: String,
178        /// No description available
179        pretty: Option<bool>,
180        /// No description available
181        source: Option<String>,
182    ) -> Result<crate::ml::UnloadModelResponse, Error> {
183        let local_var_configuration = &self.configuration;
184
185        let local_var_client = &local_var_configuration.client;
186
187        let local_var_uri_str = format!(
188            "{}_plugins/_ml/models/{model_id}/_unload",
189            local_var_configuration.base_path,
190            model_id = model_id
191        );
192        let mut local_var_req_builder =
193            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
194
195        if let Some(ref local_var_str) = error_trace {
196            local_var_req_builder =
197                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
198        }
199        if let Some(ref local_var_str) = pretty {
200            local_var_req_builder =
201                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
202        }
203        if let Some(ref local_var_str) = human {
204            local_var_req_builder =
205                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
206        }
207        if let Some(ref local_var_str) = source {
208            local_var_req_builder =
209                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
210        }
211        if let Some(ref local_var_str) = filter_path {
212            local_var_req_builder =
213                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
214        }
215
216        local_var_req_builder = local_var_req_builder.json(&unload_model);
217
218        let local_var_req = local_var_req_builder.build()?;
219        let local_var_resp = local_var_client.execute(local_var_req).await?;
220
221        let local_var_status = local_var_resp.status();
222        let local_var_content = local_var_resp.text().await?;
223
224        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
225            serde_json::from_str(&local_var_content).map_err(Error::from)
226        } else {
227            let local_var_error = ResponseContent {
228                status: local_var_status,
229                content: local_var_content,
230            };
231            Err(Error::ApiError(local_var_error))
232        }
233    }
234    ///
235    /// Searches for tasks.
236    #[builder]
237    pub async fn search_tasks(
238        &self,
239        search_tasks: ml::SearchTasks,
240        /// No description available
241        error_trace: Option<bool>,
242        /// No description available
243        filter_path: Option<common::FilterPath>,
244        /// No description available
245        human: Option<bool>,
246        /// No description available
247        pretty: Option<bool>,
248        /// No description available
249        source: Option<String>,
250    ) -> Result<crate::ml::SearchTasksResponse, Error> {
251        let local_var_configuration = &self.configuration;
252
253        let local_var_client = &local_var_configuration.client;
254
255        let local_var_uri_str = format!(
256            "{}_plugins/_ml/tasks/_search",
257            local_var_configuration.base_path
258        );
259        let mut local_var_req_builder =
260            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
261
262        if let Some(ref local_var_str) = source {
263            local_var_req_builder =
264                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
265        }
266        if let Some(ref local_var_str) = human {
267            local_var_req_builder =
268                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
269        }
270        if let Some(ref local_var_str) = pretty {
271            local_var_req_builder =
272                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
273        }
274        if let Some(ref local_var_str) = error_trace {
275            local_var_req_builder =
276                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
277        }
278        if let Some(ref local_var_str) = filter_path {
279            local_var_req_builder =
280                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
281        }
282
283        local_var_req_builder = local_var_req_builder.json(&search_tasks);
284
285        let local_var_req = local_var_req_builder.build()?;
286        let local_var_resp = local_var_client.execute(local_var_req).await?;
287
288        let local_var_status = local_var_resp.status();
289        let local_var_content = local_var_resp.text().await?;
290
291        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
292            serde_json::from_str(&local_var_content).map_err(Error::from)
293        } else {
294            let local_var_error = ResponseContent {
295                status: local_var_status,
296                content: local_var_content,
297            };
298            Err(Error::ApiError(local_var_error))
299        }
300    }
301    ///
302    /// Creates a standalone connector.
303    #[builder]
304    pub async fn create_connector(
305        &self,
306        create_connector: ml::CreateConnector,
307        /// No description available
308        error_trace: Option<bool>,
309        /// No description available
310        filter_path: Option<common::FilterPath>,
311        /// No description available
312        human: Option<bool>,
313        /// No description available
314        pretty: Option<bool>,
315        /// No description available
316        source: Option<String>,
317    ) -> Result<crate::ml::CreateConnectorResponse, Error> {
318        let local_var_configuration = &self.configuration;
319
320        let local_var_client = &local_var_configuration.client;
321
322        let local_var_uri_str = format!(
323            "{}_plugins/_ml/connectors/_create",
324            local_var_configuration.base_path
325        );
326        let mut local_var_req_builder =
327            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
328
329        if let Some(ref local_var_str) = error_trace {
330            local_var_req_builder =
331                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
332        }
333        if let Some(ref local_var_str) = filter_path {
334            local_var_req_builder =
335                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
336        }
337        if let Some(ref local_var_str) = pretty {
338            local_var_req_builder =
339                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
340        }
341        if let Some(ref local_var_str) = source {
342            local_var_req_builder =
343                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
344        }
345        if let Some(ref local_var_str) = human {
346            local_var_req_builder =
347                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
348        }
349
350        local_var_req_builder = local_var_req_builder.json(&create_connector);
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    /// Get stats.
370    #[builder]
371    pub async fn get_stats(
372        &self,
373        /// No description available
374        error_trace: Option<bool>,
375        /// No description available
376        filter_path: Option<common::FilterPath>,
377        /// No description available
378        human: Option<bool>,
379        /// No description available
380        node_id: String,
381        /// No description available
382        pretty: Option<bool>,
383        /// No description available
384        source: Option<String>,
385        /// No description available
386        stat: String,
387    ) -> Result<crate::ml::GetStatsResponse, Error> {
388        let local_var_configuration = &self.configuration;
389
390        let local_var_client = &local_var_configuration.client;
391
392        let local_var_uri_str = format!(
393            "{}_plugins/_ml/{node_id}/stats/{stat}",
394            local_var_configuration.base_path,
395            node_id = node_id,
396            stat = stat
397        );
398        let mut local_var_req_builder =
399            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
400
401        if let Some(ref local_var_str) = error_trace {
402            local_var_req_builder =
403                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
404        }
405        if let Some(ref local_var_str) = source {
406            local_var_req_builder =
407                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
408        }
409        if let Some(ref local_var_str) = filter_path {
410            local_var_req_builder =
411                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
412        }
413        if let Some(ref local_var_str) = pretty {
414            local_var_req_builder =
415                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
416        }
417        if let Some(ref local_var_str) = human {
418            local_var_req_builder =
419                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
420        }
421
422        let local_var_req = local_var_req_builder.build()?;
423        let local_var_resp = local_var_client.execute(local_var_req).await?;
424
425        let local_var_status = local_var_resp.status();
426        let local_var_content = local_var_resp.text().await?;
427
428        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
429            serde_json::from_str(&local_var_content).map_err(Error::from)
430        } else {
431            let local_var_error = ResponseContent {
432                status: local_var_status,
433                content: local_var_content,
434            };
435            Err(Error::ApiError(local_var_error))
436        }
437    }
438    ///
439    /// Retrieves a task.
440    #[builder]
441    pub async fn get_task(
442        &self,
443        /// No description available
444        error_trace: Option<bool>,
445        /// No description available
446        filter_path: Option<common::FilterPath>,
447        /// No description available
448        human: Option<bool>,
449        /// No description available
450        pretty: Option<bool>,
451        /// No description available
452        source: Option<String>,
453        /// No description available
454        task_id: String,
455    ) -> Result<crate::ml::Task, Error> {
456        let local_var_configuration = &self.configuration;
457
458        let local_var_client = &local_var_configuration.client;
459
460        let local_var_uri_str = format!(
461            "{}_plugins/_ml/tasks/{task_id}",
462            local_var_configuration.base_path,
463            task_id = task_id
464        );
465        let mut local_var_req_builder =
466            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
467
468        if let Some(ref local_var_str) = source {
469            local_var_req_builder =
470                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
471        }
472        if let Some(ref local_var_str) = human {
473            local_var_req_builder =
474                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
475        }
476        if let Some(ref local_var_str) = filter_path {
477            local_var_req_builder =
478                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
479        }
480        if let Some(ref local_var_str) = pretty {
481            local_var_req_builder =
482                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
483        }
484        if let Some(ref local_var_str) = error_trace {
485            local_var_req_builder =
486                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
487        }
488
489        let local_var_req = local_var_req_builder.build()?;
490        let local_var_resp = local_var_client.execute(local_var_req).await?;
491
492        let local_var_status = local_var_resp.status();
493        let local_var_content = local_var_resp.text().await?;
494
495        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
496            serde_json::from_str(&local_var_content).map_err(Error::from)
497        } else {
498            let local_var_error = ResponseContent {
499                status: local_var_status,
500                content: local_var_content,
501            };
502            Err(Error::ApiError(local_var_error))
503        }
504    }
505    ///
506    /// Trains a model synchronously.
507    #[builder]
508    pub async fn train(
509        &self,
510        train: ml::Train,
511        /// No description available
512        algorithm_name: String,
513        /// No description available
514        error_trace: Option<bool>,
515        /// No description available
516        filter_path: Option<common::FilterPath>,
517        /// No description available
518        human: Option<bool>,
519        /// No description available
520        pretty: Option<bool>,
521        /// No description available
522        source: Option<String>,
523    ) -> Result<crate::ml::TrainResponse, Error> {
524        let local_var_configuration = &self.configuration;
525
526        let local_var_client = &local_var_configuration.client;
527
528        let local_var_uri_str = format!(
529            "{}_plugins/_ml/_train/{algorithm_name}",
530            local_var_configuration.base_path,
531            algorithm_name = algorithm_name
532        );
533        let mut local_var_req_builder =
534            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
535
536        if let Some(ref local_var_str) = pretty {
537            local_var_req_builder =
538                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
539        }
540        if let Some(ref local_var_str) = error_trace {
541            local_var_req_builder =
542                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
543        }
544        if let Some(ref local_var_str) = human {
545            local_var_req_builder =
546                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
547        }
548        if let Some(ref local_var_str) = filter_path {
549            local_var_req_builder =
550                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
551        }
552        if let Some(ref local_var_str) = source {
553            local_var_req_builder =
554                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
555        }
556
557        local_var_req_builder = local_var_req_builder.json(&train);
558
559        let local_var_req = local_var_req_builder.build()?;
560        let local_var_resp = local_var_client.execute(local_var_req).await?;
561
562        let local_var_status = local_var_resp.status();
563        let local_var_content = local_var_resp.text().await?;
564
565        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
566            serde_json::from_str(&local_var_content).map_err(Error::from)
567        } else {
568            let local_var_error = ResponseContent {
569                status: local_var_status,
570                content: local_var_content,
571            };
572            Err(Error::ApiError(local_var_error))
573        }
574    }
575    ///
576    /// Deletes a model.
577    #[builder]
578    pub async fn delete_model(
579        &self,
580        /// No description available
581        error_trace: Option<bool>,
582        /// No description available
583        filter_path: Option<common::FilterPath>,
584        /// No description available
585        human: Option<bool>,
586        /// No description available
587        model_id: String,
588        /// No description available
589        pretty: Option<bool>,
590        /// No description available
591        source: Option<String>,
592    ) -> Result<crate::common::WriteResponseBase, Error> {
593        let local_var_configuration = &self.configuration;
594
595        let local_var_client = &local_var_configuration.client;
596
597        let local_var_uri_str = format!(
598            "{}_plugins/_ml/models/{model_id}",
599            local_var_configuration.base_path,
600            model_id = model_id
601        );
602        let mut local_var_req_builder =
603            local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
604
605        if let Some(ref local_var_str) = error_trace {
606            local_var_req_builder =
607                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
608        }
609        if let Some(ref local_var_str) = pretty {
610            local_var_req_builder =
611                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
612        }
613        if let Some(ref local_var_str) = human {
614            local_var_req_builder =
615                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
616        }
617        if let Some(ref local_var_str) = source {
618            local_var_req_builder =
619                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
620        }
621        if let Some(ref local_var_str) = filter_path {
622            local_var_req_builder =
623                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
624        }
625
626        let local_var_req = local_var_req_builder.build()?;
627        let local_var_resp = local_var_client.execute(local_var_req).await?;
628
629        let local_var_status = local_var_resp.status();
630        let local_var_content = local_var_resp.text().await?;
631
632        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
633            serde_json::from_str(&local_var_content).map_err(Error::from)
634        } else {
635            let local_var_error = ResponseContent {
636                status: local_var_status,
637                content: local_var_content,
638            };
639            Err(Error::ApiError(local_var_error))
640        }
641    }
642    ///
643    /// Registers a model group.
644    #[builder]
645    pub async fn register_model_group(
646        &self,
647        register_model_group: ml::RegisterModelGroup,
648        /// No description available
649        error_trace: Option<bool>,
650        /// No description available
651        filter_path: Option<common::FilterPath>,
652        /// No description available
653        human: Option<bool>,
654        /// No description available
655        pretty: Option<bool>,
656        /// No description available
657        source: Option<String>,
658    ) -> Result<crate::ml::ModelGroupRegistration, Error> {
659        let local_var_configuration = &self.configuration;
660
661        let local_var_client = &local_var_configuration.client;
662
663        let local_var_uri_str = format!(
664            "{}_plugins/_ml/model_groups/_register",
665            local_var_configuration.base_path
666        );
667        let mut local_var_req_builder =
668            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
669
670        if let Some(ref local_var_str) = human {
671            local_var_req_builder =
672                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
673        }
674        if let Some(ref local_var_str) = pretty {
675            local_var_req_builder =
676                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
677        }
678        if let Some(ref local_var_str) = error_trace {
679            local_var_req_builder =
680                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
681        }
682        if let Some(ref local_var_str) = source {
683            local_var_req_builder =
684                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
685        }
686        if let Some(ref local_var_str) = filter_path {
687            local_var_req_builder =
688                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
689        }
690
691        local_var_req_builder = local_var_req_builder.json(&register_model_group);
692
693        let local_var_req = local_var_req_builder.build()?;
694        let local_var_resp = local_var_client.execute(local_var_req).await?;
695
696        let local_var_status = local_var_resp.status();
697        let local_var_content = local_var_resp.text().await?;
698
699        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
700            serde_json::from_str(&local_var_content).map_err(Error::from)
701        } else {
702            let local_var_error = ResponseContent {
703                status: local_var_status,
704                content: local_var_content,
705            };
706            Err(Error::ApiError(local_var_error))
707        }
708    }
709    ///
710    /// Execute an algorithm.
711    #[builder]
712    pub async fn execute_algorithm(
713        &self,
714        execute_algorithm: ml::ExecuteAlgorithm,
715        /// No description available
716        algorithm_name: String,
717        /// No description available
718        error_trace: Option<bool>,
719        /// No description available
720        filter_path: Option<common::FilterPath>,
721        /// No description available
722        human: Option<bool>,
723        /// No description available
724        pretty: Option<bool>,
725        /// No description available
726        source: Option<String>,
727    ) -> Result<crate::ml::ExecuteAlgorithmResponse, Error> {
728        let local_var_configuration = &self.configuration;
729
730        let local_var_client = &local_var_configuration.client;
731
732        let local_var_uri_str = format!(
733            "{}_plugins/_ml/_execute/{algorithm_name}",
734            local_var_configuration.base_path,
735            algorithm_name = algorithm_name
736        );
737        let mut local_var_req_builder =
738            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
739
740        if let Some(ref local_var_str) = human {
741            local_var_req_builder =
742                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
743        }
744        if let Some(ref local_var_str) = source {
745            local_var_req_builder =
746                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
747        }
748        if let Some(ref local_var_str) = error_trace {
749            local_var_req_builder =
750                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
751        }
752        if let Some(ref local_var_str) = filter_path {
753            local_var_req_builder =
754                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
755        }
756        if let Some(ref local_var_str) = pretty {
757            local_var_req_builder =
758                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
759        }
760
761        local_var_req_builder = local_var_req_builder.json(&execute_algorithm);
762
763        let local_var_req = local_var_req_builder.build()?;
764        let local_var_resp = local_var_client.execute(local_var_req).await?;
765
766        let local_var_status = local_var_resp.status();
767        let local_var_content = local_var_resp.text().await?;
768
769        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
770            serde_json::from_str(&local_var_content).map_err(Error::from)
771        } else {
772            let local_var_error = ResponseContent {
773                status: local_var_status,
774                content: local_var_content,
775            };
776            Err(Error::ApiError(local_var_error))
777        }
778    }
779    ///
780    /// Predicts new data with trained model.
781    #[builder]
782    pub async fn predict(
783        &self,
784        predict: ml::Predict,
785        /// No description available
786        algorithm_name: String,
787        /// No description available
788        error_trace: Option<bool>,
789        /// No description available
790        filter_path: Option<common::FilterPath>,
791        /// No description available
792        human: Option<bool>,
793        /// No description available
794        model_id: String,
795        /// No description available
796        pretty: Option<bool>,
797        /// No description available
798        source: Option<String>,
799    ) -> Result<crate::ml::PredictResponse, Error> {
800        let local_var_configuration = &self.configuration;
801
802        let local_var_client = &local_var_configuration.client;
803
804        let local_var_uri_str = format!(
805            "{}_plugins/_ml/_predict/{algorithm_name}/{model_id}",
806            local_var_configuration.base_path,
807            model_id = model_id,
808            algorithm_name = algorithm_name
809        );
810        let mut local_var_req_builder =
811            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
812
813        if let Some(ref local_var_str) = source {
814            local_var_req_builder =
815                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
816        }
817        if let Some(ref local_var_str) = human {
818            local_var_req_builder =
819                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
820        }
821        if let Some(ref local_var_str) = error_trace {
822            local_var_req_builder =
823                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
824        }
825        if let Some(ref local_var_str) = pretty {
826            local_var_req_builder =
827                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
828        }
829        if let Some(ref local_var_str) = filter_path {
830            local_var_req_builder =
831                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
832        }
833
834        local_var_req_builder = local_var_req_builder.json(&predict);
835
836        let local_var_req = local_var_req_builder.build()?;
837        let local_var_resp = local_var_client.execute(local_var_req).await?;
838
839        let local_var_status = local_var_resp.status();
840        let local_var_content = local_var_resp.text().await?;
841
842        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
843            serde_json::from_str(&local_var_content).map_err(Error::from)
844        } else {
845            let local_var_error = ResponseContent {
846                status: local_var_status,
847                content: local_var_content,
848            };
849            Err(Error::ApiError(local_var_error))
850        }
851    }
852    ///
853    /// Deletes a model group.
854    #[builder]
855    pub async fn delete_model_group(
856        &self,
857        /// No description available
858        error_trace: Option<bool>,
859        /// No description available
860        filter_path: Option<common::FilterPath>,
861        /// No description available
862        human: Option<bool>,
863        /// No description available
864        model_group_id: String,
865        /// No description available
866        pretty: Option<bool>,
867        /// No description available
868        source: Option<String>,
869    ) -> Result<crate::common::WriteResponseBase, Error> {
870        let local_var_configuration = &self.configuration;
871
872        let local_var_client = &local_var_configuration.client;
873
874        let local_var_uri_str = format!(
875            "{}_plugins/_ml/model_groups/{model_group_id}",
876            local_var_configuration.base_path,
877            model_group_id = model_group_id
878        );
879        let mut local_var_req_builder =
880            local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
881
882        if let Some(ref local_var_str) = pretty {
883            local_var_req_builder =
884                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
885        }
886        if let Some(ref local_var_str) = human {
887            local_var_req_builder =
888                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
889        }
890        if let Some(ref local_var_str) = error_trace {
891            local_var_req_builder =
892                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
893        }
894        if let Some(ref local_var_str) = source {
895            local_var_req_builder =
896                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
897        }
898        if let Some(ref local_var_str) = filter_path {
899            local_var_req_builder =
900                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
901        }
902
903        let local_var_req = local_var_req_builder.build()?;
904        let local_var_resp = local_var_client.execute(local_var_req).await?;
905
906        let local_var_status = local_var_resp.status();
907        let local_var_content = local_var_resp.text().await?;
908
909        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
910            serde_json::from_str(&local_var_content).map_err(Error::from)
911        } else {
912            let local_var_error = ResponseContent {
913                status: local_var_status,
914                content: local_var_content,
915            };
916            Err(Error::ApiError(local_var_error))
917        }
918    }
919    ///
920    /// Registers a model.
921    #[builder]
922    pub async fn upload_model(
923        &self,
924        upload_model: ml::UploadModel,
925        /// No description available
926        error_trace: Option<bool>,
927        /// No description available
928        filter_path: Option<common::FilterPath>,
929        /// No description available
930        human: Option<bool>,
931        /// No description available
932        pretty: Option<bool>,
933        /// No description available
934        source: Option<String>,
935    ) -> Result<crate::ml::UploadModelResponse, Error> {
936        let local_var_configuration = &self.configuration;
937
938        let local_var_client = &local_var_configuration.client;
939
940        let local_var_uri_str = format!(
941            "{}_plugins/_ml/models/_upload",
942            local_var_configuration.base_path
943        );
944        let mut local_var_req_builder =
945            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
946
947        if let Some(ref local_var_str) = human {
948            local_var_req_builder =
949                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
950        }
951        if let Some(ref local_var_str) = pretty {
952            local_var_req_builder =
953                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
954        }
955        if let Some(ref local_var_str) = source {
956            local_var_req_builder =
957                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
958        }
959        if let Some(ref local_var_str) = filter_path {
960            local_var_req_builder =
961                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
962        }
963        if let Some(ref local_var_str) = error_trace {
964            local_var_req_builder =
965                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
966        }
967
968        local_var_req_builder = local_var_req_builder.json(&upload_model);
969
970        let local_var_req = local_var_req_builder.build()?;
971        let local_var_resp = local_var_client.execute(local_var_req).await?;
972
973        let local_var_status = local_var_resp.status();
974        let local_var_content = local_var_resp.text().await?;
975
976        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
977            serde_json::from_str(&local_var_content).map_err(Error::from)
978        } else {
979            let local_var_error = ResponseContent {
980                status: local_var_status,
981                content: local_var_content,
982            };
983            Err(Error::ApiError(local_var_error))
984        }
985    }
986    ///
987    /// Uploads model chunk.
988    #[builder]
989    pub async fn chunk_model(
990        &self,
991        chunk_model: ml::ChunkModel,
992        /// No description available
993        chunk_number: String,
994        /// No description available
995        error_trace: Option<bool>,
996        /// No description available
997        filter_path: Option<common::FilterPath>,
998        /// No description available
999        human: Option<bool>,
1000        /// No description available
1001        model_id: String,
1002        /// No description available
1003        pretty: Option<bool>,
1004        /// No description available
1005        source: Option<String>,
1006    ) -> Result<crate::ml::ChunkModelResponse, Error> {
1007        let local_var_configuration = &self.configuration;
1008
1009        let local_var_client = &local_var_configuration.client;
1010
1011        let local_var_uri_str = format!(
1012            "{}_plugins/_ml/models/{model_id}/chunk/{chunk_number}",
1013            local_var_configuration.base_path,
1014            chunk_number = chunk_number,
1015            model_id = model_id
1016        );
1017        let mut local_var_req_builder =
1018            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1019
1020        if let Some(ref local_var_str) = human {
1021            local_var_req_builder =
1022                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1023        }
1024        if let Some(ref local_var_str) = filter_path {
1025            local_var_req_builder =
1026                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1027        }
1028        if let Some(ref local_var_str) = pretty {
1029            local_var_req_builder =
1030                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1031        }
1032        if let Some(ref local_var_str) = source {
1033            local_var_req_builder =
1034                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1035        }
1036        if let Some(ref local_var_str) = error_trace {
1037            local_var_req_builder =
1038                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1039        }
1040
1041        local_var_req_builder = local_var_req_builder.json(&chunk_model);
1042
1043        let local_var_req = local_var_req_builder.build()?;
1044        let local_var_resp = local_var_client.execute(local_var_req).await?;
1045
1046        let local_var_status = local_var_resp.status();
1047        let local_var_content = local_var_resp.text().await?;
1048
1049        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1050            serde_json::from_str(&local_var_content).map_err(Error::from)
1051        } else {
1052            let local_var_error = ResponseContent {
1053                status: local_var_status,
1054                content: local_var_content,
1055            };
1056            Err(Error::ApiError(local_var_error))
1057        }
1058    }
1059    ///
1060    /// Retrieves a model group.
1061    #[builder]
1062    pub async fn get_model_group(
1063        &self,
1064        /// No description available
1065        error_trace: Option<bool>,
1066        /// No description available
1067        filter_path: Option<common::FilterPath>,
1068        /// No description available
1069        human: Option<bool>,
1070        /// No description available
1071        model_group_id: String,
1072        /// No description available
1073        pretty: Option<bool>,
1074        /// No description available
1075        source: Option<String>,
1076    ) -> Result<crate::ml::ModelGroup, Error> {
1077        let local_var_configuration = &self.configuration;
1078
1079        let local_var_client = &local_var_configuration.client;
1080
1081        let local_var_uri_str = format!(
1082            "{}_plugins/_ml/model_groups/{model_group_id}",
1083            local_var_configuration.base_path,
1084            model_group_id = model_group_id
1085        );
1086        let mut local_var_req_builder =
1087            local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
1088
1089        if let Some(ref local_var_str) = source {
1090            local_var_req_builder =
1091                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1092        }
1093        if let Some(ref local_var_str) = filter_path {
1094            local_var_req_builder =
1095                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1096        }
1097        if let Some(ref local_var_str) = pretty {
1098            local_var_req_builder =
1099                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1100        }
1101        if let Some(ref local_var_str) = error_trace {
1102            local_var_req_builder =
1103                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1104        }
1105        if let Some(ref local_var_str) = human {
1106            local_var_req_builder =
1107                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1108        }
1109
1110        let local_var_req = local_var_req_builder.build()?;
1111        let local_var_resp = local_var_client.execute(local_var_req).await?;
1112
1113        let local_var_status = local_var_resp.status();
1114        let local_var_content = local_var_resp.text().await?;
1115
1116        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1117            serde_json::from_str(&local_var_content).map_err(Error::from)
1118        } else {
1119            let local_var_error = ResponseContent {
1120                status: local_var_status,
1121                content: local_var_content,
1122            };
1123            Err(Error::ApiError(local_var_error))
1124        }
1125    }
1126    ///
1127    /// Registers model metadata.
1128    #[builder]
1129    pub async fn create_model_meta(
1130        &self,
1131        create_model_meta: ml::CreateModelMeta,
1132        /// No description available
1133        error_trace: Option<bool>,
1134        /// No description available
1135        filter_path: Option<common::FilterPath>,
1136        /// No description available
1137        human: Option<bool>,
1138        /// No description available
1139        pretty: Option<bool>,
1140        /// No description available
1141        source: Option<String>,
1142    ) -> Result<crate::ml::CreateModelMetaResponse, Error> {
1143        let local_var_configuration = &self.configuration;
1144
1145        let local_var_client = &local_var_configuration.client;
1146
1147        let local_var_uri_str = format!(
1148            "{}_plugins/_ml/models/meta",
1149            local_var_configuration.base_path
1150        );
1151        let mut local_var_req_builder =
1152            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1153
1154        if let Some(ref local_var_str) = filter_path {
1155            local_var_req_builder =
1156                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1157        }
1158        if let Some(ref local_var_str) = error_trace {
1159            local_var_req_builder =
1160                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1161        }
1162        if let Some(ref local_var_str) = pretty {
1163            local_var_req_builder =
1164                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1165        }
1166        if let Some(ref local_var_str) = human {
1167            local_var_req_builder =
1168                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1169        }
1170        if let Some(ref local_var_str) = source {
1171            local_var_req_builder =
1172                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1173        }
1174
1175        local_var_req_builder = local_var_req_builder.json(&create_model_meta);
1176
1177        let local_var_req = local_var_req_builder.build()?;
1178        let local_var_resp = local_var_client.execute(local_var_req).await?;
1179
1180        let local_var_status = local_var_resp.status();
1181        let local_var_content = local_var_resp.text().await?;
1182
1183        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1184            serde_json::from_str(&local_var_content).map_err(Error::from)
1185        } else {
1186            let local_var_error = ResponseContent {
1187                status: local_var_status,
1188                content: local_var_content,
1189            };
1190            Err(Error::ApiError(local_var_error))
1191        }
1192    }
1193    ///
1194    /// Searches for models.
1195    #[builder]
1196    pub async fn search_models(
1197        &self,
1198        search_models: ml::SearchModels,
1199        /// No description available
1200        error_trace: Option<bool>,
1201        /// No description available
1202        filter_path: Option<common::FilterPath>,
1203        /// No description available
1204        human: Option<bool>,
1205        /// No description available
1206        pretty: Option<bool>,
1207        /// No description available
1208        source: Option<String>,
1209    ) -> Result<crate::ml::SearchModelsResponse, Error> {
1210        let local_var_configuration = &self.configuration;
1211
1212        let local_var_client = &local_var_configuration.client;
1213
1214        let local_var_uri_str = format!(
1215            "{}_plugins/_ml/models/_search",
1216            local_var_configuration.base_path
1217        );
1218        let mut local_var_req_builder =
1219            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1220
1221        if let Some(ref local_var_str) = filter_path {
1222            local_var_req_builder =
1223                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1224        }
1225        if let Some(ref local_var_str) = error_trace {
1226            local_var_req_builder =
1227                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1228        }
1229        if let Some(ref local_var_str) = pretty {
1230            local_var_req_builder =
1231                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1232        }
1233        if let Some(ref local_var_str) = human {
1234            local_var_req_builder =
1235                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1236        }
1237        if let Some(ref local_var_str) = source {
1238            local_var_req_builder =
1239                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1240        }
1241
1242        local_var_req_builder = local_var_req_builder.json(&search_models);
1243
1244        let local_var_req = local_var_req_builder.build()?;
1245        let local_var_resp = local_var_client.execute(local_var_req).await?;
1246
1247        let local_var_status = local_var_resp.status();
1248        let local_var_content = local_var_resp.text().await?;
1249
1250        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1251            serde_json::from_str(&local_var_content).map_err(Error::from)
1252        } else {
1253            let local_var_error = ResponseContent {
1254                status: local_var_status,
1255                content: local_var_content,
1256            };
1257            Err(Error::ApiError(local_var_error))
1258        }
1259    }
1260    ///
1261    /// Deploys a model.
1262    #[builder]
1263    pub async fn load_model(
1264        &self,
1265        /// No description available
1266        error_trace: Option<bool>,
1267        /// No description available
1268        filter_path: Option<common::FilterPath>,
1269        /// No description available
1270        human: Option<bool>,
1271        /// No description available
1272        model_id: String,
1273        /// No description available
1274        pretty: Option<bool>,
1275        /// No description available
1276        source: Option<String>,
1277    ) -> Result<crate::ml::LoadModelResponse, Error> {
1278        let local_var_configuration = &self.configuration;
1279
1280        let local_var_client = &local_var_configuration.client;
1281
1282        let local_var_uri_str = format!(
1283            "{}_plugins/_ml/models/{model_id}/_load",
1284            local_var_configuration.base_path,
1285            model_id = model_id
1286        );
1287        let mut local_var_req_builder =
1288            local_var_client.request(reqwest::Method::POST, local_var_uri_str.as_str());
1289
1290        if let Some(ref local_var_str) = error_trace {
1291            local_var_req_builder =
1292                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1293        }
1294        if let Some(ref local_var_str) = filter_path {
1295            local_var_req_builder =
1296                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1297        }
1298        if let Some(ref local_var_str) = pretty {
1299            local_var_req_builder =
1300                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1301        }
1302        if let Some(ref local_var_str) = human {
1303            local_var_req_builder =
1304                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1305        }
1306        if let Some(ref local_var_str) = source {
1307            local_var_req_builder =
1308                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1309        }
1310
1311        let local_var_req = local_var_req_builder.build()?;
1312        let local_var_resp = local_var_client.execute(local_var_req).await?;
1313
1314        let local_var_status = local_var_resp.status();
1315        let local_var_content = local_var_resp.text().await?;
1316
1317        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1318            serde_json::from_str(&local_var_content).map_err(Error::from)
1319        } else {
1320            let local_var_error = ResponseContent {
1321                status: local_var_status,
1322                content: local_var_content,
1323            };
1324            Err(Error::ApiError(local_var_error))
1325        }
1326    }
1327    ///
1328    /// Deletes a task.
1329    #[builder]
1330    pub async fn delete_task(
1331        &self,
1332        /// No description available
1333        error_trace: Option<bool>,
1334        /// No description available
1335        filter_path: Option<common::FilterPath>,
1336        /// No description available
1337        human: Option<bool>,
1338        /// No description available
1339        pretty: Option<bool>,
1340        /// No description available
1341        source: Option<String>,
1342        /// No description available
1343        task_id: String,
1344    ) -> Result<crate::common::WriteResponseBase, Error> {
1345        let local_var_configuration = &self.configuration;
1346
1347        let local_var_client = &local_var_configuration.client;
1348
1349        let local_var_uri_str = format!(
1350            "{}_plugins/_ml/tasks/{task_id}",
1351            local_var_configuration.base_path,
1352            task_id = task_id
1353        );
1354        let mut local_var_req_builder =
1355            local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
1356
1357        if let Some(ref local_var_str) = source {
1358            local_var_req_builder =
1359                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1360        }
1361        if let Some(ref local_var_str) = human {
1362            local_var_req_builder =
1363                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1364        }
1365        if let Some(ref local_var_str) = filter_path {
1366            local_var_req_builder =
1367                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1368        }
1369        if let Some(ref local_var_str) = error_trace {
1370            local_var_req_builder =
1371                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1372        }
1373        if let Some(ref local_var_str) = pretty {
1374            local_var_req_builder =
1375                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1376        }
1377
1378        let local_var_req = local_var_req_builder.build()?;
1379        let local_var_resp = local_var_client.execute(local_var_req).await?;
1380
1381        let local_var_status = local_var_resp.status();
1382        let local_var_content = local_var_resp.text().await?;
1383
1384        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1385            serde_json::from_str(&local_var_content).map_err(Error::from)
1386        } else {
1387            let local_var_error = ResponseContent {
1388                status: local_var_status,
1389                content: local_var_content,
1390            };
1391            Err(Error::ApiError(local_var_error))
1392        }
1393    }
1394    ///
1395    /// Deletes a standalone connector.
1396    #[builder]
1397    pub async fn delete_connector(
1398        &self,
1399        /// No description available
1400        connector_id: String,
1401        /// No description available
1402        error_trace: Option<bool>,
1403        /// No description available
1404        filter_path: Option<common::FilterPath>,
1405        /// No description available
1406        human: Option<bool>,
1407        /// No description available
1408        pretty: Option<bool>,
1409        /// No description available
1410        source: Option<String>,
1411    ) -> Result<crate::common::WriteResponseBase, Error> {
1412        let local_var_configuration = &self.configuration;
1413
1414        let local_var_client = &local_var_configuration.client;
1415
1416        let local_var_uri_str = format!(
1417            "{}_plugins/_ml/connectors/{connector_id}",
1418            local_var_configuration.base_path,
1419            connector_id = connector_id
1420        );
1421        let mut local_var_req_builder =
1422            local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
1423
1424        if let Some(ref local_var_str) = error_trace {
1425            local_var_req_builder =
1426                local_var_req_builder.query(&[("error_trace", &local_var_str.to_string())]);
1427        }
1428        if let Some(ref local_var_str) = pretty {
1429            local_var_req_builder =
1430                local_var_req_builder.query(&[("pretty", &local_var_str.to_string())]);
1431        }
1432        if let Some(ref local_var_str) = source {
1433            local_var_req_builder =
1434                local_var_req_builder.query(&[("source", &local_var_str.to_string())]);
1435        }
1436        if let Some(ref local_var_str) = filter_path {
1437            local_var_req_builder =
1438                local_var_req_builder.query(&[("filter_path", &local_var_str.to_string())]);
1439        }
1440        if let Some(ref local_var_str) = human {
1441            local_var_req_builder =
1442                local_var_req_builder.query(&[("human", &local_var_str.to_string())]);
1443        }
1444
1445        let local_var_req = local_var_req_builder.build()?;
1446        let local_var_resp = local_var_client.execute(local_var_req).await?;
1447
1448        let local_var_status = local_var_resp.status();
1449        let local_var_content = local_var_resp.text().await?;
1450
1451        if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
1452            serde_json::from_str(&local_var_content).map_err(Error::from)
1453        } else {
1454            let local_var_error = ResponseContent {
1455                status: local_var_status,
1456                content: local_var_content,
1457            };
1458            Err(Error::ApiError(local_var_error))
1459        }
1460    }
1461}
opensearch_client/ml/ml_api.rs

opensearch_client/ml/
ml_api.rs
