1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

error_chain! {
    foreign_links {
        Io(::std::io::Error);
    }

    links {
        Kafka(::kafka::error::Error, ::kafka::error::ErrorKind) #[cfg(feature="with_kafka")];
    }

    errors {
        #[cfg(feature="with_kafka")]
        KafkaInitializeError(e: ::kafka::Error) {
            description("couldn't initialize kafka consumer")
            display("couldn't initialize kafka consumer: {}", e)
        }
        VarintDecodeError(e: ::std::io::Error) {
            description("couldn't decode leading varint")
            display("couldn't decode leading varint: '{}'", e)
        }
        InvalidStreamTypeError(t: String) {
            description("invalid stream type")
            display("invalid stream type: {} ((only support single, leb128, varint)", t)
        }
        VarintDecodeMaxBytesError {
            description("exceeded max attempts to decode leading varint")
            display("exceeded max attempts to decode leading varint")
        }
    }
}