Enum ErrorAction 

pub enum ErrorAction {
    Stop,
    Skip,
    Retry,
}

Action to take when an error occurs in a pipeline component.

This enum is used by error strategies to determine how to handle errors during stream processing.

Example

use streamweave::error::ErrorAction;

// Stop processing on error
let action = ErrorAction::Stop;

// Skip the item and continue
let action = ErrorAction::Skip;

// Retry the operation
let action = ErrorAction::Retry;

Variants

Stop

Stop processing immediately when an error occurs.

This is the default behavior and ensures data integrity by preventing partial results after an error.

Skip

Skip the item that caused the error and continue processing.

Useful for non-critical errors where partial results are acceptable.

Retry

Retry the operation that caused the error.

Useful for transient failures that may succeed on retry.

Trait Implementations

impl Clone for ErrorAction

fn clone(&self) -> ErrorAction

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ErrorAction

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

Formats the value using the given formatter.

impl PartialEq for ErrorAction

fn eq(&self, other: &ErrorAction) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ErrorAction