Enum Error 

pub enum Error {
    NotFound(String),
    ConfigMismatch,
    AlreadyExists(String),
    InvalidOffset(String),
    InvalidStreamName(String),
    ContentTypeMismatch {
        expected: String,
        actual: String,
    },
    StreamClosed,
    SequenceRegression {
        expected: u64,
        actual: u64,
    },
    SequenceGap {
        expected: u64,
        actual: u64,
    },
    EpochFenced {
        current: u64,
        received: u64,
    },
    InvalidProducerState(String),
    MemoryLimitExceeded,
    StreamSizeLimitExceeded,
    InvalidTtl(String),
    ConflictingExpiration,
    StreamExpired,
    InvalidJson(String),
    EmptyBody,
    InvalidHeader {
        header: String,
        reason: String,
    },
    SeqOrderingViolation {
        last: String,
        received: String,
    },
    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)

AlreadyExists(String)

Stream already exists (used for idempotent operations)

InvalidOffset(String)

Invalid offset format (400)

InvalidStreamName(String)

Invalid stream name (400)

ContentTypeMismatch

Content type mismatch (409)

Fields

expected: String

actual: String

StreamClosed

Stream is closed (409)

SequenceRegression

Producer sequence regression (409)

Fields

expected: u64

actual: u64

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 expected (400)

InvalidHeader

Invalid header value (400)

Fields

header: String

reason: String

SeqOrderingViolation

Stream-Seq ordering violation (409)

Fields

last: String

received: String

Storage(String)

Storage backend I/O or serialization error (500)

Implementations

impl Error

pub fn status_code(&self) -> u16

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.

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

Convert Error to HTTP response

fn into_response(self) -> Response

Create a response.