unitycatalog_client/codegen/credentials/
client.rs

1// @generated — do not edit by hand.
2#![allow(unused_imports)]
3use crate::Result;
4#[cfg(not(target_arch = "wasm32"))]
5use ::olai_http::CloudClient as Transport;
6#[cfg(target_arch = "wasm32")]
7use ::olai_http_wasm::WasmClient as Transport;
8use unitycatalog_common::models::credentials::v1::*;
9use url::Url;
10/// HTTP client for service operations
11#[derive(Clone)]
12pub struct CredentialServiceClient {
13    pub(crate) client: Transport,
14    pub(crate) base_url: Url,
15}
16impl CredentialServiceClient {
17    /// Create a new client instance
18    pub fn new(client: Transport, mut base_url: Url) -> Self {
19        if !base_url.path().ends_with('/') {
20            base_url.set_path(&format!("{}/", base_url.path()));
21        }
22        Self { client, base_url }
23    }
24    pub async fn list_credentials(
25        &self,
26        request: &ListCredentialsRequest,
27    ) -> Result<ListCredentialsResponse> {
28        let mut url = self.base_url.join("credentials")?;
29        if let Some(known) = request.purpose.and_then(|v| v.as_known()) {
30            use buffa::Enumeration as _;
31            url.query_pairs_mut()
32                .append_pair("purpose", known.proto_name());
33        }
34        if let Some(ref value) = request.max_results {
35            url.query_pairs_mut()
36                .append_pair("max_results", &value.to_string());
37        }
38        if let Some(ref value) = request.page_token {
39            url.query_pairs_mut()
40                .append_pair("page_token", &value.to_string());
41        }
42        let response = self.client.get(url).send().await?;
43        if !response.status().is_success() {
44            return Err(crate::error::parse_error_response(response).await);
45        }
46        let result = response.bytes().await?;
47        Ok(serde_json::from_slice(&result)?)
48    }
49    pub async fn create_credential(&self, request: &CreateCredentialRequest) -> Result<Credential> {
50        let url = self.base_url.join("credentials")?;
51        let response = self.client.post(url).json(request).send().await?;
52        if !response.status().is_success() {
53            return Err(crate::error::parse_error_response(response).await);
54        }
55        let result = response.bytes().await?;
56        Ok(serde_json::from_slice(&result)?)
57    }
58    pub async fn get_credential(&self, request: &GetCredentialRequest) -> Result<Credential> {
59        let formatted_path = format!("credentials/{}", request.name);
60        let url = self.base_url.join(&formatted_path)?;
61        let response = self.client.get(url).send().await?;
62        if !response.status().is_success() {
63            return Err(crate::error::parse_error_response(response).await);
64        }
65        let result = response.bytes().await?;
66        Ok(serde_json::from_slice(&result)?)
67    }
68    pub async fn update_credential(&self, request: &UpdateCredentialRequest) -> Result<Credential> {
69        let formatted_path = format!("credentials/{}", request.name);
70        let url = self.base_url.join(&formatted_path)?;
71        let response = self.client.patch(url).json(request).send().await?;
72        if !response.status().is_success() {
73            return Err(crate::error::parse_error_response(response).await);
74        }
75        let result = response.bytes().await?;
76        Ok(serde_json::from_slice(&result)?)
77    }
78    pub async fn delete_credential(&self, request: &DeleteCredentialRequest) -> Result<()> {
79        let formatted_path = format!("credentials/{}", request.name);
80        let url = self.base_url.join(&formatted_path)?;
81        let response = self.client.delete(url).send().await?;
82        if !response.status().is_success() {
83            return Err(crate::error::parse_error_response(response).await);
84        }
85        Ok(())
86    }
87}
unitycatalog_client/codegen/credentials/client.rs

unitycatalog_client/codegen/credentials/
client.rs
