Enum PolarisError 

#[non_exhaustive]
pub enum PolarisError {
    ConnectionFailed(String),
    SchedulingFailed(String),
    TaskExecutionFailed(String),
    TaskTimeout(Duration),
    NodeNotFound(String),
    NodeUnavailable(String),
    InvalidConfig(String),
    SerializationError(String),
    NetworkError(String),
    StorageError(String),
    AuthenticationFailed(String),
    AuthorizationFailed(String),
    ResourceLimitExceeded(String),
    DagCycleDetected,
    InvalidStateTransition {
        from: String,
        to: String,
    },
    Io(Error),
    Other(String),
}

The main error type for Polaris operations.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

ConnectionFailed(String)

Error connecting to cluster

SchedulingFailed(String)

Error during task scheduling

TaskExecutionFailed(String)

Task execution error

TaskTimeout(Duration)

Task timeout

NodeNotFound(String)

Node not found

NodeUnavailable(String)

Node unavailable

InvalidConfig(String)

Invalid configuration

SerializationError(String)

Serialization error

NetworkError(String)

Network error

StorageError(String)

Storage error

AuthenticationFailed(String)

Authentication error

AuthorizationFailed(String)

Authorization error

ResourceLimitExceeded(String)

Resource limit exceeded

DagCycleDetected

DAG cycle detected

InvalidStateTransition

Invalid task state transition

Fields

from: String

Current state

to: String

Attempted new state

Io(Error)

IO error

Other(String)

Other error

Implementations

impl PolarisError

pub fn connection_failed(msg: impl Display) -> PolarisError

Create a connection error

pub fn scheduling_failed(msg: impl Display) -> PolarisError

Create a scheduling error

pub fn task_execution_failed(msg: impl Display) -> PolarisError

Create a task execution error

pub fn network_error(msg: impl Display) -> PolarisError

Create a network error

pub fn storage_error(msg: impl Display) -> PolarisError

Create a storage error

pub fn other(msg: impl Display) -> PolarisError

Create an other error

Trait Implementations

impl Debug for PolarisError

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

Formats the value using the given formatter.

impl Display for PolarisError

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

Formats the value using the given formatter.

impl Error for PolarisError

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 PolarisError

fn from(source: Error) -> PolarisError

Converts to this type from the input type.