pub enum RemoteError {
Transport(TransportError),
Validation(ValidationError),
BreakerOpen(CircuitBreakerOpenError),
Internal(DataFusionError),
}Expand description
A failure anywhere on the remote call path.
This is the single error the remote layer threads through the exchange:
transport failures, response-containment failures (including the streaming
size ceiling and the per-call timeout), a fast-fail when the breaker is open,
and internal bridging errors. It converts to a DataFusionError at the
UDF trait boundary.
Variants§
Transport(TransportError)
A transport/RPC-layer failure.
Validation(ValidationError)
A response-containment failure (schema, row count, size, or timeout).
BreakerOpen(CircuitBreakerOpenError)
The call was rejected because the circuit breaker is open.
Internal(DataFusionError)
An internal error (batch construction or the arrow bridge).
Implementations§
Source§impl RemoteError
impl RemoteError
Sourcepub fn metric_reason(&self) -> String
pub fn metric_reason(&self) -> String
A short, stable reason string for metrics keying.
Trait Implementations§
Source§impl Debug for RemoteError
impl Debug for RemoteError
Source§impl Display for RemoteError
impl Display for RemoteError
Source§impl Error for RemoteError
impl Error for RemoteError
Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
👎Deprecated since 1.42.0: use the Display impl or to_string()
Source§impl From<CircuitBreakerOpenError> for RemoteError
impl From<CircuitBreakerOpenError> for RemoteError
Source§fn from(source: CircuitBreakerOpenError) -> Self
fn from(source: CircuitBreakerOpenError) -> Self
Converts to this type from the input type.
Source§impl From<DataFusionError> for RemoteError
impl From<DataFusionError> for RemoteError
Source§impl From<RemoteError> for DataFusionError
impl From<RemoteError> for DataFusionError
Source§fn from(err: RemoteError) -> Self
fn from(err: RemoteError) -> Self
Converts to this type from the input type.
Source§impl From<TransportError> for RemoteError
impl From<TransportError> for RemoteError
Source§fn from(source: TransportError) -> Self
fn from(source: TransportError) -> Self
Converts to this type from the input type.
Source§impl From<ValidationError> for RemoteError
impl From<ValidationError> for RemoteError
Source§fn from(source: ValidationError) -> Self
fn from(source: ValidationError) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl Freeze for RemoteError
impl !RefUnwindSafe for RemoteError
impl Send for RemoteError
impl Sync for RemoteError
impl Unpin for RemoteError
impl !UnwindSafe for RemoteError
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].