Enum SubscriptionContractError 

pub enum SubscriptionContractError {
    ProtocolVersion {
        actual: u16,
        expected: u16,
    },
    DistributionCertificateVersion {
        actual: u16,
        expected: u16,
    },
    ZeroDigest {
        field: &'static str,
    },
    ZeroCatalogGeneration,
    NonCanonicalIdentity {
        field: &'static str,
        max_bytes: usize,
    },
    PipelineIdentity,
    PartitionAbi {
        actual: u16,
        expected: u16,
    },
    VnodeCount {
        actual: u16,
        expected: u16,
    },
    PartitionOutOfRange {
        partition: u16,
        vnode_count: u16,
    },
    NonCanonicalSingleton {
        partition: u16,
    },
    DistributionCertificateMismatch,
    SequenceOverflow,
    CheckpointAttempt,
    AssignmentCertificate,
    GenerationMismatch,
    SchemaMismatch,
    NonCanonicalFrontiers,
    MissingPartitionFrontier,
    NonCanonicalObjectKey,
    InvalidSegmentRange,
    NonCanonicalSegments,
    OverlappingSegments,
    SegmentBeyondFrontier,
    TooManySegments {
        actual: usize,
        limit: usize,
    },
    ManifestTooLarge {
        actual: usize,
        limit: usize,
    },
    Encode(String),
    ManifestDigest,
    NonCanonicalNodeStreams,
    NonCanonicalPartitionRanges,
    PartitionOwnerMismatch {
        partition: u16,
    },
    NodeParticipant,
    NodeManifestDigest,
    SequenceGap {
        partition: u16,
        expected: u64,
        actual: u64,
    },
}

Structured validation failure for durable subscription contracts.

Variants

ProtocolVersion

Unsupported persisted or wire protocol.

Fields

actual: u16

Decoded protocol version.

expected: u16

Runtime protocol version.

DistributionCertificateVersion

Unsupported planner certificate encoding.

Fields

actual: u16

Decoded certificate version.

expected: u16

Runtime certificate version.

ZeroDigest

Digest is the reserved all-zero value.

Fields

field: &'static str

Field containing the reserved digest.

ZeroCatalogGeneration

Catalog generations begin at one.

NonCanonicalIdentity

Catalog or graph identity is empty, padded, or oversized.

Fields

field: &'static str

Identity field.

max_bytes: usize

Hard encoded bound.

PipelineIdentity

Pipeline identity is not canonical.

PartitionAbi

Stable partitioning ABI differs.

Fields

actual: u16

Persisted ABI.

expected: u16

Runtime ABI.

VnodeCount

Certified vnode domain differs.

Fields

actual: u16

Certified vnode count.

expected: u16

Runtime vnode count.

PartitionOutOfRange

Output partition lies outside its certified vnode domain.

Fields

partition: u16

Invalid partition.

vnode_count: u16

Exclusive vnode-domain end.

NonCanonicalSingleton

Global singleton output must use vnode zero.

Fields

partition: u16

Invalid singleton partition.

DistributionCertificateMismatch

Restored and planned certificates are not identical.

SequenceOverflow

Partition sequence cannot advance without wrapping.

CheckpointAttempt

Checkpoint attempt is zero or internally inconsistent.

AssignmentCertificate

Assignment fence is absent or malformed.

GenerationMismatch

Generation binding differs.

SchemaMismatch

User schema fingerprint differs.

NonCanonicalFrontiers

Frontier vector is not sorted and duplicate-free.

MissingPartitionFrontier

Complete certified partition roster is absent.

NonCanonicalObjectKey

Segment object key is not a bounded provider-neutral relative path.

InvalidSegmentRange

Segment range or counts are inconsistent.

NonCanonicalSegments

Segment references are not canonically sorted and unique.

OverlappingSegments

Segment ranges overlap within one partition.

SegmentBeyondFrontier

Segment extends beyond the checkpoint frontier.

TooManySegments

Segment reference count exceeds the hard limit.

Fields

actual: usize

Segment count.

limit: usize

Hard segment-count bound.

ManifestTooLarge

Encoded manifest exceeds the hard limit.

Fields

actual: usize

Encoded byte count.

limit: usize

Hard encoded-size bound.

Encode(String)

Canonical metadata encoding failed.

ManifestDigest

Manifest body does not match its content digest.

NonCanonicalNodeStreams

Participant-local stream inventory is not sorted and unique.

NonCanonicalPartitionRanges

Participant-local partition ranges are not sorted and unique.

PartitionOwnerMismatch

A participant claimed an output partition it does not own.

Fields

partition: u16

Partition claimed by the wrong participant.

NodeParticipant

Participant identity is missing from its assignment certificate.

NodeManifestDigest

Participant manifest body does not match its content digest.

SequenceGap

A committed partition interval is discontinuous.

Fields

partition: u16

Partition containing the gap.

expected: u64

Required next sequence.

actual: u64

Observed next sequence.

Trait Implementations

impl Clone for SubscriptionContractError

fn clone(&self) -> SubscriptionContractError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionContractError

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

Formats the value using the given formatter.

impl Display for SubscriptionContractError

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

Formats the value using the given formatter.

impl Eq for SubscriptionContractError

impl Error for SubscriptionContractError

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 SubscriptionContractError

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SubscriptionContractError