kip_db 0.1.2-alpha.26.fix1

轻量级、异步 基于LSM Leveled Compaction K-V数据库
Documentation 
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

use crate::kernel::lsm::compactor::CompactTask;
use crate::kernel::lsm::version::cleaner::CleanTag;
use std::io;
use thiserror::Error;
use tokio::sync::mpsc::error::SendError;
use tokio::sync::oneshot::error::RecvError;

/// Error type for kvs
#[derive(Error, Debug)]
#[non_exhaustive]
pub enum KernelError {
    /// IO error
    #[error(transparent)]
    Io(#[from] io::Error),

    #[error(transparent)]
    RecvError(#[from] RecvError),

    #[error("Failed to send compact task")]
    SendCompactTaskError(#[from] SendError<CompactTask>),

    #[error("Failed to send clean tag")]
    SendCleanTagError(#[from] SendError<CleanTag>),

    /// Serialization or deserialization error
    #[error(transparent)]
    SerdeBinCode(#[from] Box<bincode::ErrorKind>),

    /// Remove no-existent key error
    #[error("Key not found")]
    KeyNotFound,

    #[error("Data is empty")]
    DataEmpty,

    #[error("Level Over")]
    LevelOver,

    #[error("Not the correct type of Cmd")]
    NotMatchCmd,

    #[error("CRC code does not match")]
    CrcMisMatch,

    #[cfg(feature = "sled")]
    #[error(transparent)]
    SledErr(#[from] sled::Error),

    #[cfg(feature = "rocksdb")]
    #[error(transparent)]
    RocksdbErr(#[from] rocksdb::Error),

    #[error("Cache size overflow")]
    CacheSizeOverFlow,

    #[error("Cache sharding and size overflow")]
    CacheShardingNotAlign,

    #[error("File not found")]
    FileNotFound,

    /// 正常情况wal在内存中存在索引则表示硬盘中存在有对应的数据
    /// 而错误则是内存存在索引却在硬盘中不存在这个数据
    #[error("WAL log load error")]
    WalLoad,

    /// Unexpected command type error.
    /// It indicated a corrupted log or a program bug.
    #[error("Unexpected command type")]
    UnexpectedCommandType,

    #[error("Process already exists")]
    ProcessExists,

    #[error("Channel is closed")]
    ChannelClose,

    #[error("{0}")]
    NotSupport(&'static str),

    #[error("The number of caches cannot be divisible by the number of shards")]
    ShardingNotAlign,

    #[error("Same write in different transactions")]
    RepeatedWrite,
}

#[derive(Error, Debug)]
#[non_exhaustive]
pub enum ConnectionError {
    #[error(transparent)]
    IO(#[from] io::Error),

    #[error("disconnected")]
    Disconnected,

    #[error("write failed")]
    WriteFailed,

    #[error("wrong instruction")]
    WrongInstruction,

    #[error("encode error")]
    EncodeErr,

    #[error("decode error")]
    DecodeErr,

    #[error("server flush error")]
    FlushError,

    #[cfg(feature = "net")]
    #[error("Failed to connect to server, {0}")]
    TonicTransportErr(#[from] tonic::transport::Error),

    #[cfg(feature = "net")]
    #[error("Failed to call server, {0}")]
    TonicFailureStatus(#[from] tonic::Status),

    #[error("Failed to parse addr, {0}")]
    AddrParseError(#[from] std::net::AddrParseError),

    #[error(transparent)]
    KernelError(#[from] KernelError),
}