Enum ClusterError 

pub enum ClusterError {
    SchedulerError(String),
    TaskNotFound(String),
    DependencyCycle(String),
    WorkerPoolError(String),
    WorkerNotFound(String),
    WorkerUnhealthy(String),
    CapacityExceeded(String),
    DataLocalityError(String),
    DataNotAvailable(String),
    FaultToleranceError(String),
    MaxRetriesExceeded(String),
    CheckpointError(String),
    CacheError(String),
    CoherencyViolation(String),
    ReplicationError(String),
    QuorumNotReached {
        required: usize,
        actual: usize,
    },
    ReplicaPlacementError(String),
    CoordinatorError(String),
    LeaderElectionFailed(String),
    NoLeader,
    ConsensusError(String),
    MetricsError(String),
    SerializationError(String),
    NetworkError(String),
    Timeout(String),
    ConfigError(String),
    ResourceExhausted(String),
    InvalidState(String),
    ExecutionError(String),
    TaskCancelled(String),
    Io(Error),
    Json(Error),
    RaftError(String),
    QuotaExceeded(String),
    ReservationNotFound(String),
    ResourceNotAvailable(String),
    InvalidOperation(String),
    InvalidConfiguration(String),
    WorkflowNotFound(String),
    MetricNotFound(String),
    AlertNotFound(String),
    AuthenticationFailed(String),
    PermissionDenied(String),
    SecretNotFound(String),
    CompressionError(String),
    Other(String),
}

Main error type for cluster operations.

Variants

SchedulerError(String)

Task scheduling errors

TaskNotFound(String)

Task not found

DependencyCycle(String)

Task dependency cycle detected

WorkerPoolError(String)

Worker pool errors

WorkerNotFound(String)

Worker not found

WorkerUnhealthy(String)

Worker unhealthy

CapacityExceeded(String)

Worker capacity exceeded

DataLocalityError(String)

Data locality errors

DataNotAvailable(String)

Data not available on any worker

FaultToleranceError(String)

Fault tolerance errors

MaxRetriesExceeded(String)

Maximum retries exceeded

CheckpointError(String)

Checkpoint error

CacheError(String)

Distributed cache errors

CoherencyViolation(String)

Cache coherency violation

ReplicationError(String)

Replication errors

QuorumNotReached

Quorum not reached

Fields

required: usize

The required quorum size

actual: usize

The actual number of responses received

ReplicaPlacementError(String)

Replica placement error

CoordinatorError(String)

Coordinator errors

LeaderElectionFailed(String)

Leader election failed

NoLeader

No leader available

ConsensusError(String)

Consensus error

MetricsError(String)

Metrics collection error

SerializationError(String)

Serialization/deserialization errors

NetworkError(String)

Network communication errors

Timeout(String)

Timeout error

ConfigError(String)

Configuration error

ResourceExhausted(String)

Resource exhausted

InvalidState(String)

Invalid state

ExecutionError(String)

Task execution error

TaskCancelled(String)

Task cancelled

Io(Error)

IO errors

Json(Error)

JSON errors

RaftError(String)

Raft errors

QuotaExceeded(String)

Quota errors

ReservationNotFound(String)

Reservation errors

ResourceNotAvailable(String)

Resource not available

InvalidOperation(String)

Invalid operation

InvalidConfiguration(String)

Invalid configuration

WorkflowNotFound(String)

Workflow errors

MetricNotFound(String)

Monitoring errors

AlertNotFound(String)

Alert not found

AuthenticationFailed(String)

Security errors

PermissionDenied(String)

Permission denied

SecretNotFound(String)

Secret not found

CompressionError(String)

Compression error

Other(String)

Other errors

Implementations

impl ClusterError

pub fn is_retryable(&self) -> bool

Check if the error is retryable.

pub fn is_permanent(&self) -> bool

Check if the error indicates a permanent failure.

pub fn requires_failover(&self) -> bool

Check if the error requires failover.

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

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for ClusterError

fn from(source: Error) -> Self

Converts to this type from the input type.