Functions — github.com/ShisoftResearch/Nebuchadnezzar

hub / github.com/ShisoftResearch/Nebuchadnezzar / functions

Functions2,177 in github.com/ShisoftResearch/Nebuchadnezzar

⨍ Functions 2,177◇ Types & classes 366

↓ 8 callersFunctionschema_with_id

(schema_id: u32, name: &str, blobs: bool)

src/ram/recovery.rs:1174

↓ 8 callersFunctionscoped_txn_client

( address: &String, group_name: &str, )

src/server/transactions/corruption_tests.rs:13

↓ 8 callersMethodtransaction

(&self, func: TFN)

src/client/mod.rs:385

↓ 8 callersFunctionwait_for_shared_counter_alignment

( manager: &crate::ram::tiered::manager::TieredMemoryManager, chunk_sets: &[&Arc<Chunks>], timeout

src/ram/tiered/tests.rs:147

↓ 8 callersMethodwrite_commit_marker

Write a commit marker for a transaction

src/server/transactions/undo_log.rs:372

↓ 7 callersFunctioncell_header_from_entry_content_addr

(addr: usize)

src/ram/cell.rs:696

↓ 7 callersMethodcompare_version_and_set_field

( &self, hash: u64, version: u64, field: u64, value: OwnedValue, )

src/ram/chunk.rs:1357

↓ 7 callersFunctiondecompress_if_compressed

Decompress data or return original if not compressed This function auto-detects compression by checking for the magic number. If the data is not comp

src/ram/compression.rs:60

↓ 7 callersFunctiondeletion_set

()

src/index/ranged/tree/btree/test.rs:61

↓ 7 callersMethodensure_rw_state

(&self, txn: &TxnGuard)

src/server/transactions/manager.rs:984

↓ 7 callersFunctionentry_bytes_at

(addr: usize)

src/ram/recovery.rs:1194

↓ 7 callersMethodfirst_key

(&self)

src/index/ranged/tree/btree/node.rs:134

↓ 7 callersMethodflush_to_disk

Flush in-memory stats to disk using upsert operations Note: Posting lists are written directly to Chunks during add_document, so we only need to flus

src/index/full_text/shard.rs:917

↓ 7 callersMethodget_all_schema

(&self)

src/client/mod.rs:606

↓ 7 callersMethodget_or_create_transaction

(&self, tid: &TxnId)

src/server/transactions/data_site.rs:173

↓ 7 callersMethodhead_id

Get the tree's head ID for persistence

src/index/ranged/tree/tree.rs:307

↓ 7 callersFunctionheader_from_chunk_raw

(ptr: usize)

src/ram/cell.rs:716

↓ 7 callersMethodinsert

Insert an index into the indexer clients

src/index/builder.rs:228

↓ 7 callersMethoditer_keys

Iterate over all segment IDs that have active segments Returns an iterator over keys (segment IDs) Uses bitmap for efficient iteration (O(capacity/64)

src/ram/segment_list.rs:224

↓ 7 callersMethodopen

()

src/query/planner/range.rs:68

↓ 7 callersMethodprefix_gt

Check if this key's prefix (schema + field + feature) is greater than the other's.

src/index/entry.rs:121

↓ 7 callersFunctionprobe_cell_indices

Function to probe and generate indices for a cell based on its schema

src/index/builder.rs:714

↓ 7 callersMethodpunch_hole

Frees memory pages from this segment starting at the given offset. This function uses `madvise_free` to free pages from the aligned start offset to t

src/ram/segs.rs:280

↓ 7 callersMethodput_segment

(&self, segment: Segment)

src/ram/chunk.rs:956

↓ 7 callersMethodrefresh_statistics_for_schema

(&self, schema_id: u32)

src/ram/chunk.rs:182

↓ 7 callersMethodset_hot

(&self)

src/ram/segs.rs:976

↓ 7 callersMethodsize

(&self)

src/index/ranged/tree/btree/mod.rs:379

↓ 7 callersFunctionstart_external_nodes_write_back

(_client: &Arc<client::AsyncClient>)

src/index/ranged/tree/btree/storage.rs:53

↓ 7 callersMethodupsert_cell

(&self, cell: &mut OwnedCell)

src/ram/chunk.rs:764

↓ 6 callersMethodaddr_by_id

(&self, id: usize)

src/ram/segs.rs:1473

↓ 6 callersMethodalloc_seg_with_class

( &self, file_manager: &Arc<SegmentFileManager>, segment_class: SegmentClass, )

src/ram/segs.rs:1292

↓ 6 callersMethodcheck_and_evict

Check if eviction is needed and evict segments if necessary (legacy/test-only) NOTE: This method is kept for tests/benchmarks compatibility. Producti

src/ram/tiered/manager.rs:315

↓ 6 callersFunctionclause_priority

(candidate: &IndexedClausePlan)

src/query/planner/expr.rs:683

↓ 6 callersFunctionclause_selectivity_cost

(candidate: &IndexedClausePlan)

src/query/planner/expr.rs:824

↓ 6 callersMethodclient_by_server_id

( &'a self, server_id: u64, )

src/client/mod.rs:177

↓ 6 callersMethodcommit

(&self)

src/client/transaction.rs:208

↓ 6 callersFunctioncomparison_expr

(op: ClauseOp, field_id: u64, field_name: String, value: OwnedValue)

src/query/planner/expr.rs:1142

↓ 6 callersFunctioncompress

Compress data using LZ4 block format with CRC32 checksum Format: [MAGIC(4)] [CRC32(4)] [compressed_data_with_prepended_size] The CRC32 checksum is c

src/ram/compression.rs:29

↓ 6 callersMethodcount_hot_segments

Count hot segments in the chunk.

src/ram/tiered/manager.rs:648

↓ 6 callersMethoddebug_check_integrity

(&self)

src/index/ranged/tree/btree/internal.rs:540

↓ 6 callersFunctionexpect_invalid_schema_registration

( client: &Arc<client::AsyncClient>, schema: Schema, )

src/client/tests.rs:442

↓ 6 callersMethodget_clock

(&self)

src/server/transactions/manager.rs:555

↓ 6 callersMethodget_embedding_index_core

Get the embedding index core. # Panics Panics if the core has not been set via `set_embedding_index_core`.

src/index/embedding/mod.rs:235

↓ 6 callersMethodget_vector_index_core

Get the vector index core. # Panics Panics if the core has not been set via `set_vector_index_core`.

src/index/vector/mod.rs:230

↓ 6 callersFunctionhistogram_with_distinct

(unique: usize)

src/query/planner/expr.rs:2073

↓ 6 callersFunctioninstall_basic_schema

(runtime: &Arc<crate::server::DatabaseRuntime>)

src/server/transactions/manager.rs:1133

↓ 6 callersMethodis_unassigned

(&self)

src/ram/chunk.rs:1905

↓ 6 callersMethodlocation_for_read

(&self, hash: u64)

src/ram/chunk.rs:570

↓ 6 callersFunctionmake_changed

(node: &NodeCellRef, tree: &BPlusTree<KS, PS>)

src/index/ranged/tree/btree/external.rs:442

↓ 6 callersMethodmerge_clock

(&self, clock: &StandardVectorClock)

src/server/transactions/manager.rs:558

↓ 6 callersFunctionnew_index_task

(task: impl Future<Output = Result<(), IndexError>> + Send + 'static)

src/index/builder.rs:355

↓ 6 callersFunctionnew_test_file_manager

()

src/ram/segment_list.rs:337

↓ 6 callersMethodnote_dead_bytes_change

(&self)

src/ram/segs.rs:333

↓ 6 callersMethodprefix_lt

Check if this key's prefix (schema + field + feature) is less than the other's.

src/index/entry.rs:134

↓ 6 callersFunctionquery_price_range

Helper function to query a price range and collect results

src/index/ranged/tree/service_test.rs:1052

↓ 6 callersFunctionscan_segment_for_recovery_test

( chunk: &Chunk, data: &[u8], )

src/ram/recovery.rs:1256

↓ 6 callersMethodschema_by_id

(&self, id: u32)

src/client/mod.rs:512

↓ 6 callersFunctionseed_counter_cell

( runtime: &Arc<crate::server::DatabaseRuntime>, schema_id: u32, id: Id, score

src/server/transactions/manager.rs:1146

↓ 6 callersMethodsegment_ids

(&self)

src/ram/chunk.rs:1144

↓ 6 callersMethodset_cold

(&self)

src/ram/segs.rs:935

↓ 6 callersFunctiontotal_hot_segments

(chunks: &Arc<Chunks>)

src/ram/tiered/tests.rs:105

↓ 6 callersMethodtotal_hot_segments

(&self)

src/ram/tiered/mod.rs:106

↓ 6 callersMethodundo_log

(&self)

src/server/transactions/data_site.rs:238

↓ 6 callersMethodupsert_cell

(&self, mut cell: OwnedCell)

src/server/cell_rpc.rs:138

↓ 6 callersMethodwith_blobs

(mut self, blobs: bool)

src/ram/schema/mod.rs:168

↓ 6 callersMethodwith_indices_ensured

(&'a self, op: F)

src/server/cell_rpc.rs:307

↓ 6 callersFunctionwrite_node

(node: &NodeCellRef)

src/index/ranged/tree/btree/node.rs:388

↓ 5 callersMethodabort

(&self, tid: TxnId)

src/server/transactions/manager.rs:347

↓ 5 callersFunctionappend_round_robin_until_reconciled_hot_segments

( chunks: &Arc<Chunks>, schema_id: u32, partitions: &[u64], next_indices: &mut [usize], ma

src/ram/tiered/tests.rs:178

↓ 5 callersMethodassert_address_aligned_for_write

(&self, addr: usize, operation: &str, hash: u64)

src/ram/chunk.rs:247

↓ 5 callersMethodbuild

(self)

src/index/full_text/coordinator.rs:424

↓ 5 callersFunctioncell_version_from_chunk_raw

(ptr: usize)

src/ram/cell.rs:725

↓ 5 callersFunctionclient_by_server_name_for_database

( server_id: u64, server_name: String, group_name: &str, database_name: &str, )

src/client/mod.rs:700

↓ 5 callersMethodcount

Get count of keys in tree

src/index/ranged/tree/tree.rs:302

↓ 5 callersMethodcreate

Create a new ranged tree

src/index/ranged/tree/tree.rs:41

↓ 5 callersMethodcurrent_database

(&self)

src/server/mod.rs:967

↓ 5 callersFunctiondata_manager_for_database

( server: &Arc<NebServer>, address: &str, database_name: &str, )

src/server/transactions/data_site.rs:808

↓ 5 callersMethoddecr_references

(&self)

src/ram/segs.rs:818

↓ 5 callersMethoddecrement_and_check

(&self)

src/ram/segs.rs:1066

↓ 5 callersMethodensure_chunk_state

(&self, chunk: &Chunk)

src/ram/tiered/manager.rs:132

↓ 5 callersMethodensure_indices

(&self, new_cell: &OwnedCell, old_cell: Option<&SharedCell>, schema: &Schema)

src/ram/chunk.rs:663

↓ 5 callersMethodfinish

(self)

src/exec/funcs/aggregate/sum.rs:18

↓ 5 callersMethodforce_wal_sync

Force a WAL sync, ensuring all buffered data is persisted to disk This is useful for transaction commits and other critical durability points

src/ram/segs.rs:762

↓ 5 callersFunctionget_hash_id

(schema: u32, field: u64, hash_feat: Feature)

src/index/hash/mod.rs:371

↓ 5 callersMethodget_head_seg_id

(&self)

src/ram/chunk.rs:381

↓ 5 callersMethodhot_memory_bytes

(&self, hot_segments_count: usize)

src/ram/tiered/manager.rs:89

↓ 5 callersMethodid_by_addr

(&self, addr: usize)

src/ram/segs.rs:1466

↓ 5 callersMethodinsert

(&self, key: &EntryKey)

src/index/ranged/client/mod.rs:174

↓ 5 callersFunctioninvalid_page_format

(cell: &OwnedCell, reason: impl Into<String>)

src/index/ranged/tree/btree/external.rs:39

↓ 5 callersFunctionis_null_like

(value: &OwnedValue)

src/query/data_client/aggregate.rs:517

↓ 5 callersMethodis_ref_none

(&self)

src/index/ranged/tree/btree/node.rs:559

↓ 5 callersMethodis_scannable

(self)

src/query/data_client/alignment_tests.rs:280

↓ 5 callersMethodlocate_key

(&self, entry: EntryKey)

src/index/ranged/sm.rs:66

↓ 5 callersFunctionlocate_tree_server_from_conshash

( id: &Id, conshash: &Arc<ConsistentHashing>, group_name: &str, database_name: &str, )

src/index/ranged/tree/service.rs:1318

↓ 5 callersFunctionmake_pool

(threshold: f32, limit: usize)

src/ram/tiered/manager.rs:710

↓ 5 callersMethodmark_dead_entry_with_cell

(&self, addr: usize, cell: &C)

src/ram/chunk.rs:1135

↓ 5 callersMethodmark_dead_entry_with_size

(&self, addr: usize, size: u32, seg: &Segment)

src/ram/chunk.rs:1101

↓ 5 callersMethodmark_referenced

(&self)

src/ram/segs.rs:1017

↓ 5 callersMethodmerge_levels

No-op: Single tree doesn't need level merging

src/index/ranged/tree/tree.rs:314

↓ 5 callersMethodmerge_with

(&mut self, right: &mut Self, right_key: EntryKey)

src/index/ranged/tree/btree/internal.rs:364

← previous next →201–300 of 2,177, ranked by callers