Enum Error 

pub enum Error {
    NotFound(String),
    ConfigMismatch,
    InvalidOffset(String),
    ContentTypeMismatch {
        expected: String,
        actual: String,
    },
    StreamClosed,
    SequenceGap {
        expected: u64,
        actual: u64,
    },
    EpochFenced {
        current: u64,
        received: u64,
    },
    InvalidProducerState(String),
    MemoryLimitExceeded,
    StreamSizeLimitExceeded,
    InvalidTtl(String),
    ConflictingExpiration,
    StreamExpired,
    InvalidJson(String),
    EmptyBody,
    EmptyArray,
    InvalidHeader {
        header: String,
        reason: String,
    },
    InvalidStreamName(String),
    SeqOrderingViolation {
        last: String,
        received: String,
    },
    Unavailable(StorageFailure),
    InsufficientStorage(StorageFailure),
    Storage(String),
}

Single error type for all storage and protocol operations

Maps to HTTP status codes in handlers. Following the single error enum pattern to avoid error type proliferation.

Variants

NotFound(String)

Stream not found (404)

ConfigMismatch

Stream already exists with different config (409)

InvalidOffset(String)

Invalid offset format (400)

ContentTypeMismatch

Content type mismatch (409)

Fields

expected: String

actual: String

StreamClosed

Stream is closed (409)

SequenceGap

Producer sequence gap (409)

Fields

expected: u64

actual: u64

EpochFenced

Producer epoch fenced (403)

Fields

current: u64

received: u64

InvalidProducerState(String)

Invalid producer state (400)

MemoryLimitExceeded

Memory limit exceeded (413)

StreamSizeLimitExceeded

Stream size limit exceeded (413)

InvalidTtl(String)

Invalid TTL format (400)

ConflictingExpiration

Both TTL and Expires-At provided (400)

StreamExpired

Stream has expired (404)

InvalidJson(String)

Invalid JSON (400)

EmptyBody

Empty request body when data is required (400)

EmptyArray

Empty JSON array append body (400)

InvalidHeader

Invalid header value (400)

Fields

header: String

reason: String

InvalidStreamName(String)

Invalid stream name (400)

SeqOrderingViolation

Stream-Seq ordering violation (409)

Fields

last: String

received: String

Unavailable(StorageFailure)

Storage backend is temporarily unavailable (503)

InsufficientStorage(StorageFailure)

Storage backend has insufficient capacity (507)

Storage(String)

Storage backend I/O or serialization error (500)

Implementations

impl Error

pub fn status_code(&self) -> StatusCode

Map error to HTTP status code

This is the single place where errors are mapped to status codes. Handlers should use this method to determine the response code.

pub fn storage_unavailable( backend: &'static str, operation: impl Into<String>, detail: impl Into<String>, ) -> Self

pub fn storage_insufficient( backend: &'static str, operation: impl Into<String>, detail: impl Into<String>, ) -> Self

pub fn classify_io_failure( backend: &'static str, operation: impl Into<String>, detail: impl Into<String>, error: &Error, ) -> Self

pub fn is_retryable_io_error(error: &Error) -> bool

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, __formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Error for Error

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 ProblemResponse

fn from(error: Error) -> Self

Converts to this type from the input type.

impl IntoResponse for Error

Convert Error to HTTP response

fn into_response(self) -> Response

Create a response.