dge_runtime/
error.rs

1use lapin;
2use thiserror;
3
4pub type Result<T> = std::result::Result<T, Error>;
5
6#[derive(Debug, thiserror::Error)]
7pub enum Error {
8    // runtime errors
9    #[error("Failed to publish to {}, error: {}", .queue, .error)]
10    FailedToPublishRmqMsg { queue: String, error: String },
11
12    #[error(transparent)]
13    RabbitMQError(#[from] lapin::Error),
14
15    // errors returned by user functions
16    #[error("User error: {}", .error)]
17    UserError { error: String },
18}