Enum tower_kafka::transport::KafkaTransportError

pub enum KafkaTransportError {
    BrokenTransportSend,
    BrokenTransportRecv,
    Cancelled,
    TransportFull,
    ClientDropped,
    Desynchronized,
    TransportDropped,
    Unknown,
}

Errors that can be returned from the underlying transport layer.

Variants

BrokenTransportSend

The underlying transport failed to send a request.

BrokenTransportRecv

The underlying transport failed while attempting to receive a response.

If None, the transport closed without error while there were pending requests.

Cancelled

The internal pending data store has dropped the pending response.

TransportFull

Attempted to issue a call when no more requests can be in flight.

See [tower_service::Service::poll_ready] and [Client::with_limit].

ClientDropped

Attempted to issue a call, but the underlying transport has been closed.

Desynchronized

The server sent a response that the client was not expecting.

TransportDropped

The underlying transport task did not exit gracefully (either panic or cancellation). Transport task panics can happen for example when the codec logic panics.

Unknown

An unknown error occurred.

Trait Implementations

impl Debug for KafkaTransportError

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

Formats the value using the given formatter.

impl Display for KafkaTransportError

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

Formats the value using the given formatter.

impl Error for KafkaTransportError

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

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, demand: &mut Demand<'a>)

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

Provides type based access to context intended for error reports.

impl<T> From<Error<MultiplexTransport<Framed<T, KafkaClientCodec>, CorrelationStore>, BytesMut>> for KafkaTransportErrorwhere
    T: AsyncWrite + AsyncRead,

fn from(value: TransportError<T>) -> Self

Converts to this type from the input type.

impl From<KafkaTransportError> for KafkaError

fn from(value: KafkaTransportError) -> Self

Converts to this type from the input type.