unitycatalog_client/codegen/credentials/
client.rs

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

unitycatalog_client/codegen/credentials/
client.rs
