zrpc 0.8.16

Framework for decentralized and distributed microservices over Zenoh.
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

use serde::{Deserialize, Serialize};
use std::collections::HashMap;

#[derive(Serialize, Deserialize, Debug, Clone)]
pub struct Status {
    code: Code,
    message: String,
    metadata: HashMap<String, String>,
}

impl Status {
    pub fn new<IntoString>(code: Code, message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self {
            code,
            message: message.into(),
            metadata: HashMap::new(),
        }
    }

    pub fn code(&self) -> &Code {
        &self.code
    }

    pub fn message(&self) -> &String {
        &self.message
    }

    pub fn ok<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::Ok, message)
    }

    pub fn created<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::Created, message)
    }

    pub fn bad_request<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::BadRequest, message)
    }

    pub fn unauthorized<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::Unauthorized, message)
    }

    pub fn forbidden<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::Forbidden, message)
    }

    pub fn not_found<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::NotFound, message)
    }

    pub fn timeout<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::Timeout, message)
    }

    pub fn internal_error<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::InternalError, message)
    }

    pub fn not_implemented<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::NotImplemented, message)
    }

    pub fn unavailable<IntoString>(message: IntoString) -> Self
    where
        IntoString: Into<String>,
    {
        Self::new(Code::Unavailable, message)
    }
}

/// Zenoh-RPC status codes
/// Based on HTTP ones: https://developer.mozilla.org/en-US/docs/Web/HTTP/Status#client_error_responses
#[derive(Serialize, Deserialize, Clone, Copy, Debug, PartialEq, Eq, Hash)]
pub enum Code {
    Ok = 200,
    Created = 201,
    Accepted = 202,
    BadRequest = 400,
    Unauthorized = 401,
    Forbidden = 403,
    NotFound = 404,
    Timeout = 408,
    InternalError = 500,
    NotImplemented = 501,
    Unavailable = 503,
}