Functions — github.com/Gifted-s/velarixdb

hub / github.com/Gifted-s/velarixdb / functions

Functions380 in github.com/Gifted-s/velarixdb

⨍ Functions 380◇ Types & classes 79

↓ 1 callersMethodget_filter

(&self)

src/sst/table.rs:122

↓ 1 callersMethodget_from_index

(&self, searched_key: &[u8])

src/fs/mod.rs:667

↓ 1 callersMethodget_last_entry

(&self)

src/block/block_manager.rs:163

↓ 1 callersMethodget_most_recent_offset

Returns most recent entry value offset

src/memtable/mem.rs:250

↓ 1 callersFunctionget_open_file_limit

()

src/cfg/config.rs:66

↓ 1 callersMethodincrease_hotness

(&mut self)

src/sst/table.rs:150

↓ 1 callersMethodload_entries

(&self)

src/fs/mod.rs:275

↓ 1 callersMethodload_entries_within_range

( &self, range_offset: RangeOffset, )

src/fs/mod.rs:391

↓ 1 callersMethodmerge_sstables

Merge two `Table` together one returns a larger one Errors Returns error if an error occured during merge

src/compactors/sized.rs:207

↓ 1 callersMethodmigrate_memtable_to_read_only

Moves active memtable to read-only memtables Marks the active memtable as read only, updates store metadata and moves the memtable to read-only memta

src/db/store.rs:250

↓ 1 callersMethodopen

(path: impl P)

src/fs/mod.rs:203

↓ 1 callersMethodopen

Opens a keyspace in the given directory. Keyspace names can be up to 255 characters long, can not be empty and can only contain alphanumerics, unders

src/db/store.rs:139

↓ 1 callersMethodprint_keyspace_name

Prints the keyspace name of the DataStore to the console.

src/db/store.rs:746

↓ 1 callersMethodr_lock

(&self)

src/fs/mod.rs:257

↓ 1 callersMethodrange_query_scan

Returns SSTables whose keys overlap with the key range supplied

src/key_range/range.rs:196

↓ 1 callersMethodrecover

Recovers [`DataStore`] state after crash Errors Returns error incase there is an IO error

src/db/recovery.rs:50

↓ 1 callersMethodremove_dir_all

(&self)

src/fs/mod.rs:249

↓ 1 callersMethodreset_memtables

Resets both active memtable and GC table to new

src/db/store.rs:381

↓ 1 callersMethodreset_size

(&mut self)

src/sst/table.rs:352

↓ 1 callersMethodrun_compaction

Main compaction runner

src/compactors/sized.rs:60

↓ 1 callersMethodsearch_gc_entries

Searches for entries from gc yet be synced to active memtable # Errors Returns error, if IO error occurs

src/db/store.rs:489

↓ 1 callersMethodsearch_key_in_sstables

Search for a key across SSTables [`Index`] is used to locate block is sstables that can possibly contain the key # Errors Returns error, if any er

src/db/store.rs:579

↓ 1 callersMethodserialize

Converts value log entry to a byte vector

src/vlog/v_log.rs:291

↓ 1 callersMethodserialize

Serializes `Meta` into byte vector

src/meta/meta_manager.rs:93

↓ 1 callersMethodserialize

Serializes `BloomFilter` attributes Converts `BloomFilter` atttributes such as no_of_hash_func, no_of_elements and false positive floating point into

src/filter/bf.rs:158

↓ 1 callersMethodserialize_entry

Serializes the entry in the index as a byte vector Returns `ByteSerializedEntry`or Error if not

src/index/indexer.rs:151

↓ 1 callersMethodset_entries

Set `entries` field in `Table`

src/sst/table.rs:362

↓ 1 callersMethodset_entries

(&mut self, entries: SkipMapEntries<Key>)

src/compactors/insertor.rs:39

↓ 1 callersMethodset_sst_size_from_entries

Set byte `size` from entries size

src/sst/table.rs:368

↓ 1 callersMethodset_sst_size_from_entries

(&mut self)

src/compactors/insertor.rs:43

↓ 1 callersMethodset_sstable_path

Sets the sst_dir field for [`BloomFilter`]

src/filter/bf.rs:175

↓ 1 callersMethodsize

(&self)

src/fs/mod.rs:88

↓ 1 callersMethodsize_unit

Returns `size` of `MemTable`

src/memtable/mem.rs:318

↓ 1 callersFunctionsleep_gc_task

(duration: std::time::Duration)

src/gc/garbage_collector.rs:555

↓ 1 callersMethodspawn_compaction_worker

Background compaction runner for maintenance

src/compactors/compact.rs:270

↓ 1 callersMethodsstable_count_exceeds_threshhold

(&self)

src/bucket/bucket_manager.rs:171

↓ 1 callersMethodstart_background_tasks

Starts background tasks that maintain the keyspace. Should not be called, unless [`DataStore::open`] and should not be user-facing.

src/db/store.rs:173

↓ 1 callersMethodstart_flush_listener

Background flush listener If a flush signal has been sent then compaction handler is called

src/compactors/compact.rs:224

↓ 1 callersMethodstart_gc_worker

Continues to check if it's time to run GC (works in background)

src/gc/garbage_collector.rs:118

↓ 1 callersMethodsync_all

(&self)

src/fs/mod.rs:234

↓ 1 callersMethodsync_gc_update_with_store

(&mut self)

src/db/store.rs:291

↓ 1 callersMethodsync_to_disk

Ensures value log entries are persisted on the disk # Error Returns error in case there is an IO error

src/vlog/v_log.rs:215

↓ 1 callersMethodupdate_meta_background

(&self)

src/db/store.rs:313

↓ 1 callersMethodwith_compaction_strategy

Sets the compaction strategy.

src/cfg/config.rs:206

↓ 1 callersMethodwrite_to_file

Writes SSTable files to disk After successful write, the summary and bloom filter for the table is set and stored in memory Errors Returns error in

src/sst/table.rs:258

Methodbuild

(root_path: impl AsRef<Path> + Send + Sync)

src/db/store.rs:751

Methodbuild_from

Returns new `Table` using the supplied parameters

src/sst/table.rs:208

Methodcal_average_size

Calculate `Bucket` average size Returns a `Result` that can be the average size or error # Errors Returns error, if an IO error occured.

src/bucket/bucket_manager.rs:111

Methodcalculate_no_of_bits

Calculates number of bits to be inserted to `bit_vec`

src/filter/bf.rs:230

Methodcalculate_no_of_hash_function

Calculates number of hash fuctions to be used by [`BloomFilter`]

src/bucket/bucket_manager.rs:354

Methodcreate_or_recover

Creates or opens a keyspace in the specified directory. # Errors Returns error, if an IO error occured.

src/db/store.rs:683

Functiondatastore_compaction

()

src/tests/store_test.rs:274

Functiondatastore_create_new

()

src/tests/store_test.rs:33

Functiondatastore_deletion

()

src/tests/store_test.rs:389

Functiondatastore_gc_test_free_before_synchronization

()

src/tests/gc_test.rs:142

Functiondatastore_gc_test_head_shifted

()

src/tests/gc_test.rs:230

Functiondatastore_gc_test_no_entry_to_collect

()

src/tests/gc_test.rs:270

Functiondatastore_gc_test_punch_hole

()

src/tests/gc_test.rs:309

Functiondatastore_gc_test_success

()

src/tests/gc_test.rs:28

Functiondatastore_gc_test_tail_shifted

()

src/tests/gc_test.rs:103

Functiondatastore_gc_test_tail_shifted_to_correct_position

()

src/tests/gc_test.rs:179

Functiondatastore_gc_test_unsupported_platform

()

src/tests/gc_test.rs:66

Functiondatastore_not_found

()

src/tests/store_test.rs:247

Functiondatastore_put_test

()

src/tests/store_test.rs:56

Functiondatastore_recover

()

src/tests/store_test.rs:42

Functiondatastore_test_put_and_get

()

src/tests/store_test.rs:90

Functiondatastore_test_put_and_get_concurrent

()

src/tests/store_test.rs:142

Functiondatastore_test_seqential_put

()

src/tests/store_test.rs:197

Functiondatastore_test_sequential_put_and_get

()

src/tests/store_test.rs:220

Functiondatastore_update

()

src/tests/store_test.rs:336

Methoddefault

()

src/compactors/insertor.rs:52

src/key_range/range.rs:50

Methodfetch_imbalanced_buckets

Returns buckets whose size exceeds max threshold

src/compactors/sized.rs:55

(insert_time: CreatedAt, lowest_insert_date: CreatedAt)

src/gc/garbage_collector.rs:513

Methodfrom

Creates `Bucket` from the passed in variables Returns Ok(Bucket) # Errors Returns error, if an IO error occured.

src/bucket/bucket_manager.rs:86

Methodfrom

( false_pos: f64, entries: Arc<SkipMap<Vec<u8>, SkipMapValue<usize>>>, )

src/tests/workload.rs:123

Methodfrom

(entries: SkipMapEntries<Key>, filter: &BloomFilter)

src/compactors/insertor.rs:27

Methodgc_handler

Handles online garbage collection Fetch `gc_chunk_size` from value log, checks valid and invalid entries. Re-inserts valid entries while it filters o

src/gc/garbage_collector.rs:168

Methodgenerate_file_path

Creates table directory Returns data and index file name

src/sst/table.rs:166

Methodgenerate_ssts

(number: u32)

src/tests/workload.rs:164

Methodgenerate_table_id

Used to generate id for read-only `MemTable`

src/memtable/mem.rs:255

Methodget

Retrieves a Block Offset from index file

src/index/indexer.rs:170

Methodget

Returns a key from a block in sstable data file # Errors Returns IO error in case it occurs

src/sst/table.rs:184

Methodget

Fetches value from value log returns tuple of Value and Tombstone # Error Returns error in case there is an IO error

src/vlog/v_log.rs:205

Methodget

(&self, start_offset: usize)

src/fs/mod.rs:470

Methodget_block_range

(&self, start_key: &[u8], end_key: &[u8])

src/fs/mod.rs:712

Methodget_bloom_filter

Returns `Memtable` bloom filter

src/memtable/mem.rs:308

Methodget_bucket_id_from_full_bucket_path

(full_path: impl P)

src/db/recovery.rs:387

Methodget_data_file_path

Returns `Table` `data_file` path

src/sst/table.rs:154

Methodget_dir

Get [`DataStore`] directories

src/db/store.rs:736

Methodget_entries

(&self)

src/memtable/mem.rs:158

Methodget_entry_count

Get entry count

src/block/block_manager.rs:169

Methodget_filter

(&self)

src/memtable/mem.rs:166

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