Enum Error 

pub enum Error {
    MessageTooLarge {
        size: usize,
        max_size: usize,
    },
    MessageNotFound(MessageId),
    Encode(String),
    Decode(String),
    Send {
        target: String,
        reason: String,
    },
    Shutdown,
    NoPeers,
    Channel(String),
    QueueFull {
        dropped: usize,
        capacity: usize,
    },
    Memberlist(String),
    Config(String),
    Io(Error),
    Custom(String),
}

Errors that can occur during Plumtree operations.

Variants

MessageTooLarge

Message payload exceeds the configured maximum size.

Fields

size: usize

Size of the message in bytes.

max_size: usize

Maximum allowed size.

MessageNotFound(MessageId)

Message was not found in the cache.

Encode(String)

Failed to encode a message.

Decode(String)

Failed to decode a message.

Send

Network send operation failed.

Fields

target: String

Target node that we failed to send to.

reason: String

Underlying error message.

Shutdown

The Plumtree instance has been shut down.

NoPeers

No peers available for broadcast.

Channel(String)

Internal channel error.

QueueFull

Outgoing message queue is full (backpressure).

This error indicates the system is under load and the caller should back off and retry later.

Fields

dropped: usize

Number of messages that failed to queue.

capacity: usize

Current queue capacity.

Memberlist(String)

Memberlist operation failed.

Config(String)

Configuration error.

Io(Error)

Generic IO error.

Custom(String)

Custom error with message.

Implementations

impl Error

pub const fn kind(&self) -> ErrorKind

Get the classification of this error.

Returns ErrorKind::Transient for errors that may succeed if retried, or ErrorKind::Permanent for errors that will not succeed with retries.

pub const fn is_transient(&self) -> bool

Check if this error is transient (may succeed if retried).

Example

match plumtree.broadcast(payload).await {
    Ok(_) => {}
    Err(e) if e.is_transient() => {
        // Retry after a delay
        tokio::time::sleep(Duration::from_millis(100)).await;
        plumtree.broadcast(payload).await?;
    }
    Err(e) => return Err(e), // Permanent error, don't retry
}

pub const fn is_permanent(&self) -> bool

Check if this error is permanent (will not succeed with retries).

pub const fn is_shutdown(&self) -> bool

Check if this error indicates the system is shutting down.

pub fn is_resource_exhausted(&self) -> bool

Check if this is a rate limiting or resource exhaustion error.

pub const fn is_queue_full(&self) -> bool

Check if this is a queue full error (backpressure).

Trait Implementations

impl Debug for Error

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

Formats the value using the given formatter.

impl Display for Error

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

Formats the value using the given formatter.

impl Error for Error

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 Error

fn from(err: Error) -> Self

Converts to this type from the input type.

impl From<RecvError> for Error

fn from(err: RecvError) -> Self

Converts to this type from the input type.

impl<T> From<SendError<T>> for Error

fn from(err: SendError<T>) -> Self

Converts to this type from the input type.