tmprl-client 0.1.0

Temporal gRPC access layer for tmprl
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
32
33
34

//! Typed operations.
//!
//! Everything above this crate talks in these types, never in protobuf types. That is what
//! keeps a `temporalio-client` bump contained: the generated types stop here.

pub mod codec;
pub mod history;
pub mod mutate;
pub mod namespace;
pub mod schedule;
pub mod workflow;

#[derive(Debug, thiserror::Error)]
pub enum OpError {
    #[error("{operation} failed: {message}")]
    Rpc {
        operation: &'static str,
        code: String,
        message: String,
    },
    /// The codec server is HTTP, not gRPC, so its failures are not `tonic::Status`.
    #[error("{message}")]
    Codec { message: String },
}

impl OpError {
    pub(crate) fn rpc(operation: &'static str, status: temporalio_client::tonic::Status) -> Self {
        Self::Rpc {
            operation,
            code: format!("{:?}", status.code()),
            message: status.message().to_string(),
        }
    }
}