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

↓ 2 callersFunctionnum_of_keys

()

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

↓ 2 callersMethodpartial_cmp

(&self, other: &Self)

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

↓ 2 callersMethodpath_of_wal

(&self, id: usize)

src/engines/lsm/storage.rs:696

↓ 2 callersMethodput

向 WAL 中追加写入 [key_len(2byte), key , time_stamp, value_len(2byte), value]

src/engines/lsm/wal.rs:63

↓ 2 callersMethodput

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

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

↓ 2 callersMethodskip_deletes

(&mut self)

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

↓ 2 callersMethodto_key_vec

(self)

src/engines/lsm/key.rs:138

↓ 2 callersMethodtry_freeze

(&self, estimated_size: usize)

src/engines/lsm/storage.rs:581

↓ 2 callersMethodtry_skip_second

(&mut self)

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

↓ 1 callersMethodcheck_size

检查加入 KV-Pair 后是否超出 block_size 大小

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

↓ 1 callersMethodclose

(&self)

src/engines/mod.rs:55

↓ 1 callersMethodclose

(&self)

src/engines/lsm/storage.rs:59

↓ 1 callersFunctiondraw_logo

()

src/bin/cli.rs:44

↓ 1 callersMethodestimated_size

计算 sstable的估计大小

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

↓ 1 callersMethodfind_block_idx

找到一个可能包含 key 的 Block

src/engines/lsm/table.rs:224

↓ 1 callersMethodgenerate_compaction_task

(&self, snapshot: &LsmStorageState)

src/engines/lsm/compact.rs:61

↓ 1 callersFunctiongenerate_concat_sst

( start_key: usize, end_key: usize, dir: impl AsRef<Path>, id: usize, )

src/engines/lsm/storage.rs:1106

↓ 1 callersMethodget_first_key

获取 Block 的 first_key

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

↓ 1 callersMethodget_with_ts

(&self, key: &[u8], read_ts: u64)

src/engines/lsm/storage.rs:348

↓ 1 callersFunctioninit_config

()

src/bin/server.rs:64

↓ 1 callersMethodinto_inner

获取 user_key

src/engines/lsm/key.rs:27

↓ 1 callersMethodis_empty

(&self)

src/engines/lsm/mem_table.rs:116

↓ 1 callersMethodis_valid

(&self)

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

↓ 1 callersFunctionkey_of

(idx: usize)

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

↓ 1 callersMethodlatest_commit_ts

最新提交的 time_stamp

src/engines/lsm/mvcc.rs:45

↓ 1 callersMethodmax_ts

(&self)

src/engines/lsm/table.rs:251

↓ 1 callersMethodmay_contain

是否可能包含 key

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

↓ 1 callersMethodmove_to_first

移动到第一个 Block

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

↓ 1 callersMethodnext

(&mut self)

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

↓ 1 callersMethodnext

(&mut self)

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

↓ 1 callersFunctionnum_of_keys

()

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

↓ 1 callersMethodprocess

(&mut self, command: Command)

src/servers/cli_server.rs:78

↓ 1 callersMethodrun

(&mut self, host: &String, port: &String)

src/servers/cli_server.rs:25

↓ 1 callersMethodscan_with_ts

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

src/engines/lsm/storage.rs:499

↓ 1 callersMethodset_ts

(&mut self, ts: u64)

src/engines/lsm/key.rs:70

↓ 1 callersMethodsize

(&self)

src/engines/lsm/table.rs:126

↓ 1 callersMethodspawn_compaction_thread

( self: &Arc<Self>, rx: crossbeam_channel::Receiver<()>, )

src/engines/lsm/compact.rs:372

↓ 1 callersMethodspawn_flush_thread

( self: &Arc<Self>, rx: crossbeam_channel::Receiver<()>, )

src/engines/lsm/compact.rs:407

↓ 1 callersMethodsync

(&self)

src/engines/lsm/wal.rs:85

↓ 1 callersMethodsync

同步 WAL 文件

src/engines/lsm/storage.rs:671

↓ 1 callersFunctiontest_integration_4

(compaction_options: CompactionOptions)

src/engines/lsm/storage.rs:1229

↓ 1 callersMethodupdate_commit_ts

(&self, ts: u64)

src/engines/lsm/mvcc.rs:49

↓ 1 callersMethodvalue

(&self)

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

↓ 1 callersFunctionvalue_of

(idx: usize)

src/engines/lsm/table.rs:291

↓ 1 callersFunctionvalue_of

(idx: usize)

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

↓ 1 callersFunctionvalue_of

(idx: usize)

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

↓ 1 callersMethodwatermark

可以回收 time_stamp 小于此 time_stamp 的 key

src/engines/lsm/mvcc.rs:54

↓ 1 callersMethodwatermark

(&self)

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

Methodadd

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

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

Methodapply_compaction_result

( &self, _snapshot: &LsmStorageState, _task: &TieredCompactionTask, _output: &

src/engines/lsm/compact/tiered.rs:67

Methodapply_compaction_result

应用合并的结果，修改 l0_sstable 和 level # 参数 `snapshot`: state快照 `task`: SimpleLeveledCompactionTask `output`: compaction 后生成的 sst_ids # 返回值 (LsmStorageState, V

src/engines/lsm/compact/simple_leveled.rs:82

Methodapply_compaction_result

( &self, _snapshot: &LsmStorageState, _task: &LeveledCompactionTask, _output:

src/engines/lsm/compact/leveled.rs:48

Functionas_bytes

(x: &[u8])

src/engines/lsm/utils.rs:124

Functionas_bytes

(x: &[u8])

src/engines/lsm/table.rs:332

Functionas_bytes

(x: &[u8])

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

Methodcalc_overlap

计算 key 和 first_key 重叠的 byte 数 # 参数 `first_key`: block first key `key`: key # 返回值重叠的 byte 数

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

Methodcheck_key_in_range

检查是否 key 在[table_first_key, table_last_key]的范围内

src/engines/lsm/storage.rs:195

Methodcheck_range

( lower: Bound<&[u8]>, upper: Bound<&[u8]>, table_first_key: KeySlice, table_l

src/engines/lsm/storage.rs:203

Methodcheck_sst_valid

检查 sstables 是否满足 key 不重叠

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

Methodcheck_subcommand

检查参数数量

src/parse.rs:9

Methodchoose_iterator

(first: &T, second: &E)

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

Methodcmp

(&self, other: &Self)

src/engines/lsm/key.rs:203

Methodconnect

(addr: A)

src/client.rs:16

Functionconstruct_merge_iterator_over_storage

( state: &LsmStorageState, )

src/engines/lsm/utils.rs:186

Methodcreate

创建新的 mem_table mem_table的`id`是 LSMStorageInner 中原子性递增的 next_sst_id

src/engines/lsm/mem_table.rs:30

Methodcreate

(path: impl AsRef<Path>)

src/engines/lsm/manifest.rs:24

Methodcreate

创建文件返回 FileObject

src/engines/lsm/table.rs:131

Methodcreate

创建 WAL # 参数 path memtable 对应 WAL 文件路径

src/engines/lsm/wal.rs:20

Methodcreate

( txn: Arc<Transaction>, iter: TwoMergeIterator<TxnLocalIterator, FusedIterator<LsmIterator>>

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

Methodcreate

(options: &LsmStorageOptions)

src/engines/lsm/storage/state.rs:24

Methodcreate

(iters: Vec<Box<I>>)

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

Methodcreate

(first: T, second: E)

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

Methodcreate_and_move_to_first

创建并且移动到第一个 Block

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

Methodcreate_and_move_to_first

创建 BlockIterator 并且移动到第一个 kv-pair

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

Methodcreate_and_move_to_key

创建并且移动到第一个key >= `key` 的位置

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

Methodcreate_and_move_to_key

创建 BlockIterator 并且移动到第一个 key >= `key`

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

Methodcreate_and_seek_to_first

(sstables: Vec<Arc<SsTable>>)

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

Methodcreate_and_seek_to_key

(sstables: Vec<Arc<SsTable>>, key: KeySlice)

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

Methodcreate_with_wal

创建带有 WAL 的 mem_table

src/engines/lsm/mem_table.rs:40

Methoddecode

(data: &[u8])

src/engines/lsm/block.rs:33

Methoddecode_from_buf

(mut buf: &[u8])

src/engines/lsm/table.rs:67

Methoddecode_from_buf

(buf: &[u8])

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

Methoddefault

()

src/engines/lsm/key.rs:175

Methoddefault

()

src/engines/lsm/storage/option.rs:21

Methoddefault

()

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

Methoddefault_for_week1_day6_test

()

src/engines/lsm/storage/option.rs:45

Methoddefault_for_week1_test

()

src/engines/lsm/storage/option.rs:34

Methoddefault_for_week2_test

(compaction_options: CompactionOptions)

src/engines/lsm/storage/option.rs:56

Methoddelete

(&mut self, keys: &String)

src/engines/mod.rs:51

Methoddelete

(&self, key: &[u8])

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

Methoddrop

(&mut self)

src/engines/mod.rs:61

Methoddrop

(&mut self)

src/engines/lsm/storage.rs:51

Methoddrop

(&mut self)

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

Methodencode_to_buf

将 block_meta 编码到 buf # 参数 block_meta: block_meta max_ts: buf: block_meta 编码后的 Vec<u8>

src/engines/lsm/table.rs:37

Methodentry_to_item

(entry: Option<Entry<'_, KeyBytes, Bytes>>)

src/engines/lsm/mem_table.rs:149

Methodentry_to_item

(entry: Option<Entry<'_, Bytes, Bytes>>)

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

Methodeq

(&self, other: &Self)

src/engines/lsm/key.rs:181

Methodeq

(&self, other: &Self)

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

Methodestimate_size

计算 Blockmeta 的大小

src/engines/lsm/table.rs:94

Methodfind_overlapping_ssts

( &self, _snapshot: &LsmStorageState, _sst_ids: &[usize], _in_level: usize,

src/engines/lsm/compact/leveled.rs:32

← previous next →101–200 of 327, ranked by callers