aerro 0.9.0

Cross-service gRPC error framework for Rust.
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

//! Pure-bincode wire envelope — replaces the prost/protobuf encoding (v2).

use crate::Category;

pub(crate) const ENVELOPE_VERSION: u32 = 2;

#[derive(Debug, bincode::Encode, bincode::Decode)]
pub(crate) struct WireEnvelope {
    pub version: u32,
    pub category: u8,
    pub type_id: String,
    pub trace_id: [u8; 16],
    pub span_id: [u8; 8],
    pub frames: Vec<WireFrame>,
    pub payload: Vec<u8>,
}

#[derive(Debug, bincode::Encode, bincode::Decode)]
pub(crate) struct WireFrame {
    pub service: String,
    pub rpc: String,
    pub code: u32,
    pub message: String,
    pub location: String,
    pub category: u8,
}

impl From<Category> for u8 {
    fn from(c: Category) -> u8 {
        match c {
            Category::Business => 1,
            Category::System => 2,
            Category::Validation => 3,
            Category::Transport => 4,
        }
    }
}

impl TryFrom<u8> for Category {
    type Error = ();
    fn try_from(v: u8) -> Result<Self, ()> {
        match v {
            1 => Ok(Category::Business),
            2 => Ok(Category::System),
            3 => Ok(Category::Validation),
            4 => Ok(Category::Transport),
            _ => Err(()),
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn roundtrips_all_categories() {
        for c in [
            Category::Business,
            Category::System,
            Category::Validation,
            Category::Transport,
        ] {
            let byte: u8 = c.into();
            assert_eq!(Category::try_from(byte).unwrap(), c);
        }
    }
}