hatchet-sdk 0.2.8

This is an unofficial Rust SDK for Hatchet, a distributed, fault-tolerant task queue.
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
28
29
30
31

use super::v1::workflows::CreateWorkflowVersionRequest;
use super::v1::workflows::admin_service_client::AdminServiceClient;
use crate::HatchetError;

#[derive(Clone, Debug)]
pub(crate) struct AdminClient {
    client: AdminServiceClient<tonic::transport::Channel>,
    api_token: String,
}

impl AdminClient {
    pub(crate) fn new(channel: tonic::transport::Channel, api_token: String) -> Self {
        let client = AdminServiceClient::new(channel);
        Self { client, api_token }
    }
}

impl AdminClient {
    pub async fn put_workflow(
        &mut self,
        workflow: CreateWorkflowVersionRequest,
    ) -> Result<(), HatchetError> {
        let mut request = tonic::Request::new(workflow);
        crate::utils::add_grpc_auth_header(&mut request, &self.api_token)?;
        self.client
            .put_workflow(request)
            .await
            .map_err(|e| HatchetError::GrpcErrorStatus(e.message().to_string()))?;
        Ok(())
    }
}