k8s-maestro 0.1.0

A Kubernetes job orchestrator tool library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use k8s_openapi::api::batch::v1::Job;
use kube::{api::PostParams, Api};

use crate::entities::job::MaestroJob;

pub struct MaestroK8sClient {
    client: kube::Client
}

impl MaestroK8sClient {
    pub async fn new() -> anyhow::Result<MaestroK8sClient> {
        let client = kube::Client::try_default().await?;
        let k8s_client = MaestroK8sClient{ client };

        Ok(k8s_client)
    }

    pub async fn create_job(&self, job: &Job, namespace: &str, dry_run: bool) -> anyhow::Result<MaestroJob> {
        let api = Api::<Job>::namespaced(self.client.clone(), namespace);
        let post_parameters = PostParams{ dry_run, ..PostParams::default()};
        
        let created_job = api.create(&post_parameters, &job).await?;
        let maestro_job = MaestroJob::new(&created_job, self.client.clone());

        Ok(maestro_job)
    }
}