Struct StreamError 

pub struct StreamError<T: Debug + Clone + Send + Sync> {
    pub source: Box<dyn Error + Send + Sync>,
    pub context: ErrorContext<T>,
    pub component: ComponentInfo,
    pub retries: usize,
}

Error that occurred during stream processing.

This error type provides rich context about where and when an error occurred, making it easier to debug and handle errors appropriately.

Fields

• source - The original error that occurred
• context - Context about when and where the error occurred
• component - Information about the component that encountered the error
• retries - Number of times this error has been retried

Example

use streamweave::error::{StreamError, ErrorContext, ComponentInfo};
use std::error::Error;

let error = StreamError::new(
    Box::new(std::io::Error::new(std::io::ErrorKind::NotFound, "File not found")),
    ErrorContext {
        timestamp: chrono::Utc::now(),
        item: Some(42),
        component_name: "FileProducer".to_string(),
        component_type: "Producer".to_string(),
    },
    ComponentInfo {
        name: "file-producer".to_string(),
        type_name: "FileProducer".to_string(),
    },
);

Fields

source: Box<dyn Error + Send + Sync>

The original error that occurred.

context: ErrorContext<T>

Context about when and where the error occurred.

component: ComponentInfo

Information about the component that encountered the error.

retries: usize

Number of times this error has been retried.

Implementations

impl<T: Debug + Clone + Send + Sync> StreamError<T>

pub fn new( source: Box<dyn Error + Send + Sync>, context: ErrorContext<T>, component: ComponentInfo, ) -> Self

Creates a new StreamError with the given source error, context, and component information.

Arguments

• source - The original error that occurred.
• context - Context about when and where the error occurred.
• component - Information about the component that encountered the error.

Returns

A new StreamError with retries set to 0.

Trait Implementations

impl<T: Debug + Clone + Send + Sync> Clone for StreamError<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Debug + Clone + Send + Sync> Debug for StreamError<T>

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

Formats the value using the given formatter.

impl<T: Debug + Clone + Send + Sync> Display for StreamError<T>

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

Formats the value using the given formatter.

impl<T: Debug + Clone + Send + Sync> Error for StreamError<T>

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.