MCPcopy Create free account

hub / github.com/Yongxin-Hu/TabbyKV / functions

Functions327 in github.com/Yongxin-Hu/TabbyKV

Methodflush_to_l0
(&self)
src/engines/lsm/compact.rs:98
Methodfmt
(&self, f: &mut std::fmt::Formatter<'_>)
src/engines/lsm/key.rs:169
Methodfmt
(&self, f: &mut Formatter<'_>)
src/engines/lsm/table/bloom_filter.rs:19
Methodfor_testing_from_bytes_no_ts
(bytes: Bytes)
src/engines/lsm/key.rs:128
Methodfor_testing_from_slice_no_ts
(slice: &'a [u8])
src/engines/lsm/key.rs:159
Methodfor_testing_from_slice_with_ts
(slice: &'a [u8], ts: u64)
src/engines/lsm/key.rs:163
Methodfor_testing_from_vec_no_ts
(key: Vec<u8>)
src/engines/lsm/key.rs:101
Methodfor_testing_key_ref
(&self)
src/engines/lsm/key.rs:97
Methodfor_testing_ts
(self)
src/engines/lsm/key.rs:45
Methodforce_flush
Only for test
src/engines/lsm/storage.rs:144
Methodfrom
(_err: serde_json::Error)
src/entity/errors.rs:21
Methodfrom_bytes_with_ts
Create a `KeyBytes` from a `Bytes` and a ts.
src/engines/lsm/key.rs:116
Methodfrom_slice
Create a key slice from a slice. Will be removed in week 3.
src/engines/lsm/key.rs:143
Methodfrom_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
Methodgenerate_compaction_task
根据当前 state 快照生成合并任务 # 参数 `snapshot` state快照 # 返回值 None : 无需 compaction Some(task) : 需要执行 TieredCompactionTask
src/engines/lsm/compact/tiered.rs:35
Methodgenerate_compaction_task
根据当前 state 快照生成合并任务 # 参数 `snapshot` state快照 # 返回值 None : 无需 compaction Some(task) : 需要执行 SimpleLeveledCompactionTask
src/engines/lsm/compact/simple_leveled.rs:39
Methodgenerate_compaction_task
( &self, _snapshot: &LsmStorageState, )
src/engines/lsm/compact/leveled.rs:41
Methodget
(&self, key: &String)
src/engines/mod.rs:47
Methodget
根据 key 获取 value
src/engines/lsm/mem_table.rs:64
Methodget
(&self, key: &[u8])
src/engines/lsm/mvcc/txn.rs:39
Methodis_valid
(&self)
src/engines/lsm/utils.rs:114
Methodis_valid
(&self)
src/engines/lsm/mem_table.rs:167
Methodkey
(&self)
src/engines/lsm/utils.rs:96
Methodkey
(&self)
src/engines/lsm/table/iterator.rs:74
Methodkey
(&self)
src/engines/lsm/iterators/concat_iterator.rs:96
Methodkey
(&self)
src/engines/lsm/iterators/fused_iterator.rs:30
Functionmain
()
build.rs:1
Functionmain
()
src/bin/server.rs:76
Functionmain
()
src/bin/cli.rs:19
Methodmanifest
(&self)
src/engines/lsm/storage.rs:186
Methodmove_to_key_inner
(table: &Arc<SsTable>, key: KeySlice)
src/engines/lsm/table/iterator.rs:34
Methodnew
(engine: E)
src/servers/cli_server.rs:19
Methodnew
(engine: Arc<Mutex<E>>)
src/servers/grpc_server.rs:18
Methodnew
(path: impl AsRef<Path>)
src/engines/mod.rs:31
Methodnew
(data: Vec<(Bytes, Bytes)>)
src/engines/lsm/utils.rs:64
Methodnew
(initial_ts: u64)
src/engines/lsm/mvcc.rs:35
Methodnew
()
src/engines/lsm/key.rs:51
Methodnew
(options: TieredCompactionOptions)
src/engines/lsm/compact/tiered.rs:25
Methodnew
(options: SimpleLeveledCompactionOptions)
src/engines/lsm/compact/simple_leveled.rs:29
Methodnew
(options: LeveledCompactionOptions)
src/engines/lsm/compact/leveled.rs:28
Methodnew
()
src/engines/lsm/mvcc/watermark.rs:11
Methodnew
()
src/engines/lsm/table/bloom_filter.rs:39
Methodnew
根据给定的 block_size 创建 sstable_builder
src/engines/lsm/table/builder.rs:28
Methodnew
创建 BlockIterator
src/engines/lsm/block/iterator.rs:34
Methodnew
创建 BlockBuilder # 参数 `block_size`: Block大小(Byte)
src/engines/lsm/block/builder.rs:24
Methodnew
(iter: LsmIteratorInner, read_ts: u64, end_bound: Bound<Bytes>, )
src/engines/lsm/iterators/lsm_iterator.rs:25
Methodnew
(iter: I)
src/engines/lsm/iterators/fused_iterator.rs:12
Methodnew_txn
创建一个事务 # 参数 inner: LsmStorageInner serializable: # 返回值 Transaction
src/engines/lsm/mvcc.rs:65
Methodnew_with_error
(data: Vec<(Bytes, Bytes)>, error_when: usize)
src/engines/lsm/utils.rs:72
Methodnext
(&mut self)
src/engines/lsm/table/iterator.rs:82
Methodnext
(&mut self)
src/engines/lsm/iterators/merge_iterator.rs:89
Methodnext
(&mut self)
src/engines/lsm/iterators/concat_iterator.rs:109
Methodnum_retained_snapshots
(&self)
src/engines/lsm/mvcc/watermark.rs:29
Methodopen
(path: impl AsRef<Path>, options: LsmStorageOptions)
src/engines/lsm/storage.rs:100
Methodparse_command
(command: String)
src/parse.rs:7
Methodpartial_cmp
(&self, other: &Self)
src/engines/lsm/key.rs:197
Methodpath_of_sst_static
sst 文件格式 sst_id.sst
src/engines/lsm/storage.rs:683
Methodpath_of_wal_static
wal 文件格式 mem_table_id.wal
src/engines/lsm/storage.rs:692
Methodput
(&mut self, key: String, value: String)
src/engines/mod.rs:43
Methodread
(&mut self)
src/client.rs:35
Methodrecover
(path: impl AsRef<Path>)
src/engines/lsm/manifest.rs:31
Methodrecover
恢复 memtable # 参数 path memtable 对应 WAL 文件路径 skiplist memtable 内的跳表
src/engines/lsm/wal.rs:32
Methodrecover_from_wal
使用 WAL 恢复 memtable 的 skipmap # 参数 `id` memtable 的 id `path` wal 文件路径
src/engines/lsm/mem_table.rs:53
Methodscan
(self: &Arc<Self>, lower: Bound<&[u8]>, upper: Bound<&[u8]>)
src/engines/lsm/mvcc/txn.rs:58
Methodservice
( &self, request: Request<Req> )
src/servers/grpc_server.rs:27
Functionsimple_test_sst_builder
()
src/engines/lsm/table/builder.rs:131
Methodtable_size
(&self)
src/engines/lsm/table.rs:243
Functiontest_1
()
src/engines/lsm/block/iterator.rs:211
Functiontest_auto_flush
()
src/engines/lsm/storage.rs:1087
Functiontest_block_build_all
()
src/engines/lsm/block/builder.rs:173
Functiontest_block_build_full
()
src/engines/lsm/block/builder.rs:126
Functiontest_block_build_large_1
()
src/engines/lsm/block/builder.rs:134
Functiontest_block_build_large_2
()
src/engines/lsm/block/builder.rs:141
Functiontest_block_builder_1
()
src/engines/lsm/block/builder.rs:119
Functiontest_block_decode
()
src/engines/lsm/block/builder.rs:184
Functiontest_block_encode
()
src/engines/lsm/block/builder.rs:178
Functiontest_block_iterator
()
src/engines/lsm/block/iterator.rs:182
Functiontest_block_meta
()
src/engines/lsm/table.rs:268
Functiontest_block_seek_key
()
src/engines/lsm/block/iterator.rs:226
Functiontest_block_split
()
src/engines/lsm/table/builder.rs:140
Functiontest_bloom_filter
()
src/engines/lsm/table/bloom_filter.rs:129
Functiontest_concat_iterator
()
src/engines/lsm/storage.rs:1125
Functiontest_fused_iterator
()
src/engines/lsm/iterators/fused_iterator.rs:64
Functiontest_get_first_key
()
src/engines/lsm/block/iterator.rs:147
Functiontest_integration
()
src/engines/lsm/storage.rs:770
Functiontest_integration_2
()
src/engines/lsm/storage.rs:826
Functiontest_integration_3
()
src/engines/lsm/storage.rs:1160
Functiontest_integration_simple
()
src/engines/lsm/storage.rs:1221
Functiontest_memtable_iter
()
src/engines/lsm/mem_table.rs:185
Functiontest_merge_2
()
src/engines/lsm/iterators/merge_iterator.rs:192
Functiontest_merge_iter_1
()
src/engines/lsm/iterators/merge_iterator.rs:141
Functiontest_serializable_1
()
src/engines/lsm/storage.rs:1316
Functiontest_serializable_2
()
src/engines/lsm/storage.rs:1335
Functiontest_serializable_3_ts_range
()
src/engines/lsm/storage.rs:1350
Functiontest_serializable_4_scan
()
src/engines/lsm/storage.rs:1369
Functiontest_serializable_5_read_only
()
src/engines/lsm/storage.rs:1392
Functiontest_sst_build_all
()
src/engines/lsm/table.rs:312
Functiontest_sst_build_multi_version_simple
()
src/engines/lsm/table.rs:396
Functiontest_sst_decode
()
src/engines/lsm/table.rs:317
Functiontest_sst_iterator
()
src/engines/lsm/table.rs:337
← previousnext →201–300 of 327, ranked by callers