rs-zero 0.2.6

Rust-first microservice framework inspired by go-zero engineering practices
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

use thiserror::Error;

use crate::discovery::DiscoveryError;

/// etcd adapter result type.
pub type EtcdDiscoveryResult<T> = Result<T, EtcdDiscoveryError>;

/// etcd adapter errors.
#[derive(Debug, Error)]
pub enum EtcdDiscoveryError {
    /// Serialization failed.
    #[error("etcd discovery codec error: {0}")]
    Codec(#[from] serde_json::Error),

    /// No endpoints were configured.
    #[error("etcd discovery requires at least one endpoint")]
    MissingEndpoint,

    /// Adapter configuration is invalid.
    #[error("invalid etcd discovery configuration: {0}")]
    InvalidConfig(String),

    /// The registry was created without an etcd connection.
    #[error("etcd registry is not connected; call EtcdRegistry::connect before use")]
    NotConnected,

    /// The requested instance does not exist in etcd.
    #[error("etcd service `{service}` does not have instance `{id}`")]
    MissingInstance { service: String, id: String },

    /// An etcd key could not be normalized into a discovery instance key.
    #[error("invalid etcd discovery key `{0}`")]
    InvalidKey(String),

    /// An etcd operation timed out.
    #[error("etcd operation `{operation}` timed out")]
    Timeout { operation: &'static str },

    /// Lease creation, revocation, or keep-alive failed.
    #[error("etcd lease error: {0}")]
    Lease(String),

    /// Watch creation or streaming failed.
    #[error("etcd watch error: {0}")]
    Watch(String),

    /// Backend operation failed.
    #[error("etcd backend error: {0}")]
    Backend(String),
}

impl EtcdDiscoveryError {
    /// Converts an etcd adapter error into the stable discovery trait error type.
    pub(crate) fn into_discovery_error(self) -> DiscoveryError {
        match self {
            Self::MissingInstance { service, id } => {
                DiscoveryError::MissingInstance { service, id }
            }
            error => DiscoveryError::Resolve {
                host: "etcd".to_string(),
                message: error.to_string(),
            },
        }
    }
}