clientapi_pbs/apis/
config_datastore_api.rs

1/*
2 * Proxmox Backup Server API
3 *
4 * Generated from apidoc.js. NOT an official Proxmox specification. See https://pbs.proxmox.com/docs/api-viewer/ for the upstream documentation.
5 *
6 * The version of the OpenAPI document: 9.x
7 * 
8 * Generated by: https://openapi-generator.tech
9 */
10
11
12use reqwest;
13use serde::{Deserialize, Serialize, de::Error as _};
14use crate::{apis::ResponseContent, models};
15use super::{Error, configuration, ContentType};
16
17
18/// struct for typed errors of method [`config_datastore_create_datastore`]
19#[derive(Debug, Clone, Serialize, Deserialize)]
20#[serde(untagged)]
21pub enum ConfigDatastoreCreateDatastoreError {
22    Status400(models::PbsError),
23    Status401(models::PbsError),
24    Status403(models::PbsError),
25    Status404(models::PbsError),
26    Status500(models::PbsError),
27    Status501(models::PbsError),
28    Status503(models::PbsError),
29    UnknownValue(serde_json::Value),
30}
31
32/// struct for typed errors of method [`config_datastore_delete_datastore`]
33#[derive(Debug, Clone, Serialize, Deserialize)]
34#[serde(untagged)]
35pub enum ConfigDatastoreDeleteDatastoreError {
36    Status400(models::PbsError),
37    Status401(models::PbsError),
38    Status403(models::PbsError),
39    Status404(models::PbsError),
40    Status500(models::PbsError),
41    Status501(models::PbsError),
42    Status503(models::PbsError),
43    UnknownValue(serde_json::Value),
44}
45
46/// struct for typed errors of method [`config_datastore_get_config_datastore_by_name`]
47#[derive(Debug, Clone, Serialize, Deserialize)]
48#[serde(untagged)]
49pub enum ConfigDatastoreGetConfigDatastoreByNameError {
50    Status400(models::PbsError),
51    Status401(models::PbsError),
52    Status403(models::PbsError),
53    Status404(models::PbsError),
54    Status500(models::PbsError),
55    Status501(models::PbsError),
56    Status503(models::PbsError),
57    UnknownValue(serde_json::Value),
58}
59
60/// struct for typed errors of method [`config_datastore_get_datastore`]
61#[derive(Debug, Clone, Serialize, Deserialize)]
62#[serde(untagged)]
63pub enum ConfigDatastoreGetDatastoreError {
64    Status400(models::PbsError),
65    Status401(models::PbsError),
66    Status403(models::PbsError),
67    Status404(models::PbsError),
68    Status500(models::PbsError),
69    Status501(models::PbsError),
70    Status503(models::PbsError),
71    UnknownValue(serde_json::Value),
72}
73
74/// struct for typed errors of method [`config_datastore_update_datastore`]
75#[derive(Debug, Clone, Serialize, Deserialize)]
76#[serde(untagged)]
77pub enum ConfigDatastoreUpdateDatastoreError {
78    Status400(models::PbsError),
79    Status401(models::PbsError),
80    Status403(models::PbsError),
81    Status404(models::PbsError),
82    Status500(models::PbsError),
83    Status501(models::PbsError),
84    Status503(models::PbsError),
85    UnknownValue(serde_json::Value),
86}
87
88
89/// Create new datastore config.  Permissions: Requires Datastore.Allocate and, for a backing-device, Sys.Modify on '/system/disks'.
90pub async fn config_datastore_create_datastore(configuration: &configuration::Configuration, config_datastore_create_datastore_request: models::ConfigDatastoreCreateDatastoreRequest) -> Result<models::ConfigDatastoreCreateDatastoreResponse, Error<ConfigDatastoreCreateDatastoreError>> {
91    // add a prefix to parameters to efficiently prevent name collisions
92    let p_body_config_datastore_create_datastore_request = config_datastore_create_datastore_request;
93
94    let uri_str = format!("{}/config/datastore", configuration.base_path);
95    let mut req_builder = configuration.client.request(reqwest::Method::POST, &uri_str);
96
97    if let Some(ref user_agent) = configuration.user_agent {
98        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
99    }
100    if let Some(ref apikey) = configuration.api_key {
101        let key = apikey.key.clone();
102        let value = match apikey.prefix {
103            Some(ref prefix) => format!("{} {}", prefix, key),
104            None => key,
105        };
106        req_builder = req_builder.header("Authorization", value);
107    };
108    if let Some(ref apikey) = configuration.api_key {
109        let key = apikey.key.clone();
110        let value = match apikey.prefix {
111            Some(ref prefix) => format!("{} {}", prefix, key),
112            None => key,
113        };
114        req_builder = req_builder.header("CSRFPreventionToken", value);
115    };
116    req_builder = req_builder.json(&p_body_config_datastore_create_datastore_request);
117
118    let req = req_builder.build()?;
119    let resp = configuration.client.execute(req).await?;
120
121    let status = resp.status();
122    let content_type = resp
123        .headers()
124        .get("content-type")
125        .and_then(|v| v.to_str().ok())
126        .unwrap_or("application/octet-stream");
127    let content_type = super::ContentType::from(content_type);
128
129    if !status.is_client_error() && !status.is_server_error() {
130        let content = resp.text().await?;
131        match content_type {
132            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
133            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::ConfigDatastoreCreateDatastoreResponse`"))),
134            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::ConfigDatastoreCreateDatastoreResponse`")))),
135        }
136    } else {
137        let content = resp.text().await?;
138        let entity: Option<ConfigDatastoreCreateDatastoreError> = serde_json::from_str(&content).ok();
139        Err(Error::ResponseError(ResponseContent { status, content, entity }))
140    }
141}
142
143/// Remove a datastore configuration and optionally delete all its contents.  Permissions: Requires Datastore.Allocate and, for a backing-device, Sys.Modify on '/system/disks'.
144pub async fn config_datastore_delete_datastore(configuration: &configuration::Configuration, name: &str, destroy_data: Option<bool>, digest: Option<&str>, keep_job_configs: Option<bool>) -> Result<models::ConfigDatastoreDeleteDatastoreResponse, Error<ConfigDatastoreDeleteDatastoreError>> {
145    // add a prefix to parameters to efficiently prevent name collisions
146    let p_path_name = name;
147    let p_query_destroy_data = destroy_data;
148    let p_query_digest = digest;
149    let p_query_keep_job_configs = keep_job_configs;
150
151    let uri_str = format!("{}/config/datastore/{name}", configuration.base_path, name=crate::apis::urlencode(p_path_name));
152    let mut req_builder = configuration.client.request(reqwest::Method::DELETE, &uri_str);
153
154    if let Some(ref param_value) = p_query_destroy_data {
155        req_builder = req_builder.query(&[("destroy-data", &param_value.to_string())]);
156    }
157    if let Some(ref param_value) = p_query_digest {
158        req_builder = req_builder.query(&[("digest", &param_value.to_string())]);
159    }
160    if let Some(ref param_value) = p_query_keep_job_configs {
161        req_builder = req_builder.query(&[("keep-job-configs", &param_value.to_string())]);
162    }
163    if let Some(ref user_agent) = configuration.user_agent {
164        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
165    }
166    if let Some(ref apikey) = configuration.api_key {
167        let key = apikey.key.clone();
168        let value = match apikey.prefix {
169            Some(ref prefix) => format!("{} {}", prefix, key),
170            None => key,
171        };
172        req_builder = req_builder.header("Authorization", value);
173    };
174    if let Some(ref apikey) = configuration.api_key {
175        let key = apikey.key.clone();
176        let value = match apikey.prefix {
177            Some(ref prefix) => format!("{} {}", prefix, key),
178            None => key,
179        };
180        req_builder = req_builder.header("CSRFPreventionToken", value);
181    };
182
183    let req = req_builder.build()?;
184    let resp = configuration.client.execute(req).await?;
185
186    let status = resp.status();
187    let content_type = resp
188        .headers()
189        .get("content-type")
190        .and_then(|v| v.to_str().ok())
191        .unwrap_or("application/octet-stream");
192    let content_type = super::ContentType::from(content_type);
193
194    if !status.is_client_error() && !status.is_server_error() {
195        let content = resp.text().await?;
196        match content_type {
197            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
198            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::ConfigDatastoreDeleteDatastoreResponse`"))),
199            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::ConfigDatastoreDeleteDatastoreResponse`")))),
200        }
201    } else {
202        let content = resp.text().await?;
203        let entity: Option<ConfigDatastoreDeleteDatastoreError> = serde_json::from_str(&content).ok();
204        Err(Error::ResponseError(ResponseContent { status, content, entity }))
205    }
206}
207
208/// Read a datastore configuration.
209pub async fn config_datastore_get_config_datastore_by_name(configuration: &configuration::Configuration, name: &str) -> Result<models::ConfigDatastoreGetConfigDatastoreByNameResponse, Error<ConfigDatastoreGetConfigDatastoreByNameError>> {
210    // add a prefix to parameters to efficiently prevent name collisions
211    let p_path_name = name;
212
213    let uri_str = format!("{}/config/datastore/{name}", configuration.base_path, name=crate::apis::urlencode(p_path_name));
214    let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
215
216    if let Some(ref user_agent) = configuration.user_agent {
217        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
218    }
219    if let Some(ref apikey) = configuration.api_key {
220        let key = apikey.key.clone();
221        let value = match apikey.prefix {
222            Some(ref prefix) => format!("{} {}", prefix, key),
223            None => key,
224        };
225        req_builder = req_builder.header("Authorization", value);
226    };
227    if let Some(ref apikey) = configuration.api_key {
228        let key = apikey.key.clone();
229        let value = match apikey.prefix {
230            Some(ref prefix) => format!("{} {}", prefix, key),
231            None => key,
232        };
233        req_builder = req_builder.header("CSRFPreventionToken", value);
234    };
235
236    let req = req_builder.build()?;
237    let resp = configuration.client.execute(req).await?;
238
239    let status = resp.status();
240    let content_type = resp
241        .headers()
242        .get("content-type")
243        .and_then(|v| v.to_str().ok())
244        .unwrap_or("application/octet-stream");
245    let content_type = super::ContentType::from(content_type);
246
247    if !status.is_client_error() && !status.is_server_error() {
248        let content = resp.text().await?;
249        match content_type {
250            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
251            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::ConfigDatastoreGetConfigDatastoreByNameResponse`"))),
252            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::ConfigDatastoreGetConfigDatastoreByNameResponse`")))),
253        }
254    } else {
255        let content = resp.text().await?;
256        let entity: Option<ConfigDatastoreGetConfigDatastoreByNameError> = serde_json::from_str(&content).ok();
257        Err(Error::ResponseError(ResponseContent { status, content, entity }))
258    }
259}
260
261/// List all datastores
262pub async fn config_datastore_get_datastore(configuration: &configuration::Configuration, ) -> Result<models::ConfigDatastoreGetDatastoreResponse, Error<ConfigDatastoreGetDatastoreError>> {
263
264    let uri_str = format!("{}/config/datastore", configuration.base_path);
265    let mut req_builder = configuration.client.request(reqwest::Method::GET, &uri_str);
266
267    if let Some(ref user_agent) = configuration.user_agent {
268        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
269    }
270    if let Some(ref apikey) = configuration.api_key {
271        let key = apikey.key.clone();
272        let value = match apikey.prefix {
273            Some(ref prefix) => format!("{} {}", prefix, key),
274            None => key,
275        };
276        req_builder = req_builder.header("Authorization", value);
277    };
278    if let Some(ref apikey) = configuration.api_key {
279        let key = apikey.key.clone();
280        let value = match apikey.prefix {
281            Some(ref prefix) => format!("{} {}", prefix, key),
282            None => key,
283        };
284        req_builder = req_builder.header("CSRFPreventionToken", value);
285    };
286
287    let req = req_builder.build()?;
288    let resp = configuration.client.execute(req).await?;
289
290    let status = resp.status();
291    let content_type = resp
292        .headers()
293        .get("content-type")
294        .and_then(|v| v.to_str().ok())
295        .unwrap_or("application/octet-stream");
296    let content_type = super::ContentType::from(content_type);
297
298    if !status.is_client_error() && !status.is_server_error() {
299        let content = resp.text().await?;
300        match content_type {
301            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
302            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::ConfigDatastoreGetDatastoreResponse`"))),
303            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::ConfigDatastoreGetDatastoreResponse`")))),
304        }
305    } else {
306        let content = resp.text().await?;
307        let entity: Option<ConfigDatastoreGetDatastoreError> = serde_json::from_str(&content).ok();
308        Err(Error::ResponseError(ResponseContent { status, content, entity }))
309    }
310}
311
312/// Update datastore config.
313pub async fn config_datastore_update_datastore(configuration: &configuration::Configuration, name: &str, config_datastore_update_datastore_request: Option<models::ConfigDatastoreUpdateDatastoreRequest>) -> Result<models::ConfigDatastoreUpdateDatastoreResponse, Error<ConfigDatastoreUpdateDatastoreError>> {
314    // add a prefix to parameters to efficiently prevent name collisions
315    let p_path_name = name;
316    let p_body_config_datastore_update_datastore_request = config_datastore_update_datastore_request;
317
318    let uri_str = format!("{}/config/datastore/{name}", configuration.base_path, name=crate::apis::urlencode(p_path_name));
319    let mut req_builder = configuration.client.request(reqwest::Method::PUT, &uri_str);
320
321    if let Some(ref user_agent) = configuration.user_agent {
322        req_builder = req_builder.header(reqwest::header::USER_AGENT, user_agent.clone());
323    }
324    if let Some(ref apikey) = configuration.api_key {
325        let key = apikey.key.clone();
326        let value = match apikey.prefix {
327            Some(ref prefix) => format!("{} {}", prefix, key),
328            None => key,
329        };
330        req_builder = req_builder.header("Authorization", value);
331    };
332    if let Some(ref apikey) = configuration.api_key {
333        let key = apikey.key.clone();
334        let value = match apikey.prefix {
335            Some(ref prefix) => format!("{} {}", prefix, key),
336            None => key,
337        };
338        req_builder = req_builder.header("CSRFPreventionToken", value);
339    };
340    req_builder = req_builder.json(&p_body_config_datastore_update_datastore_request);
341
342    let req = req_builder.build()?;
343    let resp = configuration.client.execute(req).await?;
344
345    let status = resp.status();
346    let content_type = resp
347        .headers()
348        .get("content-type")
349        .and_then(|v| v.to_str().ok())
350        .unwrap_or("application/octet-stream");
351    let content_type = super::ContentType::from(content_type);
352
353    if !status.is_client_error() && !status.is_server_error() {
354        let content = resp.text().await?;
355        match content_type {
356            ContentType::Json => serde_json::from_str(&content).map_err(Error::from),
357            ContentType::Text => return Err(Error::from(serde_json::Error::custom("Received `text/plain` content type response that cannot be converted to `models::ConfigDatastoreUpdateDatastoreResponse`"))),
358            ContentType::Unsupported(unknown_type) => return Err(Error::from(serde_json::Error::custom(format!("Received `{unknown_type}` content type response that cannot be converted to `models::ConfigDatastoreUpdateDatastoreResponse`")))),
359        }
360    } else {
361        let content = resp.text().await?;
362        let entity: Option<ConfigDatastoreUpdateDatastoreError> = serde_json::from_str(&content).ok();
363        Err(Error::ResponseError(ResponseContent { status, content, entity }))
364    }
365}
366
clientapi_pbs/apis/config_datastore_api.rs

clientapi_pbs/apis/
config_datastore_api.rs
