iconoclast 0.3.0

Reusable code for Rust-based business μServices
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use rdkafka::error::KafkaError;
use std::error::Error;

/// possible errors when consuming kafka messages
#[derive(thiserror::Error, Debug)]
pub enum StreamError<DE: Error, AE: Error> {
    #[error(transparent)]
    Kafka(#[from] KafkaError),

    #[error(transparent)]
    Application(AE),

    #[error(transparent)]
    Decode(DE),
}