Enum GrpcError

Source

pub enum GrpcError {
    InvalidContentType,
    BodyReadError(String),
    InvalidFrame,
    MessageTooLarge,
    DecodeError(String),
    CompressionUnsupported,
}

Available on crate feature grpc only.

Expand description

Error types for gRPC extraction.

Variants§

§

InvalidContentType

Content-Type is not application/grpc.

§

BodyReadError(String)

Failed to read the request body.

§

InvalidFrame

gRPC frame is too short or malformed.

§

MessageTooLarge

Length-prefix advertises a message larger than MAX_GRPC_MESSAGE_SIZE.

Mapped to gRPC status ResourceExhausted (8) per the spec — grpc-go, tonic, and the upstream issue (grpc/grpc#23454) all use it for received message larger than max. Returning InvalidArgument would be wire-level wrong: clients that backoff-retry on ResourceExhausted would never retry on InvalidArgument.

§

DecodeError(String)

Protobuf decoding failed.

§

CompressionUnsupported

Frame’s compressed flag was set but the server does not advertise any compression codec. Mapped to gRPC status Unimplemented per the spec (https://grpc.io/docs/guides/wire/) so clients fall back to uncompressed.

GrpcError

Enum GrpcError Copy item path

Variants§

InvalidContentType

BodyReadError(String)

InvalidFrame

MessageTooLarge

DecodeError(String)

CompressionUnsupported

Trait Implementations§

impl Debug for GrpcError

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

impl Responder for GrpcError

fn into_response(self) -> Response<TakoBody>

Auto Trait Implementations§

impl Freeze for GrpcError

impl RefUnwindSafe for GrpcError

impl Send for GrpcError

impl Sync for GrpcError

impl Unpin for GrpcError

impl UnsafeUnpin for GrpcError

impl UnwindSafe for GrpcError

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FutureExt for T

fn with_context(self, otel_cx: Context) -> WithContext<Self>

fn with_current_context(self) -> WithContext<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Enum GrpcError

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T> PolicyExt for T
where T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,