Enum ProtocolContractViolation 

#[non_exhaustive]
pub enum ProtocolContractViolation {
    CheckpointSchemaVersion {
        expected: u16,
        actual: u16,
    },
    InvalidCheckpointField {
        field: &'static str,
        reason: &'static str,
    },
    InvalidCheckpointOffsets {
        reason: &'static str,
    },
    MissingStoreMembers,
    DuplicateStoreMember,
    CheckpointSetBindingMismatch {
        member: &'static str,
    },
    DestructiveRollback,
    RestoreVerificationIncomplete,
    Missing {
        header: &'static str,
        key: &'static str,
    },
    InvalidValue {
        header: &'static str,
        key: &'static str,
        expected: HeaderValueKind,
    },
    Conflict {
        header: &'static str,
        key: &'static str,
    },
    DynamicFieldConflict {
        header: &'static str,
        key: &'static str,
    },
    LegacyValidation {
        header: &'static str,
    },
    LegacyMapConversionFailed {
        header: &'static str,
    },
    Validation {
        header: &'static str,
        rule: &'static str,
    },
    JavaRange {
        header: &'static str,
        key: &'static str,
    },
    KeyLengthOverflow {
        header: &'static str,
        key: &'static str,
    },
    ValueLengthOverflow {
        header: &'static str,
        key: &'static str,
    },
    ExtensionFieldsLengthOverflow,
    DynamicKeyLengthOverflow,
    DynamicValueLengthOverflow,
    FastCodecUnavailable {
        header: &'static str,
    },
    InvalidSerializeType(InvalidRemotingSerializeType),
    RemotingDefaultsConflict(RemotingCommandDefaultsConflict),
    BlankSubscriptionGroup,
    SubscriptionGroupTooLong {
        max_length: usize,
    },
    SubscriptionGroupIllegalCharacters,
    DuplicateSubscriptionGroup,
}

A deterministic RocketMQ protocol contract violation.

Header variants contain only static schema metadata and never retain raw wire values. Typed configuration sources remain available through std::error::Error::source, while their text is excluded from this error’s fixed display messages.

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.

CheckpointSchemaVersion

A checkpoint uses an unsupported manifest schema version.

Fields

expected: u16

Supported schema version.

actual: u16

Version carried by the manifest.

InvalidCheckpointField

A checkpoint field violates a fixed validation rule.

Fields

field: &'static str

Stable field identifier.

reason: &'static str

Stable validation reason.

InvalidCheckpointOffsets

Checkpoint offsets violate a fixed ordering rule.

Fields

reason: &'static str

Stable offset-ordering reason.

MissingStoreMembers

A checkpoint set does not contain a Store member.

DuplicateStoreMember

A checkpoint set repeats a Store member.

CheckpointSetBindingMismatch

A checkpoint artifact does not match its set barrier.

Fields

member: &'static str

Static checkpoint member category.

DestructiveRollback

A checkpoint permits destructive rollback behavior.

RestoreVerificationIncomplete

Restore verification does not prove every required invariant.

Missing

A field declared as required was absent.

Fields

header: &'static str

Stable header type identifier.

key: &'static str

Canonical wire key.

InvalidValue

A present field could not be decoded as its declared wire type.

Fields

header: &'static str

Stable header type identifier.

key: &'static str

Canonical wire key.

expected: HeaderValueKind

Expected protocol value category.

Conflict

Canonical and alias keys carried different values.

Fields

header: &'static str

Stable header type identifier.

key: &'static str

Canonical wire key.

DynamicFieldConflict

A typed value and dynamic extension field disagreed.

Fields

header: &'static str

Stable header type identifier.

key: &'static str

Canonical wire key.

LegacyValidation

A legacy custom-header validation hook failed.

Fields

header: &'static str

Static Rust type name for the legacy header.

LegacyMapConversionFailed

A legacy header could not provide its compatibility map.

Fields

header: &'static str

Static Rust type name for the legacy header.

Validation

A header-specific validation rule failed.

Fields

header: &'static str

Stable header type identifier.

rule: &'static str

Static, non-sensitive validation rule identifier.

JavaRange

An unsigned Rust value exceeded its declared signed Java range.

Fields

header: &'static str

Stable header type identifier.

key: &'static str

Canonical wire key.

KeyLengthOverflow

A wire key cannot be represented by the ROCKETMQ binary format.

Fields

header: &'static str

Stable header type identifier.

key: &'static str

Canonical wire key.

ValueLengthOverflow

A wire value cannot be represented by the ROCKETMQ binary format.

Fields

header: &'static str

Stable header type identifier.

key: &'static str

Canonical wire key.

ExtensionFieldsLengthOverflow

The complete extension-field payload exceeded its signed length field.

DynamicKeyLengthOverflow

A dynamic extension-field key exceeded Java’s signed 16-bit length.

DynamicValueLengthOverflow

A dynamic extension-field value exceeded its signed 32-bit length.

FastCodecUnavailable

Direct binary encoding was requested for a header without that capability.

Fields

header: &'static str

Stable header type identifier.

InvalidSerializeType(InvalidRemotingSerializeType)

Process remoting configuration selects an unsupported serialization type.

RemotingDefaultsConflict(RemotingCommandDefaultsConflict)

Process remoting defaults conflict with an initialized value.

BlankSubscriptionGroup

A subscription-group name is blank.

SubscriptionGroupTooLong

A subscription-group name exceeds the supported length.

Fields

max_length: usize

Maximum accepted UTF-8 byte length.

SubscriptionGroupIllegalCharacters

A subscription-group name contains unsupported characters.

DuplicateSubscriptionGroup

A batch contains the same subscription-group name more than once.

Implementations

impl ProtocolContractViolation

pub const fn condition(&self) -> CanonicalCondition

Returns the protocol-independent condition for this violation.

Trait Implementations

impl Clone for ProtocolContractViolation

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProtocolContractViolation

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

Formats the value using the given formatter.

impl Display for ProtocolContractViolation

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

Formats the value using the given formatter.

impl Eq for ProtocolContractViolation

impl Error for ProtocolContractViolation

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<InvalidRemotingSerializeType> for ProtocolContractViolation

fn from(source: InvalidRemotingSerializeType) -> Self

Converts to this type from the input type.

impl From<RemotingCommandDefaultsConflict> for ProtocolContractViolation

fn from(source: RemotingCommandDefaultsConflict) -> Self

Converts to this type from the input type.

impl PartialEq for ProtocolContractViolation

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ProtocolContractViolation