Enum TranslateError 

pub enum TranslateError {
    NoCounterpart(&'static str),
    UnknownTopicId(Uuid),
    UnknownTopicName(String),
    InvalidReference {
        field: &'static str,
        detail: String,
    },
    InvalidValue {
        field: &'static str,
        detail: String,
    },
    Encode(String),
    Decode(String),
    UnknownAclId(Uuid),
    UnknownPrivateTag(u32),
    UnknownPrivateRecordVersion {
        tag: u32,
        version: i16,
    },
    PrivateTagMismatch {
        tag: u32,
        expected_tag: Option<u32>,
    },
    TrailingPrivateRecordBytes {
        tag: u32,
        trailing: usize,
    },
}

Variants

NoCounterpart(&'static str)

UnknownTopicId(Uuid)

UnknownTopicName(String)

InvalidReference

A value that is well-formed on its own but names something the metadata image does not hold in the shape the record needs: an unknown partition, a broker that is not a replica, a directory list whose length does not match the replicas the image holds, or an epoch that the image already holds at its maximum. Two racing committed writes can legitimately produce one, and every replica sees the same image in log order, so every replica skips the record in the same way.

Fields

field: &'static str

detail: String

InvalidValue

A value that no build accepts, whatever the image holds: an unknown enum discriminant, a negative node id or iteration count, an integer that does not fit the wire width, a string that does not parse, or a directory list whose length does not match the replicas that the same record sets. The bytes alone decide it, and Kafka treats the same content as a fatal decode failure.

Fields

field: &'static str

detail: String

Encode(String)

Decode(String)

UnknownAclId(Uuid)

A RemoveAccessControlEntry{{id}} referenced an ACL id absent from the image. On the Krabka-only path the matching add always precedes the remove in log order, so this means a corrupt or out-of-order log.

UnknownPrivateTag(u32)

A NoOpRecord carries one tagged field at a tag in the krabka-private range (1001 and up) that this build does not assign. 1002 is one: it is burned and no build writes it.

UnknownPrivateRecordVersion

The body of a krabka-private NoOpRecord tag starts with a version other than PRIVATE_RECORD_VERSION. A newer broker wrote it, or the metadata log predates krabka 1.0, whose bodies carry no version.

Fields

tag: u32

version: i16

PrivateTagMismatch

A krabka-private NoOpRecord tag carries a record that the tag table assigns to another tag (expected_tag), or to no tag (None).

Fields

tag: u32

expected_tag: Option<u32>

TrailingPrivateRecordBytes

The body of a krabka-private NoOpRecord tag holds trailing bytes after its record. A re-encode would drop them, so the body is refused.

Fields

tag: u32

trailing: usize

Trait Implementations

impl Debug for TranslateError

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

Formats the value using the given formatter.

impl Display for TranslateError

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

Formats the value using the given formatter.

impl Eq for TranslateError

impl Error for TranslateError

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 PartialEq for TranslateError

fn eq(&self, other: &TranslateError) -> 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 StructuralPartialEq for TranslateError