Enum ReplicaError 

pub enum ReplicaError {
    HandshakeRejected,
    AckMalformed,
    Truncated,
    Frame(WireError),
    OffsetGap {
        expected: u64,
        got: u64,
    },
    UnexpectedInSnapshot,
    SnapshotInProgress,
    Io(Error),
}

Errors a replica client can surface to its driver loop.

Variants

HandshakeRejected

Primary closed the connection or never replied during the handshake / +ACK exchange.

AckMalformed

+ACK line was malformed (didn’t start with +ACK , didn’t parse the offset).

Truncated

Peer closed the connection mid-frame; reconnect to resume.

Frame(WireError)

Wire-level decode error (envelope shape wrong, payload malformed, etc.).

OffsetGap

Frame arrived with an offset other than the expected next. Caller should trigger a full snapshot resync (T1.22).

Fields

expected: u64

The offset the client expected next (= last_seen + 1).

got: u64

The offset the primary actually sent.

UnexpectedInSnapshot

While streaming a snapshot, the primary sent bytes that were neither a snapshot chunk nor +SNAPSHOT_END. v1.18.0 forbids interleaving live frames inside a snapshot (see docs/snapshot.md).

SnapshotInProgress

next_frame was called but the next event is a snapshot marker / chunk. Callers that want the snapshot-aware surface must use ReplicaClient::next_event.

Io(Error)

Underlying socket I/O failure.

Trait Implementations

impl Debug for ReplicaError

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

Formats the value using the given formatter.

impl Display for ReplicaError

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

Formats the value using the given formatter.

impl Error for ReplicaError

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<Error> for ReplicaError

fn from(e: Error) -> Self

Converts to this type from the input type.

impl From<WireError> for ReplicaError

fn from(e: WireError) -> Self

Converts to this type from the input type.