Enum ClusterError 

pub enum ClusterError {
    Raft(RaftError),
    VShardNotMapped {
        vshard_id: u32,
    },
    GroupNotFound {
        group_id: u64,
    },
    MigrationInProgress {
        vshard_id: u32,
    },
    MigrationPauseBudgetExceeded {
        estimated_us: u64,
        budget_us: u64,
    },
    NodeUnreachable {
        node_id: u64,
    },
    GhostNotFound {
        node_id: String,
        shard_id: u32,
    },
    Transport {
        detail: String,
    },
    StreamTerminal {
        error: TypedClusterError,
        detail: String,
    },
    Storage {
        detail: String,
    },
    Codec {
        detail: String,
    },
    UnsupportedWireVersion {
        got: u8,
        supported_min: u8,
        supported_max: u8,
    },
    CircuitOpen {
        node_id: u64,
        failures: u32,
    },
    JoinGroupDisappeared {
        group_id: u64,
    },
    JoinCommitTimeout {
        group_id: u64,
        log_index: u64,
    },
    Config {
        detail: String,
    },
    MigrationCheckpoint(MigrationCheckpointError),
    MigrationRecovery(MigrationRecoveryError),
    WrongOwner {
        vshard_id: u32,
        expected_owner_node: Option<u64>,
    },
    Calvin(CalvinError),
    SnapshotCrcMismatch {
        group_id: u64,
        stored: u32,
        computed: u32,
    },
    SnapshotOffsetRegression {
        group_id: u64,
        expected: u64,
        actual: u64,
    },
    PartialSnapshotCorrupt {
        group_id: u64,
        detail: String,
    },
    PartialSnapshotCleanupFailed {
        group_id: u64,
        detail: String,
    },
    SnapshotApplyFailed {
        group_id: u64,
        detail: String,
    },
    Mirror(MirrorError),
}

Variants

Raft(RaftError)

VShardNotMapped

Fields

vshard_id: u32

GroupNotFound

Fields

group_id: u64

MigrationInProgress

Fields

vshard_id: u32

MigrationPauseBudgetExceeded

Fields

estimated_us: u64

budget_us: u64

NodeUnreachable

Fields

node_id: u64

GhostNotFound

Fields

node_id: String

shard_id: u32

Transport

Fields

detail: String

StreamTerminal

Terminal error carried by a streaming ExecuteStreamEnd frame.

Preserves the typed shape end-to-end so the coordinator can map a pre-row NotLeader / DescriptorMismatch back to a retryable error (retry only applies before the first row — see the coordinator’s dispatch_remote_stream). detail is the Debug rendering for logs.

Fields

error: TypedClusterError

detail: String

Storage

Fields

detail: String

Codec

Fields

detail: String

UnsupportedWireVersion

Fields

got: u8

supported_min: u8

supported_max: u8

CircuitOpen

Fields

node_id: u64

failures: u32

JoinGroupDisappeared

Fields

group_id: u64

JoinCommitTimeout

Fields

group_id: u64

log_index: u64

Config

Fields

detail: String

MigrationCheckpoint(MigrationCheckpointError)

MigrationRecovery(MigrationRecoveryError)

WrongOwner

A shard RPC was routed to a node that no longer owns the target vShard.

This surfaces when vShard ownership has transferred (rebalance or split cut-over) after the coordinator computed its routing plan. The coordinator must refresh its routing table and retry against the new owner.

expected_owner_node is Some when the receiving shard knows who the current owner is, and None when it does not (e.g. during a brief transition window). Either way, the coordinator should re-derive the owner from its local routing table — expected_owner_node is advisory only.

Fields

vshard_id: u32

expected_owner_node: Option<u64>

Calvin(CalvinError)

SnapshotCrcMismatch

Fields

group_id: u64

stored: u32

computed: u32

SnapshotOffsetRegression

Fields

group_id: u64

expected: u64

actual: u64

PartialSnapshotCorrupt

Fields

group_id: u64

detail: String

PartialSnapshotCleanupFailed

Fields

group_id: u64

detail: String

SnapshotApplyFailed

Fields

group_id: u64

detail: String

Mirror(MirrorError)

Trait Implementations

impl Debug for ClusterError

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

Formats the value using the given formatter.

impl Display for ClusterError

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

Formats the value using the given formatter.

impl Error for ClusterError

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

fn from(e: BootstrapError) -> Self

Converts to this type from the input type.

impl From<CalvinError> for ClusterError

fn from(source: CalvinError) -> Self

Converts to this type from the input type.

impl From<ClusterError> for VectorSeamError

fn from(source: ClusterError) -> Self

Converts to this type from the input type.

impl From<DecommissionSafetyError> for ClusterError

fn from(value: DecommissionSafetyError) -> Self

Converts to this type from the input type.

impl From<MigrationCheckpointError> for ClusterError

fn from(source: MigrationCheckpointError) -> Self

Converts to this type from the input type.

impl From<MigrationRecoveryError> for ClusterError

fn from(source: MigrationRecoveryError) -> Self

Converts to this type from the input type.

impl From<MirrorError> for ClusterError

fn from(source: MirrorError) -> Self

Converts to this type from the input type.

impl From<RaftError> for ClusterError

fn from(source: RaftError) -> Self

Converts to this type from the input type.

impl From<ShutdownError> for ClusterError

fn from(e: ShutdownError) -> Self

Converts to this type from the input type.

impl From<SwimError> for ClusterError

fn from(err: SwimError) -> Self

Converts to this type from the input type.

impl From<TopoError> for ClusterError

fn from(e: TopoError) -> Self

Converts to this type from the input type.

impl From<WireVersionError> for ClusterError

fn from(e: WireVersionError) -> Self

Converts to this type from the input type.