Enum MirrorError 

pub enum MirrorError {
    ClusterIdMismatch {
        declared: String,
        remote: String,
    },
    ObserverRoleViolation {
        detail: String,
    },
    SnapshotOffsetRegression {
        database_id: String,
        expected: u64,
        actual: u64,
    },
    SnapshotCrcMismatch {
        database_id: String,
        stored: u32,
        computed: u32,
    },
    HandshakeCodec {
        detail: String,
    },
    ProtocolVersionMismatch {
        local: u16,
        detail: String,
    },
    Transport {
        detail: String,
    },
    BytesInFlightCapExceeded {
        database_id: String,
        in_flight: u64,
        cap: u64,
    },
    MirrorPromoted {
        database_id: String,
    },
}

Errors produced by cross-cluster mirror operations.

These wrap into crate::error::ClusterError::Mirror at the public boundary so callers have a single error type to handle.

Variants

ClusterIdMismatch

The remote cluster refused our connection because the source_cluster we declared does not match their own cluster id.

Fields

declared: String

remote: String

ObserverRoleViolation

The remote cluster rejected the mirror link because the connecting peer presented Observer role credentials but tried to perform a voter operation (vote request, conf change, etc.).

Fields

detail: String

SnapshotOffsetRegression

Snapshot transfer was aborted because a chunk arrived out of order.

The receiver resets and requests a fresh snapshot from the source.

Fields

database_id: String

expected: u64

actual: u64

SnapshotCrcMismatch

Snapshot CRC validation failed at the final chunk.

Fields

database_id: String

stored: u32

computed: u32

HandshakeCodec

The cross-cluster handshake wire message could not be decoded.

Fields

detail: String

ProtocolVersionMismatch

The mirror declared a wire protocol version the source does not implement (or vice versa). Surfaced immediately without retry — the peers must be upgraded in lockstep.

Fields

local: u16

detail: String

Transport

QUIC transport error during cross-cluster operations.

Fields

detail: String

BytesInFlightCapExceeded

Observer-side bytes-in-flight cap was exceeded; the source should pause sending until the observer drains.

Fields

database_id: String

in_flight: u64

cap: u64

MirrorPromoted

The mirror is in Promoted state and can no longer accept replication.

Fields

database_id: String

Trait Implementations

impl Debug for MirrorError

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

Formats the value using the given formatter.

impl Display for MirrorError

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

Formats the value using the given formatter.

impl Error for MirrorError

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<MirrorError> for ClusterError

fn from(source: MirrorError) -> Self

Converts to this type from the input type.