Enum SinkError 

#[non_exhaustive]
pub enum SinkError {
    Upstream {
        status: u16,
        retryable: bool,
    },
    Transport {
        kind: &'static str,
    },
    StaleEpoch {
        stamped: Epoch,
        current: Epoch,
    },
}

A failure applying a write at the sink.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Upstream

The upstream cluster returned an error status for the whole request (not a per-item failure, which is carried in the ack).

Fields

status: u16

The upstream HTTP status.

retryable: bool

Whether the caller may retry.

Transport

The write could not be delivered (connection reset, timeout, TLS). The message is a shape/category description, never tenant data.

Fields

kind: &'static str

A short, value-free description of the transport failure.

StaleEpoch

The write was resolved against an epoch that is stale for a migrating partition; the caller must re-resolve and retry (docs/06 §2). Wired in M5; defined here so the sink contract is stable.

Fields

stamped: Epoch

The epoch the rejected write carried.

current: Epoch

The current epoch the sink expected.

Implementations

impl SinkError

pub fn code(&self) -> ErrorCode

The stable ErrorCode for this failure.

pub fn retryable(&self) -> bool

Whether the caller may retry (possibly after re-resolving placement).

Trait Implementations

impl Debug for SinkError

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

Formats the value using the given formatter.

impl Display for SinkError

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

Formats the value using the given formatter.

impl Error for SinkError

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.