Functions — github.com/Fullstop000/wickdb

hub / github.com/Fullstop000/wickdb / functions

Functions886 in github.com/Fullstop000/wickdb

⨍ Functions 886◇ Types & classes 135

Adds a key/value pair to the table being constructed. If the data block reaches the limit, it will be flushed If we just have flushed a new block data

src/sstable/table.rs:333

↓ 6 callersMethodbuild

(&mut self)

src/filter/bloom.rs:154

↓ 6 callersMethodget_next

(&self, height: usize)

src/mem/skiplist.rs:63

↓ 6 callersMethodis_empty

(&self)

src/sstable/block.rs:451

↓ 6 callersFunctionkey

Extract key

src/mem/skiplist.rs:643

↓ 6 callersMethodlevel_files_count

(&self, level: usize)

src/version/version_set.rs:235

↓ 6 callersMethodmaybe_schedule_compaction

Check whether db needs to run a compaction. DB will run a compaction when: 1. no background compaction is running 2. DB is not shutting down 3. no err

src/db/mod.rs:1327

↓ 6 callersMethodname

(&self)

src/db/mod.rs:2802

↓ 6 callersMethodoptions

(&self)

src/db/mod.rs:1499

↓ 6 callersFunctionread_block

Read the block identified from `file` according to the given `handle`. If the read data does not match the checksum, return a error marked as `Status:

src/sstable/table.rs:570

↓ 6 callersMethodseek

(&mut self, target_key: &[u8])

src/mem/skiplist.rs:303

↓ 6 callersMethodseek

(&mut self, target: &[u8])

src/sstable/mod.rs:608

↓ 6 callersMethodseek

find the first entry in block with key>= target

src/sstable/block.rs:254

↓ 5 callersMethodadd_record

Appends a slice into the underlying log file

src/record/writer.rs:51

↓ 5 callersFunctioncases

src/db/iterator.rs:338

↓ 5 callersMethodcompare

(&self, a: &[u8], b: &[u8])

src/db/mod.rs:2799

↓ 5 callersMethoddelete_obsolete_files

Delete any unneeded files and stale in-memory entries. This func could delete generated compaction files when the compaction is failed due some reason

src/db/mod.rs:783

↓ 5 callersFunctionencode_fixed_64

Encodes `value` in little-endian and puts in the first 8-bytes of `dst`. # Panics Panics if `dst.len()` is less than 8.

src/util/coding.rs:43

↓ 5 callersMethodencode_to

Convert into bytes and push into given `dst`

src/version/version_edit.rs:228

↓ 5 callersMethodfill_entry

fill the kv buffer from inner key-value

src/sstable/mod.rs:768

↓ 5 callersMethodfill_value_buf

(&mut self)

src/version/mod.rs:661

↓ 5 callersFunctionfind_file

Binary search given files to find earliest index of index whose largest ikey >= given ikey. If not found, returns the length of files.

src/version/mod.rs:550

↓ 5 callersMethodfinish

Appends the block restarts metadata and returns the block data

src/sstable/block.rs:388

↓ 5 callersMethodfix_checksum

(&mut self, header_offset: usize, len: usize)

src/record/mod.rs:292

↓ 5 callersMethodget

(&self, options: ReadOptions, key: &[u8])

src/db/mod.rs:115

↓ 5 callersMethodinit_derived_iter

Create a derived iter from the current value of the origin iter. Only works when current derived iter is `None` or the previous origin value has been

src/iterator.rs:112

↓ 5 callersMethodkey

(&self)

src/mem/skiplist.rs:81

↓ 5 callersMethodkey

Returns the internal key

src/mem/mod.rs:220

↓ 5 callersMethodlarger

Updates the smallest if given `iter` has a smaller value and returns true. Otherwise returns false.

src/iterator.rs:314

↓ 5 callersMethodlast_sequence

(&self)

src/version/version_set.rs:287

↓ 5 callersMethodlist

(&self, dir: P)

src/storage/mem.rs:343

↓ 5 callersMethodnew_iter

Create an iterator for the specified `file_number` (the corresponding file length must be exactly `file_size` bytes). The table referenced by returnin

src/table_cache.rs:100

↓ 5 callersMethodnext

(&mut self)

src/sstable/mod.rs:613

↓ 5 callersFunctionpack_seq_and_type

compose sequence number and value type into a single u64

src/db/format.rs:398

↓ 5 callersMethodparse_block_entry

Decodes a block entry from `current` mark as corrupted when the current entry tail overflows the starting offset of restarts

src/sstable/block.rs:174

↓ 5 callersFunctionparse_filename

Returns a tuple that contains `FileType` and the sequence number of the file. The `filename` should be a valid path.

src/db/filename.rs:88

↓ 5 callersMethodput

(&self, key: impl Into<Bytes>)

src/mem/inlineskiplist.rs:191

↓ 5 callersMethodread_all

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

src/storage/mem.rs:469

↓ 5 callersMethodseek_to_first

(&mut self)

src/iterator.rs:203

↓ 5 callersMethodseek_to_first

(&mut self)

src/sstable/mod.rs:600

↓ 5 callersMethodseek_to_last

(&mut self)

src/iterator.rs:213

↓ 5 callersMethodsequence

(self)

src/snapshot.rs:33

↓ 5 callersMethodset

(&self, k: usize, v: usize)

src/mem/skiplist.rs:633

↓ 5 callersMethodset_byte

(&mut self, offset: usize, byte: u8)

src/record/mod.rs:283

↓ 5 callersMethodset_sequence

(&mut self, seq: u64)

src/batch.rs:185

↓ 5 callersMethodsmaller

Updates the smallest if given `iter` has a smaller value and returns true. Otherwise returns false.

src/iterator.rs:300

↓ 5 callersMethodvalue

(&self)

src/sstable/mod.rs:632

↓ 5 callersMethodvalue

(&self)

src/db/iterator.rs:161

↓ 5 callersMethodwait

Wait util ReaderState reaches given `s`

src/mem/skiplist.rs:829

↓ 4 callersMethodadd_file

Add the specified file at the specified number

src/version/version_edit.rs:176

↓ 4 callersMethodassert_valid

(&self, expect: bool)

src/iterator.rs:552

↓ 4 callersFunctionbase_range

Returns the minimal range that covers all entries in `files`

src/compaction.rs:314

↓ 4 callersMethodclear_buf

clear `buf` and reset `buf_length`

src/record/reader.rs:341

↓ 4 callersMethodclose

(&mut self)

src/storage/mem.rs:457

↓ 4 callersMethodcmp

(&self)

src/iterator.rs:443

↓ 4 callersMethodcompare

(&self, a: &[u8], b: &[u8])

src/sstable/mod.rs:412

↓ 4 callersMethoddelete

If the database contains a mapping for "key", erase it. Else do nothing

src/batch.rs:85

↓ 4 callersMethoddelete_file

(&mut self, level: usize, file_number: u64)

src/version/version_edit.rs:198

↓ 4 callersMethoddetach

(&mut self, n: *mut LRUEntry<K, V>)

src/cache/lru.rs:101

↓ 4 callersMethodencoded

(&self)

src/sstable/mod.rs:259

↓ 4 callersMethodencoded_to

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

src/sstable/mod.rs:252

↓ 4 callersMethoderase

(&self, key: &K)

src/cache/lru.rs:216

↓ 4 callersMethodfinalize

Calculate the compaction score of the version The level with highest score will be marked as compaction needed.

src/version/mod.rs:296

↓ 4 callersMethodfind_greater_or_equal

Find the nearest node with a key >= the given key. Add prev node into `prev_nodes` which can be helpful for adding new node to the skiplist.

src/mem/skiplist.rs:179

↓ 4 callersMethodfind_near

findNear finds the node near to key. If less=true, it finds rightmost node such that node.key < key (if allowEqual=false) or node.key <= key (if allow

src/mem/inlineskiplist.rs:123

↓ 4 callersMethodgc

Remove all the old versions NOTE: This func always keeps the last element in `versions`

src/version/version_set.rs:827

↓ 4 callersMethodget_restart_point

(&self, index: u32)

src/sstable/block.rs:162

↓ 4 callersMethodis_empty

(&self)

src/batch.rs:197

↓ 4 callersMethoditers_len

(&self)

src/iterator.rs:447

↓ 4 callersMethodlog_and_apply

Apply `edit` to the current version to form a new descriptor that is both saved to persistent state and installed as the new current version. Only ca

src/version/version_set.rs:355

↓ 4 callersMethodlog_number

(&self)

src/version/version_set.rs:249

↓ 4 callersMethodmake_sst_files

Do `n` memtable compactions, each of which produces an sstable covering the key range `[begin,end]`.

src/db/mod.rs:1759

↓ 4 callersMethodnext

(&mut self)

src/iterator.rs:232

↓ 4 callersMethodnext

(&mut self)

src/sstable/block.rs:295

↓ 4 callersMethodopen

(&self, name: P)

src/storage/mem.rs:184

↓ 4 callersMethodparsed

Returns a `ParsedInternalKey`

src/db/format.rs:179

↓ 4 callersMethodprev

(&mut self)

src/iterator.rs:238

↓ 4 callersMethodread_exact_at

Reads the exact number of bytes required to fill `buf` from an `offset`. Errors if the "EOF" is encountered before filling the buffer. See [`Read::r

src/storage/mod.rs:98

↓ 4 callersMethodseek_to_restart_point

(&mut self, index: u32)

src/sstable/block.rs:166

↓ 4 callersMethodset_comparator_name

(&mut self, name: String)

src/version/version_edit.rs:203

↓ 4 callersMethodset_count

(&mut self, count: u32)

src/batch.rs:180

↓ 4 callersMethodset_derived

(&mut self, iter: Option<F::Iter>)

src/iterator.rs:138

↓ 4 callersMethodset_last_sequence

(&mut self, new: u64)

src/version/version_set.rs:293

↓ 4 callersMethodset_next_file

(&mut self, file_num: u64)

src/version/version_edit.rs:218

↓ 4 callersMethodshrink_size

(&mut self, bytes: usize)

src/record/mod.rs:287

↓ 4 callersMethodvalid

(&self)

src/mem/skiplist.rs:277

↓ 4 callersMethodvalid_or_panic

(&self)

src/version/mod.rs:669

↓ 4 callersMethodvalid_or_panic

(&self)

src/db/iterator.rs:195

↓ 4 callersFunctionwrite_raw_block

Write given block data into the file with block trailer

src/sstable/table.rs:544

↓ 3 callersMethodaccumulate

Add the given `FileDelta` for later applying 'vset.compaction_pointers' will be updated same as `apply` in C++ implementation

src/version/version_set.rs:78

↓ 3 callersMethodadd

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

src/sstable/mod.rs:874

↓ 3 callersMethodadd_base

(&mut self, f: Arc<FileMetaData>)

src/compaction.rs:55

↓ 3 callersMethodadd_key

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

src/filter/bloom.rs:126

↓ 3 callersMethodallocate_fallback

(&self, size: usize)

src/mem/arena.rs:134

↓ 3 callersMethodallocate_new_block

(&self, block_bytes: usize)

src/mem/arena.rs:151

↓ 3 callersMethodapply_to_new

Apply all the changes on the base Version and produce a new Version based on it same as `SaveTo` in C++ implementation

src/version/version_set.rs:113

↓ 3 callersMethodassert_deleted_kv

(&self, index: usize, (key, val): (u32, u32))

src/cache/lru.rs:293

↓ 3 callersMethodassert_not_closed

(&self)

src/sstable/table.rs:486

↓ 3 callersMethodattach

(&mut self, n: *mut LRUEntry<K, V>)

src/cache/lru.rs:108

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