use thiserror::Error;
#[derive(Debug)]
pub struct CustomError {
pub message: String,
}
#[derive(Debug, Error)]
pub enum ConsumerError {
#[error("Processing failed for ticker {ticker_code}")]
TickerFailed { ticker_code: String },
#[error("Failed to get next ticker from data stream")]
StreamError(#[from] anyhow::Error),
}