Enum IggyError

Source

#[repr(u32)]pub enum IggyError {
Show 219 variants    Error = 1,
    InvalidConfiguration = 2,
    InvalidCommand = 3,
    InvalidFormat = 4,
    FeatureUnavailable = 5,
    InvalidIdentifier = 6,
    InvalidVersion(String),
    Disconnected = 8,
    CannotEstablishConnection = 9,
    CannotCreateBaseDirectory(String),
    CannotCreateRuntimeDirectory(String),
    CannotRemoveRuntimeDirectory(String),
    CannotCreateStateDirectory(String),
    StateFileNotFound = 14,
    StateFileCorrupted = 15,
    InvalidStateEntryChecksum(u64, u64, u64),
    CannotOpenDatabase(String),
    ResourceNotFound(String),
    CannotCloseWebSocketConnection(String),
    StaleClient = 30,
    TcpError = 31,
    QuicError = 32,
    InvalidServerAddress = 33,
    InvalidClientAddress = 34,
    InvalidIpAddress(String, String),
    HttpError(String),
    Unauthenticated = 40,
    Unauthorized = 41,
    InvalidCredentials = 42,
    InvalidUsername = 43,
    InvalidPassword = 44,
    InvalidUserStatus = 45,
    UserAlreadyExists = 46,
    UserInactive = 47,
    CannotDeleteUser(u32),
    CannotChangePermissions(u32),
    InvalidPersonalAccessTokenName = 50,
    PersonalAccessTokenAlreadyExists(String, u32),
    PersonalAccessTokensLimitReached(u32, u32),
    InvalidPersonalAccessToken = 53,
    PersonalAccessTokenExpired(String, u32),
    UsersLimitReached = 55,
    NotConnected = 61,
    ClientShutdown = 63,
    InvalidTlsDomain = 64,
    InvalidTlsCertificatePath = 65,
    InvalidTlsCertificate = 66,
    FailedToAddCertificate = 67,
    InvalidEncryptionKey = 70,
    CannotEncryptData = 71,
    CannotDecryptData = 72,
    InvalidJwtAlgorithm(String),
    InvalidJwtSecret = 74,
    JwtMissing = 75,
    CannotGenerateJwt = 76,
    AccessTokenMissing = 77,
    InvalidAccessToken = 78,
    InvalidSizeBytes = 80,
    InvalidUtf8 = 81,
    InvalidNumberEncoding = 82,
    InvalidBooleanValue = 83,
    InvalidNumberValue = 84,
    ClientNotFound(u32),
    InvalidClientId = 101,
    ConnectionClosed = 206,
    CannotParseHeaderKind(String),
    HttpResponseError(u16, String),
    InvalidHttpRequest = 301,
    InvalidJsonResponse = 302,
    InvalidBytesResponse = 303,
    EmptyResponse = 304,
    CannotCreateEndpoint = 305,
    CannotParseUrl = 306,
    WebSocketError = 400,
    WebSocketConnectionError = 401,
    WebSocketCloseError = 402,
    WebSocketReceiveError = 403,
    WebSocketSendError = 404,
    CannotCreateStreamsDirectory(String),
    CannotCreateStreamDirectory(u32, String),
    CannotCreateStreamInfo(u32),
    CannotUpdateStreamInfo(u32),
    CannotOpenStreamInfo(u32),
    CannotReadStreamInfo(u32),
    CannotCreateStream(u32),
    CannotDeleteStream(u32),
    CannotDeleteStreamDirectory(u32),
    StreamIdNotFound(Identifier),
    StreamNameNotFound(String),
    StreamDirectoryNotFound(String),
    StreamNameAlreadyExists(String),
    InvalidStreamName = 1_013,
    InvalidStreamId = 1_014,
    CannotReadStreams = 1_015,
    InvalidTopicSize(MaxTopicSize, IggyByteSize),
    CannotCreateTopicsDirectory(Identifier, String),
    CannotCreateTopicDirectory(usize, usize, String),
    CannotCreateTopicInfo(u32, u32),
    CannotUpdateTopicInfo(u32, u32),
    CannotOpenTopicInfo(u32, u32),
    CannotReadTopicInfo(u32, u32),
    CannotCreateTopic(u32, u32),
    CannotDeleteTopic(u32, u32),
    CannotDeleteTopicDirectory(u32, u32, String),
    CannotPollTopic = 2_009,
    TopicIdNotFound(Identifier, Identifier),
    TopicNameNotFound(String, String),
    TopicNameAlreadyExists(String, Identifier),
    InvalidTopicName = 2_014,
    TooManyPartitions = 2_015,
    InvalidTopicId = 2_016,
    CannotReadTopics(u32),
    InvalidReplicationFactor = 2_018,
    InvalidPartitionsCount = 2_019,
    TopicDirectoryNotFound(String),
    CannotCreatePartition(usize, usize, usize),
    CannotCreatePartitionsDirectory(usize, usize),
    CannotCreatePartitionDirectory(usize, usize, usize),
    CannotOpenPartitionLogFile = 3_003,
    CannotReadPartitions = 3_004,
    CannotDeletePartition(usize, Identifier, Identifier),
    CannotDeletePartitionDirectory(usize, usize, usize),
    PartitionNotFound(usize, Identifier, Identifier),
    NoPartitions(Identifier, Identifier),
    TopicFull(Identifier, Identifier),
    CannotDeleteConsumerOffsetsDirectory(String),
    CannotDeleteConsumerOffsetFile(String),
    CannotCreateConsumerOffsetsDirectory(String),
    CannotReadConsumerOffsets(String),
    ConsumerOffsetNotFound(usize),
    NotResolvedConsumer(Identifier),
    CannotOpenConsumerOffsetsFile(String),
    SegmentNotFound = 4_000,
    SegmentClosed(u64, usize),
    InvalidSegmentSize(u64),
    CannotCreateSegmentLogFile(String),
    CannotCreateSegmentIndexFile(String),
    CannotCreateSegmentTimeIndexFile(String),
    CannotSaveMessagesToSegment = 4_006,
    CannotSaveIndexToSegment = 4_007,
    CannotSaveTimeIndexToSegment = 4_008,
    InvalidMessagesCount = 4_009,
    CannotAppendMessage = 4_010,
    CannotReadMessage = 4_011,
    CannotReadMessageId = 4_012,
    CannotReadMessageState = 4_013,
    CannotReadMessageTimestamp = 4_014,
    CannotReadHeadersLength = 4_015,
    CannotReadHeadersPayload = 4_016,
    TooBigUserHeaders = 4_017,
    InvalidHeaderKey = 4_018,
    InvalidHeaderValue = 4_019,
    CannotReadMessageLength = 4_020,
    CannotReadMessagePayload = 4_021,
    TooBigMessagePayload = 4_022,
    TooManyMessages = 4_023,
    EmptyMessagePayload = 4_024,
    InvalidMessagePayloadLength = 4_025,
    CannotReadMessageChecksum = 4_026,
    InvalidMessageChecksum(u64, u64, u64),
    InvalidKeyValueLength = 4_028,
    CommandLengthError(String),
    InvalidSegmentsCount(u32),
    NonZeroOffset(u64, u32),
    NonZeroTimestamp(u64, u32),
    MissingIndex(u32),
    InvalidIndexesByteSize(u32),
    InvalidIndexesCount(u32, u32),
    InvalidMessagesSize(u32, u32),
    TooSmallMessage(u32, u32),
    CannotSendMessagesDueToClientDisconnection = 4_050,
    BackgroundSendError = 4_051,
    BackgroundSendTimeout = 4_052,
    BackgroundSendBufferFull = 4_053,
    BackgroundWorkerDisconnected = 4_054,
    BackgroundSendBufferOverflow = 4_055,
    ProducerSendFailed {
        cause: Box<IggyError>,
        failed: Arc<Vec<IggyMessage>>,
        stream_name: String,
        topic_name: String,
    },
    ProducerClosed = 4_057,
    InvalidOffset(u64),
    InvalidReservedField(u64),
    ConsumerGroupIdNotFound(Identifier, Identifier),
    InvalidConsumerGroupId = 5_002,
    ConsumerGroupNameNotFound(String, Identifier),
    ConsumerGroupNameAlreadyExists(String, Identifier),
    InvalidConsumerGroupName = 5_005,
    ConsumerGroupMemberNotFound(u32, Identifier, Identifier),
    CannotCreateConsumerGroupInfo(usize, Identifier, Identifier),
    CannotDeleteConsumerGroupInfo(usize, Identifier, Identifier),
    MissingBaseOffsetRetainedMessageBatch = 6_000,
    MissingLastOffsetDeltaRetainedMessageBatch = 6_001,
    MissingMaxTimestampRetainedMessageBatch = 6_002,
    MissingLengthRetainedMessageBatch = 6_003,
    MissingPayloadRetainedMessageBatch = 6_004,
    CannotReadBatchBaseOffset = 7_000,
    CannotReadBatchLength = 7_001,
    CannotReadLastOffsetDelta = 7_002,
    CannotReadMaxTimestamp = 7_003,
    CannotReadBatchPayload = 7_004,
    InvalidConnectionString = 8_000,
    SnapshotFileCompletionFailed = 9_000,
    CannotSerializeResource = 10_000,
    CannotDeserializeResource = 10_001,
    CannotReadFile = 10_002,
    CannotReadFileMetadata = 10_003,
    CannotSeekFile = 10_004,
    CannotAppendToFile = 10_005,
    CannotWriteToFile = 10_006,
    CannotOverwriteFile = 10_007,
    CannotDeleteFile = 10_008,
    CannotSyncFile = 10_009,
    CannotReadIndexOffset = 10_010,
    CannotReadIndexPosition = 10_011,
    CannotReadIndexTimestamp = 10_012,
    TimestampOutOfRange(u64),
    ShardNotFound(usize, usize, usize),
    ShardCommunicationError = 11_001,
    CannotBindToSocket(String),
    TaskTimeout = 12_001,
    IoError(String),
}

Variants§

§

ProducerSendFailed

Fields

§cause: Box<IggyError>

§failed: Arc<Vec<IggyMessage>>

§stream_name: String

§topic_name: String

§

ProducerClosed = 4_057

§

InvalidOffset(u64)

§

InvalidReservedField(u64)

§

ConsumerGroupIdNotFound(Identifier, Identifier)

§

InvalidConsumerGroupId = 5_002

§

ConsumerGroupNameNotFound(String, Identifier)

§

ConsumerGroupNameAlreadyExists(String, Identifier)

§

InvalidConsumerGroupName = 5_005

§

ConsumerGroupMemberNotFound(u32, Identifier, Identifier)

§

CannotCreateConsumerGroupInfo(usize, Identifier, Identifier)

§

CannotDeleteConsumerGroupInfo(usize, Identifier, Identifier)

§

MissingBaseOffsetRetainedMessageBatch = 6_000

§

MissingLastOffsetDeltaRetainedMessageBatch = 6_001

§

MissingMaxTimestampRetainedMessageBatch = 6_002

§

MissingLengthRetainedMessageBatch = 6_003

§

MissingPayloadRetainedMessageBatch = 6_004

§

CannotReadBatchBaseOffset = 7_000

§

CannotReadBatchLength = 7_001

§

CannotReadLastOffsetDelta = 7_002

§

CannotReadMaxTimestamp = 7_003

§

CannotReadBatchPayload = 7_004

§

InvalidConnectionString = 8_000

§

SnapshotFileCompletionFailed = 9_000

§

CannotSerializeResource = 10_000

§

CannotDeserializeResource = 10_001

§

CannotReadFile = 10_002

§

CannotReadFileMetadata = 10_003

§

CannotSeekFile = 10_004

§

CannotAppendToFile = 10_005

§

CannotWriteToFile = 10_006

§

CannotOverwriteFile = 10_007

§

CannotDeleteFile = 10_008

§

CannotSyncFile = 10_009

§

CannotReadIndexOffset = 10_010

§

CannotReadIndexPosition = 10_011

§

CannotReadIndexTimestamp = 10_012

§

TimestampOutOfRange(u64)

§

ShardNotFound(usize, usize, usize)

§

ShardCommunicationError = 11_001

§

CannotBindToSocket(String)

§

TaskTimeout = 12_001

§

IoError(String)

Implementations§

Source §

impl IggyError

Source

pub fn from_repr(discriminant: u32) -> Option<IggyError>

Try to create Self from the raw representation

Source §

impl IggyError

Source

pub fn as_code(&self) -> u32

Source

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

Source

pub fn from_code(code: u32) -> Self

Source

pub fn from_code_as_string(code: u32) -> &'static str

Trait Implementations§

Source §

impl Clone for IggyError

Source §

fn clone(&self) -> IggyError

Returns a duplicate of the value. Read more

1.0.0 · Source§

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

Performs copy-assignment from source. Read more

Source §

impl Debug for IggyError

Source §

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

Formats the value using the given formatter. Read more

Source §

impl Default for IggyError

Source §

fn default() -> IggyError

Returns the “default value” for a type. Read more

Source §

impl Display for IggyError

Source §

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

Formats the value using the given formatter. Read more

Source §

impl Error for IggyError

1.30.0 · Source§

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

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

1.0.0 · Source§

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

Source §

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. Read more

Source §