Enum NormalizedProtocolError 

pub enum NormalizedProtocolError {
    InvalidSchema(NormalizedSchemaError),
    ComparatorMismatch {
        expected: u32,
        got: u32,
    },
    FpMismatch {
        expected: u64,
        got: u64,
    },
    EpochMismatch {
        expected: u64,
        got: u64,
    },
    Gap {
        expected: u64,
        got: u64,
    },
}

A protocol violation the NormalizedSubscriber surfaces. All but a duplicate are fatal — the only repair is a re-hydrate under a new epoch (§5.3).

Variants

InvalidSchema(NormalizedSchemaError)

The hello’s table set is not a valid normalized wire schema. Validation happens before fingerprinting so an attacker-controlled primary-key index can never reach columns[pk] and panic.

ComparatorMismatch

The hello’s comparator-contract version differs — reconstruction would silently corrupt, so the subscription is refused (a code contract, not data).

Fields

expected: u32

got: u32

FpMismatch

The advertised / batch fingerprint differs from the subscribed schema.

Fields

expected: u64

got: u64

EpochMismatch

A batch from a different (usually stale) subscription epoch.

Fields

expected: u64

got: u64

Gap

A seq beyond the next expected ⇒ a batch was lost. Re-hydrate. (expected is the next seq the receiver wanted.)

Fields

expected: u64

got: u64

Trait Implementations

impl Clone for NormalizedProtocolError

fn clone(&self) -> NormalizedProtocolError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NormalizedProtocolError

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

Formats the value using the given formatter.

impl PartialEq for NormalizedProtocolError

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

impl Eq for NormalizedProtocolError

impl StructuralPartialEq for NormalizedProtocolError