dakera_client/
error.rs

1//! Error types for the Dakera client SDK
2
3use serde::{Deserialize, Serialize};
4use thiserror::Error;
5
6/// Result type alias for Dakera client operations
7pub type Result<T> = std::result::Result<T, ClientError>;
8
9/// Typed error codes from the Dakera server API
10#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
11#[serde(rename_all = "SCREAMING_SNAKE_CASE")]
12pub enum ServerErrorCode {
13    NamespaceNotFound,
14    VectorNotFound,
15    DimensionMismatch,
16    EmptyVector,
17    InvalidRequest,
18    StorageError,
19    InternalError,
20    QuotaExceeded,
21    ServiceUnavailable,
22    AuthenticationRequired,
23    InvalidApiKey,
24    ApiKeyExpired,
25    InsufficientScope,
26    NamespaceAccessDenied,
27    #[serde(other)]
28    Unknown,
29}
30
31/// Errors that can occur when using the Dakera client
32#[derive(Error, Debug)]
33pub enum ClientError {
34    /// HTTP request failed
35    #[cfg(feature = "http-client")]
36    #[error("HTTP request failed: {0}")]
37    Http(#[from] reqwest::Error),
38
39    /// gRPC request failed
40    #[cfg(feature = "grpc")]
41    #[error("gRPC request failed: {0}")]
42    Grpc(String),
43
44    /// JSON serialization/deserialization failed
45    #[error("JSON error: {0}")]
46    Json(#[from] serde_json::Error),
47
48    /// Server returned an error response
49    #[error("Server error ({status}): {message}")]
50    Server {
51        /// HTTP status code
52        status: u16,
53        /// Error message from server
54        message: String,
55        #[doc = "Typed error code from the server"]
56        code: Option<ServerErrorCode>,
57    },
58
59    /// 403 Forbidden — insufficient scope or namespace access denied
60    #[error("Authorization failed ({status}): {message}")]
61    Authorization {
62        status: u16,
63        message: String,
64        code: Option<ServerErrorCode>,
65    },
66
67    /// Invalid configuration
68    #[error("Invalid configuration: {0}")]
69    Config(String),
70
71    /// Namespace not found
72    #[error("Namespace not found: {0}")]
73    NamespaceNotFound(String),
74
75    /// Vector not found
76    #[error("Vector not found: {0}")]
77    VectorNotFound(String),
78
79    /// Invalid URL
80    #[error("Invalid URL: {0}")]
81    InvalidUrl(String),
82
83    /// Connection failed
84    #[error("Connection failed: {0}")]
85    Connection(String),
86
87    /// Timeout
88    #[error("Request timeout")]
89    Timeout,
90}
91
92impl ClientError {
93    /// Check if the error is retryable
94    pub fn is_retryable(&self) -> bool {
95        match self {
96            #[cfg(feature = "http-client")]
97            ClientError::Http(e) => e.is_timeout() || e.is_connect(),
98            #[cfg(feature = "grpc")]
99            ClientError::Grpc(_) => true, // gRPC errors are generally retryable
100            ClientError::Server { status, .. } => *status >= 500,
101            ClientError::Connection(_) => true,
102            ClientError::Timeout => true,
103            _ => false,
104        }
105    }
106
107    /// Check if the error is a not found error
108    pub fn is_not_found(&self) -> bool {
109        match self {
110            ClientError::Server { status, code, .. } => {
111                *status == 404
112                    || matches!(
113                        code,
114                        Some(ServerErrorCode::NamespaceNotFound)
115                            | Some(ServerErrorCode::VectorNotFound)
116                    )
117            }
118            ClientError::NamespaceNotFound(_) => true,
119            ClientError::VectorNotFound(_) => true,
120            _ => false,
121        }
122    }
123
124    /// Check if the error is an authorization/authentication error
125    pub fn is_auth_error(&self) -> bool {
126        matches!(self, ClientError::Authorization { .. })
127            || matches!(self, ClientError::Server { status: 401, .. })
128    }
129}
dakera_client/error.rs

dakera_client/
error.rs
