Enum RpcClientError 

pub enum RpcClientError {
    BrokerNotFound {
        broker_name: String,
    },
    RequestFailed {
        addr: String,
        request_code: i32,
        timeout_ms: u64,
        source: Box<dyn Error + Send + Sync>,
    },
    UnexpectedResponseCode {
        code: i32,
        code_name: String,
    },
    UnsupportedRequestCode {
        code: i32,
    },
    RemoteError(i32, String),
}

RPC client specific errors with full context preservation

Variants

BrokerNotFound

Broker address not found in client metadata

Fields

broker_name: String

RequestFailed

RPC request failed

Fields

addr: String

request_code: i32

timeout_ms: u64

source: Box<dyn Error + Send + Sync>

UnexpectedResponseCode

Unexpected response code received

Fields

code: i32

code_name: String

UnsupportedRequestCode

Request code not supported by the handler

Fields

code: i32

RemoteError(i32, String)

RPC error from remote server

Implementations

impl RpcClientError

pub fn broker_not_found(broker_name: impl Into<String>) -> Self

Helper to construct a BrokerNotFound error.

pub fn request_failed<E>( addr: impl Into<String>, request_code: i32, timeout_ms: u64, source: E, ) -> Self

where E: Error + Send + Sync + 'static,

Helper to construct a RequestFailed error.

pub fn unexpected_response_code(code: i32, code_name: impl Into<String>) -> Self

Helper to construct an UnexpectedResponseCode error.

pub fn unsupported_request_code(code: i32) -> Self

Helper to construct an UnsupportedRequestCode error.

pub fn remote_error(code: i32, message: impl Into<String>) -> Self

Helper to construct a RemoteError.

Trait Implementations

impl Debug for RpcClientError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for RpcClientError

fn fmt(&self, __formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Error for RpcClientError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl From<RpcClientError> for RocketMQError

fn from(source: RpcClientError) -> Self

Converts to this type from the input type.