batata-client 0.0.2

Rust client for Batata/Nacos service discovery and configuration management
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

use thiserror::Error;

/// Result type alias for batata client operations
pub type Result<T> = std::result::Result<T, BatataError>;

/// Error types for Batata client operations
#[derive(Error, Debug)]
pub enum BatataError {
    /// Configuration not found
    #[error("Config not found: dataId={data_id}, group={group}, namespace={namespace}")]
    ConfigNotFound {
        data_id: String,
        group: String,
        namespace: String,
    },

    /// Service not found
    #[error("Service not found: service={service_name}, group={group_name}, namespace={namespace}")]
    ServiceNotFound {
        service_name: String,
        group_name: String,
        namespace: String,
    },

    /// Connection error
    #[error("Connection error: {message}")]
    ConnectionError { message: String },

    /// Server error with error code
    #[error("Server error: code={error_code}, message={message}")]
    ServerError { error_code: i32, message: String },

    /// Authentication error
    #[error("Authentication error: {message}")]
    AuthError { message: String },

    /// Permission denied
    #[error("Permission denied: {message}")]
    PermissionDenied { message: String },

    /// Request timeout
    #[error("Request timeout after {timeout_ms}ms")]
    Timeout { timeout_ms: u64 },

    /// Serialization/Deserialization error
    #[error("Serialization error: {0}")]
    SerializationError(#[from] serde_json::Error),

    /// gRPC transport error
    #[error("gRPC transport error: {0}")]
    TransportError(#[from] tonic::transport::Error),

    /// gRPC status error
    #[error("gRPC status error: {0}")]
    GrpcStatus(#[from] tonic::Status),

    /// Invalid parameter
    #[error("Invalid parameter: {0}")]
    InvalidParameter(String),

    /// Internal error
    #[error("Internal error: {0}")]
    Internal(String),

    /// No available server
    #[error("No available server")]
    NoAvailableServer,

    /// Client not started
    #[error("Client not started")]
    ClientNotStarted,

    /// Client already started
    #[error("Client already started")]
    ClientAlreadyStarted,

    /// Encryption/Decryption error
    #[error("Encryption error: {message}")]
    EncryptionError { message: String },
}

impl BatataError {
    /// Check if the error is retryable
    pub fn is_retryable(&self) -> bool {
        matches!(
            self,
            BatataError::ConnectionError { .. }
                | BatataError::Timeout { .. }
                | BatataError::TransportError(_)
                | BatataError::NoAvailableServer
        )
    }

    /// Create a server error from error code and message
    pub fn server_error(error_code: i32, message: impl Into<String>) -> Self {
        BatataError::ServerError {
            error_code,
            message: message.into(),
        }
    }

    /// Create a connection error
    pub fn connection_error(message: impl Into<String>) -> Self {
        BatataError::ConnectionError {
            message: message.into(),
        }
    }
}