direktil/dkl
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add cluster x kube-sign

Browse Source
This commit is contained in:
Mikaël Cluseau
2025-07-02 21:11:35 +02:00
parent 4b33c64042
commit 7f4307f009
3 changed files with 51 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/dls.rs
View File

@ -96,7 +96,7 @@ impl<'t> Cluster<'t> {
.await
}
pub async fn sign_ssh_user_pubkey(&self, sign_req: &SshSignReq) -> Result<Vec<u8>> {
pub async fn ssh_userca_sign(&self, sign_req: &SshSignReq) -> Result<Vec<u8>> {
let req = self.dls.req(
Method::POST,
format!("clusters/{}/ssh/user-ca/sign", self.name),
@ -106,6 +106,14 @@ impl<'t> Cluster<'t> {
let resp = do_req(req, &self.dls.token).await?;
Ok(resp.bytes().await.map_err(Error::Read)?.to_vec())
}
pub async fn kube_sign(&self, sign_req: &KubeSignReq) -> Result<Vec<u8>> {
let req = (self.dls).req(Method::POST, format!("clusters/{}/kube/sign", self.name))?;
let req = req.json(sign_req);
let resp = do_req(req, &self.dls.token).await?;
Ok(resp.bytes().await.map_err(Error::Read)?.to_vec())
}
}
pub struct Host<'t> {
@ -164,8 +172,21 @@ pub struct SshSignReq {
pub options: Vec<String>,
}
#[derive(serde::Deserialize, serde::Serialize)]
#[serde(rename_all = "PascalCase")]
pub struct KubeSignReq {
#[serde(rename = "CSR")]
pub csr: String,
pub user: String,
#[serde(skip_serializing_if = "Option::is_none")]
pub group: Option<String>,
#[serde(skip_serializing_if = "Option::is_none")]
pub validity: Option<String>,
}
#[derive(Debug, serde::Deserialize, serde::Serialize)]
struct ServerError {
#[serde(default)]
code: u16,
message: String,
#[serde(skip_serializing_if = "Option::is_none")]