Skip to main content

tsuzuri_dynamodb/
error.rs

1use tsuzuri::{integration::error::IntegrationError, projection::error::ProjectionError};
2
3#[derive(thiserror::Error, Debug)]
4pub enum StreamProcessorError {
5    #[error("Kinesis Data Streams error: {0}")]
6    KinesisDataStreams(String),
7
8    #[error("DynamoDB Streams error: {0}")]
9    DynamoDbStreams(String),
10
11    #[error("Tsuzuri projection error: {0}")]
12    Projection(#[from] ProjectionError),
13
14    #[error("Tsuzuri integration error: {0}")]
15    Integration(#[from] IntegrationError),
16
17    #[error("Invalid data: {0}")]
18    InvalidData(String),
19}
20
21pub type Result<T> = std::result::Result<T, StreamProcessorError>;