Enum RepError 

pub enum RepError {
    NotMaster {
        master: Option<String>,
    },
    NotReplica,
    GroupNotFound(String),
    NodeNotFound(String),
    ElectionFailed(String),
    InsufficientAcks {
        needed: u32,
        received: u32,
    },
    ConsistencyTimeout(Duration),
    ReplicaLagExceeded {
        lag_ms: u64,
        limit_ms: u64,
    },
    RollbackRequired {
        from: i64,
        to: i64,
    },
    NetworkError(String),
    FrameCorrupted {
        vlsn: u64,
        expected: u32,
        actual: u32,
    },
    ProtocolError(String),
    StateError(String),
    DatabaseError(String),
    ConfigError(String),
    ShutdownInProgress,
    InvalidStateTransition(String),
    NodeAlreadyExists(String),
    ChannelClosed(String),
    ServiceNotFound(String),
    SubscriptionError(String),
    NetworkRestoreError(String),
    EnvironmentClosed,
    InvalidState(String),
}

Errors that can occur during replication operations.

Variants

NotMaster

The node is not the master. Thrown when a write operation is attempted on a replica node.

Fields

master: Option<String>

The name of the current master, if known.

NotReplica

The node is not a replica. Thrown when a replica-only operation is attempted on the master.

GroupNotFound(String)

The replication group does not exist. (group aspect).

NodeNotFound(String)

A node was not found in the replication group.

ElectionFailed(String)

An election failed to produce a master.

InsufficientAcks

Insufficient replica acknowledgments for a commit.

Fields

needed: u32

Number of acks required by the durability policy.

received: u32

Number of acks actually received.

ConsistencyTimeout(Duration)

A replica consistency policy timed out.

ReplicaLagExceeded

The replica’s replication lag exceeds the configured limit.

Fields

lag_ms: u64

Current lag in milliseconds.

limit_ms: u64

Configured limit in milliseconds.

RollbackRequired

A hard rollback is required on the replica.

Fields

from: i64

The VLSN sequence to roll back from.

to: i64

The VLSN sequence to roll back to.

NetworkError(String)

A network-level error occurred.

FrameCorrupted

A replication frame failed CRC32 verification.

Indicates in-flight corruption (hardware error, kernel bug, or an adversarial sender). The receiver closes the channel when this occurs.

Fields

vlsn: u64

expected: u32

actual: u32

ProtocolError(String)

A replication protocol error occurred (unexpected message, version mismatch, etc.).

StateError(String)

The node is in an invalid state for the requested operation.

DatabaseError(String)

An underlying database error occurred.

ConfigError(String)

A configuration error was detected.

ShutdownInProgress

The node is shutting down and cannot accept new operations.

InvalidStateTransition(String)

Invalid state transition attempted.

NodeAlreadyExists(String)

A node with the same name already exists in the group.

ChannelClosed(String)

A network channel has been closed.

ServiceNotFound(String)

A requested service was not found.

SubscriptionError(String)

A subscription error occurred.

NetworkRestoreError(String)

A network restore error occurred.

EnvironmentClosed

The environment has been closed.

InvalidState(String)

The node is in an invalid state.

Trait Implementations

impl Debug for RepError

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

Formats the value using the given formatter.

impl Display for RepError

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

Formats the value using the given formatter.

impl Error for RepError

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.