Enum DistributedError 

pub enum DistributedError {
    Io(Error),
    ConnectionFailed {
        addr: SocketAddr,
        reason: String,
    },
    ConnectionTimeout(SocketAddr, Duration),
    ConnectionRefused(SocketAddr),
    MaxRetriesExceeded {
        addr: SocketAddr,
        max_retries: u32,
    },
    PeerLost(PeerId),
    PeerIncoherentData {
        peer: PeerId,
        expected: usize,
        actual: usize,
    },
    UnknownPeer(PeerId),
    PeerUnreachable(PeerId),
    PeerTimeout {
        peer: PeerId,
        operation: String,
    },
    AllReduceBeforeRegister,
    NotRegisteredOnFinish,
    DoubleRegister,
    RegisterParamsMismatch(String),
    AllReduceParamsMismatch {
        local: usize,
        expected: usize,
    },
    RingReduceImpossible(usize),
    BufferAlignment {
        expected: usize,
        actual: usize,
    },
    BufferSize {
        expected: usize,
        actual: usize,
    },
    InsufficientNodes {
        have: usize,
        need: usize,
    },
    RingNotEstablished,
    TopologyChanged,
    NoRoute(PeerId),
    ElectionTimeout(Duration),
    SplitBrain(Vec<PeerId>),
    NoMaster,
    MasterUnreachable(PeerId),
    Protocol(String),
    InvalidMessage {
        expected: String,
        actual: String,
    },
    FirstMsgNotInit,
    VersionMismatch {
        local: String,
        remote: String,
    },
    NamespaceMismatch {
        expected: String,
        actual: String,
    },
    Config(String),
    InvalidAddress(String),
    PortInUse(u16),
    Serialization(Error),
    HealthCheckFailed {
        peer: PeerId,
        reason: String,
    },
    HeartbeatTimeout(PeerId, Duration),
    ShuttingDown,
    Cancelled,
}

Errors that can occur during distributed operations.

Variants

Io(Error)

ConnectionFailed

Fields

addr: SocketAddr

reason: String

ConnectionTimeout(SocketAddr, Duration)

ConnectionRefused(SocketAddr)

MaxRetriesExceeded

Fields

addr: SocketAddr

max_retries: u32

PeerLost(PeerId)

PeerIncoherentData

Fields

peer: PeerId

expected: usize

actual: usize

UnknownPeer(PeerId)

PeerUnreachable(PeerId)

PeerTimeout

Fields

peer: PeerId

operation: String

AllReduceBeforeRegister

NotRegisteredOnFinish

DoubleRegister

RegisterParamsMismatch(String)

AllReduceParamsMismatch

Fields

local: usize

expected: usize

RingReduceImpossible(usize)

BufferAlignment

Fields

expected: usize

actual: usize

BufferSize

Fields

expected: usize

actual: usize

InsufficientNodes

Fields

have: usize

need: usize

RingNotEstablished

TopologyChanged

NoRoute(PeerId)

ElectionTimeout(Duration)

SplitBrain(Vec<PeerId>)

NoMaster

MasterUnreachable(PeerId)

Protocol(String)

InvalidMessage

Fields

expected: String

actual: String

FirstMsgNotInit

VersionMismatch

Fields

local: String

remote: String

NamespaceMismatch

Fields

expected: String

actual: String

Config(String)

InvalidAddress(String)

PortInUse(u16)

Serialization(Error)

HealthCheckFailed

Fields

peer: PeerId

reason: String

HeartbeatTimeout(PeerId, Duration)

ShuttingDown

Cancelled

Implementations

impl DistributedError

pub fn is_recoverable(&self) -> bool

Check if this error is recoverable (can retry).

pub fn is_peer_failure(&self) -> bool

Check if this error indicates a peer failure.

pub fn is_fatal(&self) -> bool

Check if this error is fatal (cannot continue).

pub fn peer_id(&self) -> Option<&PeerId>

Get the peer ID associated with this error, if any.

Trait Implementations

impl Debug for DistributedError

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

Formats the value using the given formatter.

impl Display for DistributedError

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

Formats the value using the given formatter.

impl Error for DistributedError

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 DistributedError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for DistributedError

fn from(source: Error) -> Self

Converts to this type from the input type.