windmill_api/apis/
index_search_api.rs

1/*
2 * Windmill API
3 *
4 * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator)
5 *
6 * The version of the OpenAPI document: 1.654.0
7 * Contact: contact@windmill.dev
8 * Generated by: https://openapi-generator.tech
9 */
10
11
12use reqwest;
13use serde::{Deserialize, Serialize};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration};
16
17
18/// struct for typed errors of method [`clear_index`]
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum ClearIndexError {
22    UnknownValue(serde_json::Value),
23}
24
25/// struct for typed errors of method [`count_search_logs_index`]
26#[derive(Debug, Clone, Serialize, Deserialize)]
27#[serde(untagged)]
28pub enum CountSearchLogsIndexError {
29    UnknownValue(serde_json::Value),
30}
31
32/// struct for typed errors of method [`get_index_storage_sizes`]
33#[derive(Debug, Clone, Serialize, Deserialize)]
34#[serde(untagged)]
35pub enum GetIndexStorageSizesError {
36    UnknownValue(serde_json::Value),
37}
38
39/// struct for typed errors of method [`get_indexer_status`]
40#[derive(Debug, Clone, Serialize, Deserialize)]
41#[serde(untagged)]
42pub enum GetIndexerStatusError {
43    UnknownValue(serde_json::Value),
44}
45
46/// struct for typed errors of method [`search_jobs_index`]
47#[derive(Debug, Clone, Serialize, Deserialize)]
48#[serde(untagged)]
49pub enum SearchJobsIndexError {
50    UnknownValue(serde_json::Value),
51}
52
53/// struct for typed errors of method [`search_logs_index`]
54#[derive(Debug, Clone, Serialize, Deserialize)]
55#[serde(untagged)]
56pub enum SearchLogsIndexError {
57    UnknownValue(serde_json::Value),
58}
59
60
61pub async fn clear_index(configuration: &configuration::Configuration, idx_name: &str) -> Result<String, Error<ClearIndexError>> {
62    let local_var_configuration = configuration;
63
64    let local_var_client = &local_var_configuration.client;
65
66    let local_var_uri_str = format!("{}/indexer/delete/{idx_name}", local_var_configuration.base_path, idx_name=crate::apis::urlencode(idx_name));
67    let mut local_var_req_builder = local_var_client.request(reqwest::Method::DELETE, local_var_uri_str.as_str());
68
69    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
70        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
71    }
72    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
73        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
74    };
75
76    let local_var_req = local_var_req_builder.build()?;
77    let local_var_resp = local_var_client.execute(local_var_req).await?;
78
79    let local_var_status = local_var_resp.status();
80    let local_var_content = local_var_resp.text().await?;
81
82    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
83        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
84    } else {
85        let local_var_entity: Option<ClearIndexError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
86        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
87        Err(Error::ResponseError(local_var_error))
88    }
89}
90
91pub async fn count_search_logs_index(configuration: &configuration::Configuration, search_query: &str, min_ts: Option<String>, max_ts: Option<String>) -> Result<models::CountSearchLogsIndex200Response, Error<CountSearchLogsIndexError>> {
92    let local_var_configuration = configuration;
93
94    let local_var_client = &local_var_configuration.client;
95
96    let local_var_uri_str = format!("{}/srch/index/search/count_service_logs", local_var_configuration.base_path);
97    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
98
99    local_var_req_builder = local_var_req_builder.query(&[("search_query", &search_query.to_string())]);
100    if let Some(ref local_var_str) = min_ts {
101        local_var_req_builder = local_var_req_builder.query(&[("min_ts", &local_var_str.to_string())]);
102    }
103    if let Some(ref local_var_str) = max_ts {
104        local_var_req_builder = local_var_req_builder.query(&[("max_ts", &local_var_str.to_string())]);
105    }
106    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
107        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
108    }
109    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
110        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
111    };
112
113    let local_var_req = local_var_req_builder.build()?;
114    let local_var_resp = local_var_client.execute(local_var_req).await?;
115
116    let local_var_status = local_var_resp.status();
117    let local_var_content = local_var_resp.text().await?;
118
119    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
120        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
121    } else {
122        let local_var_entity: Option<CountSearchLogsIndexError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
123        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
124        Err(Error::ResponseError(local_var_error))
125    }
126}
127
128pub async fn get_index_storage_sizes(configuration: &configuration::Configuration, ) -> Result<models::GetIndexStorageSizes200Response, Error<GetIndexStorageSizesError>> {
129    let local_var_configuration = configuration;
130
131    let local_var_client = &local_var_configuration.client;
132
133    let local_var_uri_str = format!("{}/indexer/storage", local_var_configuration.base_path);
134    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
135
136    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
137        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
138    }
139    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
140        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
141    };
142
143    let local_var_req = local_var_req_builder.build()?;
144    let local_var_resp = local_var_client.execute(local_var_req).await?;
145
146    let local_var_status = local_var_resp.status();
147    let local_var_content = local_var_resp.text().await?;
148
149    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
150        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
151    } else {
152        let local_var_entity: Option<GetIndexStorageSizesError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
153        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
154        Err(Error::ResponseError(local_var_error))
155    }
156}
157
158pub async fn get_indexer_status(configuration: &configuration::Configuration, ) -> Result<models::GetIndexerStatus200Response, Error<GetIndexerStatusError>> {
159    let local_var_configuration = configuration;
160
161    let local_var_client = &local_var_configuration.client;
162
163    let local_var_uri_str = format!("{}/indexer/status", local_var_configuration.base_path);
164    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
165
166    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
167        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
168    }
169    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
170        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
171    };
172
173    let local_var_req = local_var_req_builder.build()?;
174    let local_var_resp = local_var_client.execute(local_var_req).await?;
175
176    let local_var_status = local_var_resp.status();
177    let local_var_content = local_var_resp.text().await?;
178
179    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
180        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
181    } else {
182        let local_var_entity: Option<GetIndexerStatusError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
183        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
184        Err(Error::ResponseError(local_var_error))
185    }
186}
187
188pub async fn search_jobs_index(configuration: &configuration::Configuration, workspace: &str, search_query: &str, pagination_offset: Option<i32>) -> Result<models::SearchJobsIndex200Response, Error<SearchJobsIndexError>> {
189    let local_var_configuration = configuration;
190
191    let local_var_client = &local_var_configuration.client;
192
193    let local_var_uri_str = format!("{}/srch/w/{workspace}/index/search/job", local_var_configuration.base_path, workspace=crate::apis::urlencode(workspace));
194    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
195
196    local_var_req_builder = local_var_req_builder.query(&[("search_query", &search_query.to_string())]);
197    if let Some(ref local_var_str) = pagination_offset {
198        local_var_req_builder = local_var_req_builder.query(&[("pagination_offset", &local_var_str.to_string())]);
199    }
200    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
201        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
202    }
203    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
204        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
205    };
206
207    let local_var_req = local_var_req_builder.build()?;
208    let local_var_resp = local_var_client.execute(local_var_req).await?;
209
210    let local_var_status = local_var_resp.status();
211    let local_var_content = local_var_resp.text().await?;
212
213    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
214        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
215    } else {
216        let local_var_entity: Option<SearchJobsIndexError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
217        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
218        Err(Error::ResponseError(local_var_error))
219    }
220}
221
222pub async fn search_logs_index(configuration: &configuration::Configuration, search_query: &str, mode: &str, hostname: &str, worker_group: Option<&str>, min_ts: Option<String>, max_ts: Option<String>) -> Result<models::SearchLogsIndex200Response, Error<SearchLogsIndexError>> {
223    let local_var_configuration = configuration;
224
225    let local_var_client = &local_var_configuration.client;
226
227    let local_var_uri_str = format!("{}/srch/index/search/service_logs", local_var_configuration.base_path);
228    let mut local_var_req_builder = local_var_client.request(reqwest::Method::GET, local_var_uri_str.as_str());
229
230    local_var_req_builder = local_var_req_builder.query(&[("search_query", &search_query.to_string())]);
231    local_var_req_builder = local_var_req_builder.query(&[("mode", &mode.to_string())]);
232    if let Some(ref local_var_str) = worker_group {
233        local_var_req_builder = local_var_req_builder.query(&[("worker_group", &local_var_str.to_string())]);
234    }
235    local_var_req_builder = local_var_req_builder.query(&[("hostname", &hostname.to_string())]);
236    if let Some(ref local_var_str) = min_ts {
237        local_var_req_builder = local_var_req_builder.query(&[("min_ts", &local_var_str.to_string())]);
238    }
239    if let Some(ref local_var_str) = max_ts {
240        local_var_req_builder = local_var_req_builder.query(&[("max_ts", &local_var_str.to_string())]);
241    }
242    if let Some(ref local_var_user_agent) = local_var_configuration.user_agent {
243        local_var_req_builder = local_var_req_builder.header(reqwest::header::USER_AGENT, local_var_user_agent.clone());
244    }
245    if let Some(ref local_var_token) = local_var_configuration.bearer_access_token {
246        local_var_req_builder = local_var_req_builder.bearer_auth(local_var_token.to_owned());
247    };
248
249    let local_var_req = local_var_req_builder.build()?;
250    let local_var_resp = local_var_client.execute(local_var_req).await?;
251
252    let local_var_status = local_var_resp.status();
253    let local_var_content = local_var_resp.text().await?;
254
255    if !local_var_status.is_client_error() && !local_var_status.is_server_error() {
256        crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).map_err(Error::from)
257    } else {
258        let local_var_entity: Option<SearchLogsIndexError> = crate::from_str_patched/* Externally injected from /build.nu */(&local_var_content).ok();
259        let local_var_error = ResponseContent { status: local_var_status, content: local_var_content, entity: local_var_entity };
260        Err(Error::ResponseError(local_var_error))
261    }
262}
263
windmill_api/apis/index_search_api.rs

windmill_api/apis/
index_search_api.rs
