Functions — github.com/Yongxin-Hu/TabbyKV

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

Functions327 in github.com/Yongxin-Hu/TabbyKV

⨍ Functions 327◇ Types & classes 62

↓ 79 callersMethodput

(&self, key: &[u8], value: &[u8])

src/engines/lsm/storage.rs:127

↓ 76 callersMethodclone

(&self)

src/engines/lsm/key.rs:189

↓ 33 callersMethodread

(&self, offset: u64, len: u64)

src/engines/lsm/table.rs:118

↓ 30 callersMethodkey_ref

(&self)

src/engines/lsm/key.rs:89

↓ 21 callersMethoddelete

(&self, key: &[u8])

src/engines/lsm/storage.rs:131

↓ 21 callersMethodget

(&self, key: &[u8])

src/engines/lsm/storage.rs:123

↓ 17 callersMethodforce_freeze_memtable

freeze activate_memtable to readonly_memtable

src/engines/lsm/storage.rs:595

↓ 17 callersMethodnext

移动到下一个 kv-pair

src/engines/lsm/block/iterator.rs:82

↓ 16 callersMethodscan

( &self, lower: Bound<&[u8]>, upper: Bound<&[u8]>, )

src/engines/lsm/storage.rs:135

↓ 16 callersMethodsst_id

(&self)

src/engines/lsm/table.rs:247

↓ 15 callersMethodkey

返回当前的 key

src/engines/lsm/block/iterator.rs:60

↓ 15 callersMethodmvcc

(&self)

src/engines/lsm/storage.rs:182

↓ 15 callersMethodnew_txn

(&self)

src/engines/lsm/storage.rs:115

↓ 14 callersMethodadd

向 sstable 中添加 kv-pair (在 Block 满的时候新建 Block)

src/engines/lsm/table/builder.rs:42

↓ 14 callersMethodis_empty

BlockBuilder里面是否为空（无 KV-Pair）

src/engines/lsm/block/builder.rs:96

↓ 14 callersMethodts

(&self)

src/engines/lsm/key.rs:93

↓ 12 callersMethodas_key_slice

(&self)

src/engines/lsm/key.rs:81

↓ 12 callersMethodbuild

构建 sstable # 参数 id: sstable 的 id path: id.sst

src/engines/lsm/table/builder.rs:90

↓ 11 callersFunctioncheck_iter_result_by_key

(iter: &mut I, expected: Vec<(Bytes, Bytes)>)

src/engines/lsm/utils.rs:128

↓ 11 callersMethodcommit

提交事务

src/engines/lsm/mvcc/txn.rs:104

↓ 9 callersFunctioncheck_lsm_iter_result_by_key

(iter: &mut I, expected: Vec<(Bytes, Bytes)>)

src/engines/lsm/utils.rs:153

↓ 9 callersMethodis_empty

(&self)

src/engines/lsm/key.rs:41

↓ 8 callersMethodkey_len

user_key 长度

src/engines/lsm/key.rs:32

↓ 8 callersFunctionsync

(storage: &LsmStorageInner)

src/engines/lsm/utils.rs:179

↓ 8 callersMethodvalue

返回当前的 value

src/engines/lsm/block/iterator.rs:66

↓ 7 callersMethodbuild

构建 Block

src/engines/lsm/block/builder.rs:101

↓ 7 callersMethodclear

Clears the key and set ts to 0.

src/engines/lsm/key.rs:61

↓ 7 callersMethodis_valid

当前 iterator 是否有效

src/engines/lsm/block/iterator.rs:72

↓ 7 callersMethodkey

(&self)

src/engines/lsm/iterators/lsm_iterator.rs:92

↓ 7 callersMethodnext

(&mut self)

src/engines/lsm/mem_table.rs:171

↓ 7 callersMethodsync_dir

同步 kv 存储文件

src/engines/lsm/storage.rs:676

↓ 6 callersMethodadd_reader

(&mut self, ts: u64)

src/engines/lsm/mvcc/watermark.rs:17

↓ 6 callersMethodforce_flush_earliest_memtable

强制将最早的 memtable 转入 L0 层

src/engines/lsm/storage.rs:631

↓ 6 callersMethodis_valid

(&self)

src/engines/lsm/iterators/lsm_iterator.rs:96

↓ 6 callersMethodkey

(&self)

src/engines/lsm/mvcc/txn.rs:207

↓ 6 callersMethodremove_reader

(&mut self, ts: u64)

src/engines/lsm/mvcc/watermark.rs:21

↓ 6 callersMethodscan

(&self, lower: Bound<KeySlice>, upper: Bound<KeySlice>)

src/engines/lsm/mem_table.rs:96

↓ 6 callersMethodsend

(&mut self, command: Command)

src/client.rs:25

↓ 6 callersMethodvalue

(&self)

src/engines/lsm/mvcc/txn.rs:203

↓ 5 callersMethodflush

将 memtable 中的 kv-pair 加入 ss_table_builder

src/engines/lsm/mem_table.rs:89

↓ 5 callersMethodid

(&self)

src/engines/lsm/mem_table.rs:107

↓ 5 callersMethodopen

(path: &Path)

src/engines/lsm/table.rs:140

↓ 5 callersMethodpath_of_sst

(&self, id: usize)

src/engines/lsm/storage.rs:687

↓ 4 callersMethodencode

(&self)

src/engines/lsm/block.rs:14

↓ 4 callersMethodfirst_key

(&self)

src/engines/lsm/table.rs:235

↓ 4 callersMethodforce_full_compaction

(&self)

src/engines/lsm/compact.rs:258

↓ 4 callersFunctiongenerate_sst

()

src/engines/lsm/table.rs:299

↓ 4 callersFunctiongenerate_sst

( id: usize, path: impl AsRef<Path>, data: Vec<(Bytes, Bytes)>, )

src/engines/lsm/storage.rs:853

↓ 4 callersMethodis_valid

(&self)

src/engines/lsm/iterators/merge_iterator.rs:82

↓ 4 callersMethodis_valid

(&self)

src/engines/lsm/iterators/two_merge_iterator.rs:64

↓ 4 callersMethodkey

(&self)

src/engines/lsm/iterators/merge_iterator.rs:78

↓ 4 callersMethodkey

(&self)

src/engines/lsm/iterators/two_merge_iterator.rs:56

↓ 4 callersFunctionmap_bound_for_test

TODO will be remove

src/engines/lsm/utils.rs:21

↓ 4 callersMethodmove_to

移动到第 index 个 kv-pair

src/engines/lsm/block/iterator.rs:105

↓ 4 callersMethodnext_sst_id

(&self)

src/engines/lsm/storage.rs:177

↓ 4 callersMethodread_block_with_cache

获取 sstable 的第 index 个 Block,使用缓存 # 参数 index: sstable 中 Block 的 index

src/engines/lsm/table.rs:212

↓ 4 callersMethodset_from_slice

Set the key from a slice without re-allocating.

src/engines/lsm/key.rs:75

↓ 4 callersMethodwrite_batch_inner

批量写入

src/engines/lsm/storage.rs:436

↓ 3 callersMethodadd

对 key 做 hash 后将对应的bit位设置为1

src/engines/lsm/table/bloom_filter.rs:66

↓ 3 callersMethodadd_record

( &self, state_lock_observer: &MutexGuard<()>, record: ManifestRecord, )

src/engines/lsm/manifest.rs:55

↓ 3 callersMethodadd_record_when_init

Record 格式 [record_data_len(u64), record_data, record_hash(u32)]

src/engines/lsm/manifest.rs:64

↓ 3 callersMethodappend

Append a slice to the end of the key

src/engines/lsm/key.rs:66

↓ 3 callersMethodapproximate_size

(&self)

src/engines/lsm/mem_table.rs:111

↓ 3 callersMethodcompact_sst_by_merge_iter

合并 sst # 参数 iter: 需要合并的 sst iter compact_to_bottom_level: 合并到最底层 # 返回值新生成的 sst 文件

src/engines/lsm/compact.rs:115

↓ 3 callersMethodcompact_to_bottom_level

(&self)

src/engines/lsm/compact.rs:43

↓ 3 callersFunctiongenerate_block

()

src/engines/lsm/block/builder.rs:159

↓ 3 callersMethodinto_key_bytes

(self)

src/engines/lsm/key.rs:85

↓ 3 callersMethodis_valid

(&self)

src/engines/lsm/mvcc/txn.rs:211

↓ 3 callersMethodis_valid

(&self)

src/engines/lsm/iterators/fused_iterator.rs:37

↓ 3 callersMethodlast_key

(&self)

src/engines/lsm/table.rs:239

↓ 3 callersFunctionmap_bound

(bound: Bound<&[u8]>)

src/engines/lsm/utils.rs:12

↓ 3 callersMethodmove_to_key

移动到第一个 key >= `key`

src/engines/lsm/block/iterator.rs:88

↓ 3 callersMethodmove_to_valid

(&mut self)

src/engines/lsm/iterators/concat_iterator.rs:71

↓ 3 callersMethodnext

(&mut self)

src/engines/lsm/iterators/fused_iterator.rs:41

↓ 3 callersMethodnext_inner

(&mut self)

src/engines/lsm/iterators/lsm_iterator.rs:41

↓ 3 callersFunctionnum_of_keys

()

src/engines/lsm/table.rs:295

↓ 3 callersMethodput

将 KV-pair 放入 mem_table

src/engines/lsm/mem_table.rs:76

↓ 3 callersMethodraw_len

user_key + timestamp 长度

src/engines/lsm/key.rs:37

↓ 3 callersMethodread_block

获取 sstable 的第 index 个 Block # 参数 index: sstable 中 Block 的 index

src/engines/lsm/table.rs:197

↓ 3 callersMethodsync_wal

(&self)

src/engines/lsm/mem_table.rs:120

↓ 3 callersMethodvalue

(&self)

src/engines/lsm/mem_table.rs:159

↓ 2 callersMethodadd_to_read_set

(&self, key: &[u8])

src/engines/lsm/mvcc/txn.rs:247

↓ 2 callersMethodapply_compaction_result

( &self, snapshot: &LsmStorageState, task: &CompactionTask, output: &[usize],

src/engines/lsm/compact.rs:76

↓ 2 callersMethodcmp

(&self, other: &Self)

src/engines/lsm/iterators/merge_iterator.rs:29

↓ 2 callersMethodcompact

根据 CompactionTask 执行 compact, 返回新生成的 sstables

src/engines/lsm/compact.rs:187

↓ 2 callersMethodcomplete_block

构建 block

src/engines/lsm/table/builder.rs:68

↓ 2 callersMethodencode_to_buf

(&self, buf: &mut Vec<u8>)

src/engines/lsm/table/bloom_filter.rs:93

↓ 2 callersMethodfreeze_memtable_with_memtable

(&self, memtable: Arc<MemTable>)

src/engines/lsm/storage.rs:613

↓ 2 callersFunctiongenerate_block

()

src/engines/lsm/block/iterator.rs:170

↓ 2 callersMethodis_valid

(&self)

src/engines/lsm/table/iterator.rs:78

↓ 2 callersMethodkey

(&self)

src/engines/lsm/mem_table.rs:163

↓ 2 callersFunctionkey_of

(idx: usize)

src/engines/lsm/table.rs:287

↓ 2 callersFunctionkey_of

(idx: usize)

src/engines/lsm/block/iterator.rs:158

↓ 2 callersFunctionmap_key_bound

(bound: Bound<KeySlice>)

src/engines/lsm/utils.rs:42

↓ 2 callersMethodmove_to_first

移动到第一个 kv-pair

src/engines/lsm/block/iterator.rs:77

↓ 2 callersMethodmove_to_key

移动到第一个key >= `key` 的位置

src/engines/lsm/table/iterator.rs:59

↓ 2 callersMethodmove_to_key

(&mut self)

src/engines/lsm/iterators/lsm_iterator.rs:55

↓ 2 callersMethodnext

(&mut self)

src/engines/lsm/utils.rs:84

↓ 2 callersMethodnext

(&mut self)

src/engines/lsm/mvcc/txn.rs:215

↓ 2 callersMethodnum_of_blocks

SsTable 中 Block 的数量

src/engines/lsm/table.rs:231

next →1–100 of 327, ranked by callers