Enum PipelineError 

pub enum PipelineError {
    InvalidConfiguration(String),
    MissingParameter(String),
    InvalidParameter(String),
    IncompatibleStage(String),
    InvalidChunk(String),
    ProcessingFailed(String),
    CompressionError(String),
    EncryptionError(String),
    IntegrityError(String),
    SecurityViolation(String),
    ResourceExhausted(String),
    IoError(String),
    DatabaseError(String),
    SerializationError(String),
    ValidationError(String),
    PluginError(String),
    TimeoutError(String),
    Cancelled(String),
    PipelineNotFound(String),
    InternalError(String),
    MetricsError(String),
}

Domain-specific errors for the pipeline processing system.

This enum represents all possible errors that can occur within the domain layer. Each variant includes a descriptive message and is designed to provide clear information about what went wrong and potentially how to fix it.

Design Principles

• Specific: Each error type represents a specific failure mode
• Actionable: Error messages provide enough context for debugging
• Categorized: Errors are grouped by type for systematic handling
• Recoverable: Some errors indicate retry-able conditions

Error Handling Strategy

Variants

InvalidConfiguration(String)

MissingParameter(String)

InvalidParameter(String)

IncompatibleStage(String)

InvalidChunk(String)

ProcessingFailed(String)

CompressionError(String)

EncryptionError(String)

IntegrityError(String)

SecurityViolation(String)

ResourceExhausted(String)

IoError(String)

DatabaseError(String)

SerializationError(String)

ValidationError(String)

PluginError(String)

TimeoutError(String)

Cancelled(String)

PipelineNotFound(String)

InternalError(String)

MetricsError(String)

Implementations

impl PipelineError

pub fn invalid_config(msg: impl Into<String>) -> Self

Creates a new configuration error

pub fn processing_failed(msg: impl Into<String>) -> Self

Creates a new processing error

pub fn security_violation(msg: impl Into<String>) -> Self

Creates a new security violation error

pub fn resource_exhausted(msg: impl Into<String>) -> Self

Creates a new resource exhausted error

pub fn io_error(msg: impl Into<String>) -> Self

Creates a new IO error

pub fn database_error(msg: impl Into<String>) -> Self

Creates a new database error

pub fn internal_error(msg: impl Into<String>) -> Self

Creates a new internal error

pub fn metrics_error(msg: impl Into<String>) -> Self

Creates a new metrics error

pub fn validation_error(msg: impl Into<String>) -> Self

Creates a new validation error

pub fn cancelled() -> Self

Creates a cancellation error with default message

pub fn cancelled_with_msg(msg: impl Into<String>) -> Self

Creates a cancellation error with custom message

pub fn is_recoverable(&self) -> bool

Checks if the error is recoverable

pub fn is_security_error(&self) -> bool

Checks if the error is a security-related error

pub fn category(&self) -> &'static str

Gets the error category

Trait Implementations

impl Clone for PipelineError

fn clone(&self) -> PipelineError

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineError

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

Formats the value using the given formatter.

impl Display for PipelineError

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

Formats the value using the given formatter.

impl Error for PipelineError

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 PipelineError

fn from(err: Error) -> Self

Converts to this type from the input type.

impl From<Error> for PipelineError

fn from(err: Error) -> Self

Converts to this type from the input type.