Enum Error 

pub enum Error {
    UnexpectedError {
        message: String,
        source: Option<Box<dyn Error + Send + Sync + 'static>>,
    },
    IoUnexpectedError {
        message: String,
        source: Error,
    },
    RemoteStorageUnexpectedError {
        message: String,
        source: Error,
    },
    JsonSerdeError {
        message: String,
    },
    RpcError {
        message: String,
        source: RpcError,
    },
    RowConvertError {
        message: String,
    },
    ArrowError {
        message: String,
        source: ArrowError,
    },
    IllegalArgument {
        message: String,
    },
    IoUnsupported {
        message: String,
    },
    WakeupError {
        message: String,
    },
    UnsupportedOperation {
        message: String,
    },
    WriterClosed {
        message: String,
    },
    BufferExhausted {
        message: String,
    },
    FlussAPIError {
        api_error: ApiError,
    },
}

Variants

UnexpectedError

Fields

message: String

source: Option<Box<dyn Error + Send + Sync + 'static>>

see https://github.com/shepmaster/snafu/issues/446

IoUnexpectedError

Fields

message: String

source: Error

RemoteStorageUnexpectedError

Fields

message: String

source: Error

JsonSerdeError

Fields

message: String

RpcError

Fields

message: String

source: RpcError

RowConvertError

Fields

message: String

ArrowError

Fields

message: String

source: ArrowError

IllegalArgument

Fields

message: String

IoUnsupported

Fields

message: String

WakeupError

Fields

message: String

UnsupportedOperation

Fields

message: String

WriterClosed

Fields

message: String

BufferExhausted

Fields

message: String

FlussAPIError

Fields

api_error: ApiError

Implementations

impl Error

Convenience constructors for API errors that may be raised client-side. These create FlussAPIError with the correct protocol error code, consistent with Java where e.g. InvalidTableException always carries code 15.

pub fn table_not_exist(message: impl Into<String>) -> Self

pub fn invalid_table(message: impl Into<String>) -> Self

pub fn partition_not_exist(message: impl Into<String>) -> Self

pub fn invalid_partition(message: impl Into<String>) -> Self

pub fn leader_not_available(message: impl Into<String>) -> Self

pub fn api_error(&self) -> Option<FlussError>

Returns the API error kind if this is an API error, for ergonomic pattern matching.

pub fn is_retriable(&self) -> bool

Returns true if retrying the request may succeed. Error::RpcError is always retriable; Error::FlussAPIError delegates to ApiError::is_retriable; all other variants are not.

Trait Implementations

impl Debug for Error

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

Formats the value using the given formatter.

impl Display for Error

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

Formats the value using the given formatter.

impl Error for Error

where Self: Debug + Display,

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 source(&self) -> Option<&(dyn Error + 'static)>

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

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

fn backtrace(&self) -> Option<&Backtrace>

Returns a Backtrace that may be printed.

fn iter_chain(&self) -> ChainCompat<'_, '_>

where Self: AsErrorSource,

Returns an iterator for traversing the chain of errors, starting with the current error and continuing with recursive calls to Error::source.

impl From<ApiError> for Error

fn from(value: ApiError) -> Self

Converts to this type from the input type.

impl From<ArrowError> for Error

fn from(value: ArrowError) -> Self

Converts to this type from the input type.

impl From<Error> for Error

fn from(value: Error) -> Self

Converts to this type from the input type.

impl From<Error> for Error

fn from(value: Error) -> Self

Converts to this type from the input type.

impl From<ParseError> for Error

fn from(value: ParseError) -> Self

Converts to this type from the input type.

impl From<RpcError> for Error

fn from(value: RpcError) -> Self

Converts to this type from the input type.

impl FromString for Error

type Source = Box<dyn Error + Send + Sync>

The underlying error

fn without_source(message: String) -> Self

Create a brand new error from the given string

fn with_source(error: Self::Source, message: String) -> Self

Wrap an existing error with the given string