Enum FlussError 

#[repr(i32)]
pub enum FlussError {
    UnknownServerError = -1,
    None = 0,
    NetworkException = 1,
    UnsupportedVersion = 2,
    CorruptMessage = 3,
    DatabaseNotExist = 4,
    DatabaseNotEmpty = 5,
    DatabaseAlreadyExist = 6,
    TableNotExist = 7,
    TableAlreadyExist = 8,
    SchemaNotExist = 9,
    LogStorageException = 10,
    KvStorageException = 11,
    NotLeaderOrFollower = 12,
    RecordTooLargeException = 13,
    CorruptRecordException = 14,
    InvalidTableException = 15,
    InvalidDatabaseException = 16,
    InvalidReplicationFactor = 17,
    InvalidRequiredAcks = 18,
    LogOffsetOutOfRangeException = 19,
    NonPrimaryKeyTableException = 20,
    UnknownTableOrBucketException = 21,
    InvalidUpdateVersionException = 22,
    InvalidCoordinatorException = 23,
    FencedLeaderEpochException = 24,
    RequestTimeOut = 25,
    StorageException = 26,
    OperationNotAttemptedException = 27,
    NotEnoughReplicasAfterAppendException = 28,
    NotEnoughReplicasException = 29,
    SecurityTokenException = 30,
    OutOfOrderSequenceException = 31,
    DuplicateSequenceException = 32,
    UnknownWriterIdException = 33,
    InvalidColumnProjection = 34,
    InvalidTargetColumn = 35,
    PartitionNotExists = 36,
    TableNotPartitionedException = 37,
    InvalidTimestampException = 38,
    InvalidConfigException = 39,
    LakeStorageNotConfiguredException = 40,
    KvSnapshotNotExist = 41,
    PartitionAlreadyExists = 42,
    PartitionSpecInvalidException = 43,
    LeaderNotAvailableException = 44,
    PartitionMaxNumException = 45,
    AuthenticateException = 46,
    SecurityDisabledException = 47,
    AuthorizationException = 48,
    BucketMaxNumException = 49,
    FencedTieringEpochException = 50,
    RetriableAuthenticateException = 51,
    InvalidServerRackInfoException = 52,
    LakeSnapshotNotExist = 53,
    LakeTableAlreadyExist = 54,
    IneligibleReplicaException = 55,
    InvalidAlterTableException = 56,
    DeletionDisabledException = 57,
}

Fluss protocol errors. These errors are part of the client-server protocol. The error codes cannot be changed, but the names can be.

Do not add exceptions that occur only on the client or only on the server here.

Variants

UnknownServerError = -1

The server experienced an unexpected error when processing the request.

None = 0

No error occurred.

NetworkException = 1

The server disconnected before a response was received.

UnsupportedVersion = 2

The version of API is not supported.

CorruptMessage = 3

This message has failed its CRC checksum, exceeds the valid size, has a null key for a primary key table, or is otherwise corrupt.

DatabaseNotExist = 4

The database does not exist.

DatabaseNotEmpty = 5

The database is not empty.

DatabaseAlreadyExist = 6

The database already exists.

TableNotExist = 7

The table does not exist.

TableAlreadyExist = 8

The table already exists.

SchemaNotExist = 9

The schema does not exist.

LogStorageException = 10

Exception occur while storage data for log in server.

KvStorageException = 11

Exception occur while storage data for kv in server.

NotLeaderOrFollower = 12

Not leader or follower.

RecordTooLargeException = 13

The record is too large.

CorruptRecordException = 14

The record is corrupt.

InvalidTableException = 15

The client has attempted to perform an operation on an invalid table.

InvalidDatabaseException = 16

The client has attempted to perform an operation on an invalid database.

InvalidReplicationFactor = 17

The replication factor is larger then the number of available tablet servers.

InvalidRequiredAcks = 18

Produce request specified an invalid value for required acks.

LogOffsetOutOfRangeException = 19

The log offset is out of range.

NonPrimaryKeyTableException = 20

The table is not primary key table.

UnknownTableOrBucketException = 21

The table or bucket does not exist.

InvalidUpdateVersionException = 22

The update version is invalid.

InvalidCoordinatorException = 23

The coordinator is invalid.

FencedLeaderEpochException = 24

The leader epoch is invalid.

RequestTimeOut = 25

The request time out.

StorageException = 26

The general storage exception.

OperationNotAttemptedException = 27

The server did not attempt to execute this operation.

NotEnoughReplicasAfterAppendException = 28

Records are written to the server already, but to fewer in-sync replicas than required.

NotEnoughReplicasException = 29

Messages are rejected since there are fewer in-sync replicas than required.

SecurityTokenException = 30

Get file access security token exception.

OutOfOrderSequenceException = 31

The tablet server received an out of order sequence batch.

DuplicateSequenceException = 32

The tablet server received a duplicate sequence batch.

UnknownWriterIdException = 33

This exception is raised by the tablet server if it could not locate the writer metadata.

InvalidColumnProjection = 34

The requested column projection is invalid.

InvalidTargetColumn = 35

The requested target column to write is invalid.

PartitionNotExists = 36

The partition does not exist.

TableNotPartitionedException = 37

The table is not partitioned.

InvalidTimestampException = 38

The timestamp is invalid.

InvalidConfigException = 39

The config is invalid.

LakeStorageNotConfiguredException = 40

The lake storage is not configured.

KvSnapshotNotExist = 41

The kv snapshot is not exist.

PartitionAlreadyExists = 42

The partition already exists.

PartitionSpecInvalidException = 43

The partition spec is invalid.

LeaderNotAvailableException = 44

There is no currently available leader for the given partition.

PartitionMaxNumException = 45

Exceed the maximum number of partitions.

AuthenticateException = 46

Authentication failed.

SecurityDisabledException = 47

Security is disabled.

AuthorizationException = 48

Authorization failed.

BucketMaxNumException = 49

Exceed the maximum number of buckets.

FencedTieringEpochException = 50

The tiering epoch is invalid.

RetriableAuthenticateException = 51

Authentication failed with retriable exception.

InvalidServerRackInfoException = 52

The server rack info is invalid.

LakeSnapshotNotExist = 53

The lake snapshot is not exist.

LakeTableAlreadyExist = 54

The lake table already exists.

IneligibleReplicaException = 55

The new ISR contains at least one ineligible replica.

InvalidAlterTableException = 56

The alter table is invalid.

DeletionDisabledException = 57

Deletion operations are disabled on this table.

Implementations

impl FlussError

pub fn code(&self) -> i32

Returns the error code for this error.

pub fn is_retriable(&self) -> bool

pub fn message(&self) -> &'static str

Returns a friendly description of the error.

pub fn to_api_error(&self, message: Option<String>) -> ApiError

Create an ApiError from this error with the default message.

pub fn for_code(code: i32) -> Self

Get the FlussError for the given error code. Returns UnknownServerError if the code is not recognized.

Trait Implementations

impl Clone for FlussError

fn clone(&self) -> FlussError

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FlussError

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

Formats the value using the given formatter.

impl Display for FlussError

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

Formats the value using the given formatter.

impl From<ApiError> for FlussError

fn from(api_error: ApiError) -> Self

Converts to this type from the input type.

impl Hash for FlussError

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for FlussError

fn eq(&self, other: &FlussError) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for FlussError

impl Eq for FlussError

impl StructuralPartialEq for FlussError