Enum ProtocolError 

pub enum ProtocolError {
    ComparatorMismatch {
        expected: u32,
        got: u32,
    },
    EpochMismatch {
        expected: u64,
        got: u64,
    },
    SchemaMismatch {
        expected: SchemaFp,
        got: SchemaFp,
    },
    Gap {
        expected: u64,
        got: u64,
    },
}

A protocol violation a Subscriber surfaces. All but a duplicate are fatal to the current subscription — the consumer must discard its tree and re-subscribe (the sender re-hydrates under a new epoch).

Variants

ComparatorMismatch

The sender’s comparator contract differs — reconstruction would silently corrupt.

Fields

expected: u32

got: u32

EpochMismatch

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

Fields

expected: u64

got: u64

SchemaMismatch

The batch (or advertised) schema fingerprint differs from the subscribed one.

Fields

expected: SchemaFp

got: SchemaFp

Gap

A seq beyond the next expected ⇒ a batch was lost. Unrecoverable from deltas; re-hydrate. (expected is the next seq the receiver wanted.)

Fields

expected: u64

got: u64

Trait Implementations

impl Clone for ProtocolError

fn clone(&self) -> ProtocolError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProtocolError

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

Formats the value using the given formatter.

impl PartialEq for ProtocolError

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

impl StructuralPartialEq for ProtocolError