Enum ClientError 

pub enum ClientError {
    ConnectionFailed(Error),
    ConnectionClosed,
    IoError(Error),
    ProtocolError(String),
    InvalidResponse(String),
    Timeout,
    CrcMismatch {
        expected: u32,
        actual: u32,
    },
    ServerBackpressure,
    WouldBlock,
    ServerError(String),
    ServerCatchingUp {
        server_offset: u64,
    },
    NotLeader {
        leader_addr: Option<SocketAddr>,
    },
    TlsError(String),
    InvalidTopicName(String),
}

Errors that can occur during client operations

Variants

ConnectionFailed(Error)

Failed to establish a connection to the server

ConnectionClosed

Connection was closed by the server

IoError(Error)

I/O error during communication

ProtocolError(String)

Protocol-level error (malformed data, invalid state)

InvalidResponse(String)

Received an unexpected or invalid response from the server

Timeout

Operation timed out

CrcMismatch

CRC checksum mismatch indicating data corruption

Fields

expected: u32

Expected CRC value

actual: u32

Actual CRC value received

ServerBackpressure

Server is applying backpressure, client should slow down

WouldBlock

M3: Operation would block (non-blocking mode), client buffer is full

ServerError(String)

Server returned an error message

ServerCatchingUp

Server has not yet replicated to the requested offset — backoff and retry

Fields

server_offset: u64

The server’s current maximum offset

NotLeader

Server is not the leader, redirect to the specified address

Fields

leader_addr: Option<SocketAddr>

Address of the current leader, if known

TlsError(String)

TLS handshake or configuration error

InvalidTopicName(String)

Topic name failed validation — must match [a-zA-Z0-9-]+

Implementations

impl ClientError

pub fn is_retryable(&self) -> bool

Returns true if this error is transient and the operation should be retried after reconnecting. Used by Producer and Consumer for automatic retry logic.

Trait Implementations

impl Debug for ClientError

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

Formats the value using the given formatter.

impl Display for ClientError

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

Formats the value using the given formatter.

impl Error for ClientError

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<Error> for ClientError

fn from(err: Error) -> Self

Converts to this type from the input type.

impl From<LanceError> for ClientError

fn from(err: LanceError) -> Self

Converts to this type from the input type.

impl From<RecordParseError> for ClientError

fn from(e: RecordParseError) -> Self

Converts to this type from the input type.