re_log_encoding/codec/
mod.rs

1pub(crate) mod arrow;
2pub mod file;
3pub mod wire;
4
5#[derive(Debug, thiserror::Error)]
6pub enum CodecError {
7    #[error("Arrow IPC serialization error: {0}")]
8    ArrowSerialization(::arrow::error::ArrowError),
9
10    #[error("Invalid Chunk: {0}")]
11    InvalidChunk(::arrow::error::ArrowError),
12
13    #[error("Arrow IPC deserialization error: {0}")]
14    ArrowDeserialization(::arrow::error::ArrowError),
15
16    #[error("Failed to decode message header {0}")]
17    HeaderDecoding(std::io::Error),
18
19    #[error("Failed to encode message header {0}")]
20    HeaderEncoding(std::io::Error),
21
22    #[error("Missing record batch")]
23    MissingRecordBatch,
24
25    #[error("Unexpected stream state")]
26    UnexpectedStreamState,
27
28    #[error("Unsupported encoding, expected Arrow IPC")]
29    UnsupportedEncoding,
30
31    #[error("Unknown message header")]
32    UnknownMessageHeader,
33}