Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Yongxin-Hu/TabbyKV
/ functions
Functions
327 in github.com/Yongxin-Hu/TabbyKV
⨍
Functions
327
◇
Types & classes
62
Method
flush_to_l0
(&self)
src/engines/lsm/compact.rs:98
Method
fmt
(&self, f: &mut std::fmt::Formatter<'_>)
src/engines/lsm/key.rs:169
Method
fmt
(&self, f: &mut Formatter<'_>)
src/engines/lsm/table/bloom_filter.rs:19
Method
for_testing_from_bytes_no_ts
(bytes: Bytes)
src/engines/lsm/key.rs:128
Method
for_testing_from_slice_no_ts
(slice: &'a [u8])
src/engines/lsm/key.rs:159
Method
for_testing_from_slice_with_ts
(slice: &'a [u8], ts: u64)
src/engines/lsm/key.rs:163
Method
for_testing_from_vec_no_ts
(key: Vec<u8>)
src/engines/lsm/key.rs:101
Method
for_testing_key_ref
(&self)
src/engines/lsm/key.rs:97
Method
for_testing_ts
(self)
src/engines/lsm/key.rs:45
Method
force_flush
Only for test
src/engines/lsm/storage.rs:144
Method
from
(_err: serde_json::Error)
src/entity/errors.rs:21
Method
from_bytes_with_ts
Create a `KeyBytes` from a `Bytes` and a ts.
src/engines/lsm/key.rs:116
Method
from_slice
Create a key slice from a slice. Will be removed in week 3.
src/engines/lsm/key.rs:143
Method
from_vec_with_ts
Create a `KeyVec` from a `Vec<u8>` and a ts. Will be removed in week 3.
src/engines/lsm/key.rs:56
Method
generate_compaction_task
根据当前 state 快照生成合并任务 # 参数 `snapshot` state快照 # 返回值 None : 无需 compaction Some(task) : 需要执行 TieredCompactionTask
src/engines/lsm/compact/tiered.rs:35
Method
generate_compaction_task
根据当前 state 快照生成合并任务 # 参数 `snapshot` state快照 # 返回值 None : 无需 compaction Some(task) : 需要执行 SimpleLeveledCompactionTask
src/engines/lsm/compact/simple_leveled.rs:39
Method
generate_compaction_task
( &self, _snapshot: &LsmStorageState, )
src/engines/lsm/compact/leveled.rs:41
Method
get
(&self, key: &String)
src/engines/mod.rs:47
Method
get
根据 key 获取 value
src/engines/lsm/mem_table.rs:64
Method
get
(&self, key: &[u8])
src/engines/lsm/mvcc/txn.rs:39
Method
is_valid
(&self)
src/engines/lsm/utils.rs:114
Method
is_valid
(&self)
src/engines/lsm/mem_table.rs:167
Method
key
(&self)
src/engines/lsm/utils.rs:96
Method
key
(&self)
src/engines/lsm/table/iterator.rs:74
Method
key
(&self)
src/engines/lsm/iterators/concat_iterator.rs:96
Method
key
(&self)
src/engines/lsm/iterators/fused_iterator.rs:30
Function
main
()
build.rs:1
Function
main
()
src/bin/server.rs:76
Function
main
()
src/bin/cli.rs:19
Method
manifest
(&self)
src/engines/lsm/storage.rs:186
Method
move_to_key_inner
(table: &Arc<SsTable>, key: KeySlice)
src/engines/lsm/table/iterator.rs:34
Method
new
(engine: E)
src/servers/cli_server.rs:19
Method
new
(engine: Arc<Mutex<E>>)
src/servers/grpc_server.rs:18
Method
new
(path: impl AsRef<Path>)
src/engines/mod.rs:31
Method
new
(data: Vec<(Bytes, Bytes)>)
src/engines/lsm/utils.rs:64
Method
new
(initial_ts: u64)
src/engines/lsm/mvcc.rs:35
Method
new
()
src/engines/lsm/key.rs:51
Method
new
(options: TieredCompactionOptions)
src/engines/lsm/compact/tiered.rs:25
Method
new
(options: SimpleLeveledCompactionOptions)
src/engines/lsm/compact/simple_leveled.rs:29
Method
new
(options: LeveledCompactionOptions)
src/engines/lsm/compact/leveled.rs:28
Method
new
()
src/engines/lsm/mvcc/watermark.rs:11
Method
new
()
src/engines/lsm/table/bloom_filter.rs:39
Method
new
根据给定的 block_size 创建 sstable_builder
src/engines/lsm/table/builder.rs:28
Method
new
创建 BlockIterator
src/engines/lsm/block/iterator.rs:34
Method
new
创建 BlockBuilder # 参数 `block_size`: Block大小(Byte)
src/engines/lsm/block/builder.rs:24
Method
new
(iter: LsmIteratorInner, read_ts: u64, end_bound: Bound<Bytes>, )
src/engines/lsm/iterators/lsm_iterator.rs:25
Method
new
(iter: I)
src/engines/lsm/iterators/fused_iterator.rs:12
Method
new_txn
创建一个事务 # 参数 inner: LsmStorageInner serializable: # 返回值 Transaction
src/engines/lsm/mvcc.rs:65
Method
new_with_error
(data: Vec<(Bytes, Bytes)>, error_when: usize)
src/engines/lsm/utils.rs:72
Method
next
(&mut self)
src/engines/lsm/table/iterator.rs:82
Method
next
(&mut self)
src/engines/lsm/iterators/merge_iterator.rs:89
Method
next
(&mut self)
src/engines/lsm/iterators/concat_iterator.rs:109
Method
num_retained_snapshots
(&self)
src/engines/lsm/mvcc/watermark.rs:29
Method
open
(path: impl AsRef<Path>, options: LsmStorageOptions)
src/engines/lsm/storage.rs:100
Method
parse_command
(command: String)
src/parse.rs:7
Method
partial_cmp
(&self, other: &Self)
src/engines/lsm/key.rs:197
Method
path_of_sst_static
sst 文件格式 sst_id.sst
src/engines/lsm/storage.rs:683
Method
path_of_wal_static
wal 文件格式 mem_table_id.wal
src/engines/lsm/storage.rs:692
Method
put
(&mut self, key: String, value: String)
src/engines/mod.rs:43
Method
read
(&mut self)
src/client.rs:35
Method
recover
(path: impl AsRef<Path>)
src/engines/lsm/manifest.rs:31
Method
recover
恢复 memtable # 参数 path memtable 对应 WAL 文件路径 skiplist memtable 内的跳表
src/engines/lsm/wal.rs:32
Method
recover_from_wal
使用 WAL 恢复 memtable 的 skipmap # 参数 `id` memtable 的 id `path` wal 文件路径
src/engines/lsm/mem_table.rs:53
Method
scan
(self: &Arc<Self>, lower: Bound<&[u8]>, upper: Bound<&[u8]>)
src/engines/lsm/mvcc/txn.rs:58
Method
service
( &self, request: Request<Req> )
src/servers/grpc_server.rs:27
Function
simple_test_sst_builder
()
src/engines/lsm/table/builder.rs:131
Method
table_size
(&self)
src/engines/lsm/table.rs:243
Function
test_1
()
src/engines/lsm/block/iterator.rs:211
Function
test_auto_flush
()
src/engines/lsm/storage.rs:1087
Function
test_block_build_all
()
src/engines/lsm/block/builder.rs:173
Function
test_block_build_full
()
src/engines/lsm/block/builder.rs:126
Function
test_block_build_large_1
()
src/engines/lsm/block/builder.rs:134
Function
test_block_build_large_2
()
src/engines/lsm/block/builder.rs:141
Function
test_block_builder_1
()
src/engines/lsm/block/builder.rs:119
Function
test_block_decode
()
src/engines/lsm/block/builder.rs:184
Function
test_block_encode
()
src/engines/lsm/block/builder.rs:178
Function
test_block_iterator
()
src/engines/lsm/block/iterator.rs:182
Function
test_block_meta
()
src/engines/lsm/table.rs:268
Function
test_block_seek_key
()
src/engines/lsm/block/iterator.rs:226
Function
test_block_split
()
src/engines/lsm/table/builder.rs:140
Function
test_bloom_filter
()
src/engines/lsm/table/bloom_filter.rs:129
Function
test_concat_iterator
()
src/engines/lsm/storage.rs:1125
Function
test_fused_iterator
()
src/engines/lsm/iterators/fused_iterator.rs:64
Function
test_get_first_key
()
src/engines/lsm/block/iterator.rs:147
Function
test_integration
()
src/engines/lsm/storage.rs:770
Function
test_integration_2
()
src/engines/lsm/storage.rs:826
Function
test_integration_3
()
src/engines/lsm/storage.rs:1160
Function
test_integration_simple
()
src/engines/lsm/storage.rs:1221
Function
test_memtable_iter
()
src/engines/lsm/mem_table.rs:185
Function
test_merge_2
()
src/engines/lsm/iterators/merge_iterator.rs:192
Function
test_merge_iter_1
()
src/engines/lsm/iterators/merge_iterator.rs:141
Function
test_serializable_1
()
src/engines/lsm/storage.rs:1316
Function
test_serializable_2
()
src/engines/lsm/storage.rs:1335
Function
test_serializable_3_ts_range
()
src/engines/lsm/storage.rs:1350
Function
test_serializable_4_scan
()
src/engines/lsm/storage.rs:1369
Function
test_serializable_5_read_only
()
src/engines/lsm/storage.rs:1392
Function
test_sst_build_all
()
src/engines/lsm/table.rs:312
Function
test_sst_build_multi_version_simple
()
src/engines/lsm/table.rs:396
Function
test_sst_decode
()
src/engines/lsm/table.rs:317
Function
test_sst_iterator
()
src/engines/lsm/table.rs:337
← previous
next →
201–300 of 327, ranked by callers