fluvio_compression/
error.rs

1#[cfg(feature = "compress")]
2use bytes::buf::Writer;
3
4#[cfg(feature = "compress")]
5use bytes::BytesMut;
6
7#[cfg(feature = "compress")]
8use snap::write::{IntoInnerError, FrameEncoder};
9
10#[derive(thiserror::Error, Debug)]
11pub enum CompressionError {
12    #[error(transparent)]
13    IoError(#[from] std::io::Error),
14    #[error("Unreachable error")]
15    UnreachableError,
16    #[error("unknown compression format: {0}")]
17    UnknownCompressionFormat(String),
18    #[error("error flushing Snap encoder: {0}")]
19    #[cfg(feature = "compress")]
20    SnapError(#[from] Box<IntoInnerError<FrameEncoder<Writer<BytesMut>>>>),
21    #[error("error flushing Snap encoder: {0}")]
22    #[cfg(feature = "compress")]
23    Lz4Error(#[from] lz4_flex::frame::Error),
24}