risingwave_hummock_trace/
error.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use bincode::error::{DecodeError, EncodeError};
16use thiserror::Error;
17
18use crate::RecordId;
19
20pub type Result<T> = std::result::Result<T, TraceError>;
21
22#[derive(Error, Debug)]
23pub enum TraceError {
24    #[error("failed to encode, {0}")]
25    Encode(#[from] EncodeError),
26
27    #[error("failed to decode, {0}")]
28    Decode(#[from] DecodeError),
29
30    #[error("failed to read or write {0}")]
31    Io(#[from] std::io::Error),
32
33    #[error("invalid magic bytes, expected {expected}, found {found}")]
34    MagicBytes { expected: u32, found: u32 },
35
36    #[error("try to close a non-existing record {0}")]
37    FinRecord(RecordId),
38
39    #[error("failed to create a iter {0}")]
40    IterFailed(String),
41
42    #[error("failed to get key  {0}")]
43    GetFailed(String),
44
45    #[error("failed to ingest  {0}")]
46    IngestFailed(String),
47
48    #[error("failed to sync  {0}")]
49    SyncFailed(String),
50
51    #[error("{0}")]
52    Other(&'static str),
53
54    #[error("failed to try wait epoch")]
55    TryWaitEpochFailed,
56
57    #[error("failed to clear shared buffer")]
58    ClearSharedBufferFailed,
59
60    #[error("failed to flush")]
61    FlushFailed,
62
63    #[error("failed to try_flush")]
64    TryFlushFailed,
65}
risingwave_hummock_trace/error.rs

risingwave_hummock_trace/
error.rs
