Functions — github.com/ShisoftResearch/Nebuchadnezzar

hub / github.com/ShisoftResearch/Nebuchadnezzar / functions

Functions2,177 in github.com/ShisoftResearch/Nebuchadnezzar

⨍ Functions 2,177◇ Types & classes 366

↓ 2 callersMethodindexed_predicate_plan

( &self, schema_id: u32, selection: &Expr, order_by_field: Option<u64>,

src/query/data_client/plan.rs:13

↓ 2 callersMethodinit_directories

Initialize storage directories

src/ram/file_manager.rs:49

↓ 2 callersMethodinsert_back

Alias for insert() to match LinkedHashMap API

src/ram/segment_list.rs:285

↓ 2 callersMethodinsert_in_place

( &mut self, key: EntryKey, new_node: NodeCellRef, pos: usize, padding

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

↓ 2 callersFunctioninstall_recovered_segment

(chunk: &Chunk, segment: Segment)

src/ram/recovery.rs:434

↓ 2 callersMethodinto_cell_guard

(self)

src/ram/cell.rs:514

↓ 2 callersMethodinto_ref

(self)

src/ram/cell.rs:259

↓ 2 callersMethodis_embedding_index_core_set

Check if the embedding index core has been set.

src/index/embedding/mod.rs:240

↓ 2 callersFunctionis_korean_char

(c: char)

src/index/full_text/tokenizer.rs:190

↓ 2 callersFunctionis_range_equality

(range: &ValueRange)

src/query/planner/expr.rs:704

↓ 2 callersFunctionis_tree_in_order

(tree: &BPlusTree<KS, PS>, level: usize)

src/index/ranged/tree/btree/verification.rs:157

↓ 2 callersMethodis_var

(&self)

src/ram/schema/mod.rs:543

↓ 2 callersMethodis_vector_index_core_set

Check if the vector index core has been set.

src/index/vector/mod.rs:235

↓ 2 callersMethodis_vector_search_coordinator_set

(&self)

src/index/vector/mod.rs:247

↓ 2 callersMethodkey_pos_from_ptr_pos

(&self, ptr_pos: usize)

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

↓ 2 callersMethodlast_key

(&self)

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

↓ 2 callersMethodlevels

(&self)

src/index/ranged/tree/btree/reconstruct.rs:143

↓ 2 callersFunctionlist_all_files

(dir: &Path)

src/ram/recovery.rs:2271

↓ 2 callersMethodliving_space

(&self)

src/ram/segs.rs:383

↓ 2 callersMethodload_tree

(&self, id: Id, boundary: Boundary, epoch: u64)

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

↓ 2 callersMethodlocate_tree_server

(&self, id: &Id)

src/index/ranged/sm.rs:425

↓ 2 callersMethodlower_watermark_limit

(&self)

src/ram/tiered/manager.rs:84

↓ 2 callersFunctionmadvise_free

(addr: usize, size: usize)

src/ram/segs.rs:1478

↓ 2 callersMethodmark_changed

(&self, node: &NodeCellRef)

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

↓ 2 callersMethodmark_field_stats_dirty

(&self, schema_id: u32, field_id: u64)

src/index/full_text/shard.rs:541

↓ 2 callersMethodmemory_status

Get comprehensive memory status including chunk and segment statistics This function provides detailed information about: - Total number of chunks -

src/server/status.rs:157

↓ 2 callersMethodmerge_hits

Merge hits from multiple nodes (simple score aggregation)

src/index/full_text/coordinator.rs:174

↓ 2 callersFunctionmerge_statistics

(all_stats: Vec<Arc<SchemaStatistics>>)

src/query/statistics/mod.rs:414

↓ 2 callersFunctionmerge_with_boundary

( level: usize, src_tree: &BPlusTree<KS, PS>, dest_tree: &dyn LevelTree, key_boundary: &EntryK

src/index/ranged/tree/btree/level.rs:343

↓ 2 callersMethodname

Get the model name.

src/index/embedding/mod.rs:53

↓ 2 callersMethodneb_name

(self)

src/query/data_client/alignment_tests.rs:34

↓ 2 callersMethodnew_cursor

( &'a self, index_cursor: Option<ClientCursor>, projection: Vec<u64>, selectio

src/query/data_client/read.rs:116

↓ 2 callersMethodnew_index

Create a new vector index.

src/index/vector/mod.rs:323

↓ 2 callersMethodnew_index_with_config

( &self, schema_id: u32, field_id: u64, hnsw_config: HnswConfig, )

src/index/vector/mod.rs:331

↓ 2 callersFunctionnewer_resident_segment

(chunk: &Chunk, seg_id: u64, seq_id: u64)

src/ram/recovery.rs:291

↓ 2 callersMethodnext_block

(&mut self)

src/query/data_client/cursor.rs:85

↓ 2 callersFunctionnode_version

(cc_num: usize)

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

↓ 2 callersFunctionnormalize_selection_for_eval

(selection: &Expr)

src/query/planner/expr.rs:330

↓ 2 callersMethodopen_or_create_backup_writer

Open or create a backup file for writing (unbuffered for memory efficiency) If the file exists, it opens for read/write without truncating If the file

src/ram/file_manager.rs:128

↓ 2 callersMethodoverall_statistics

(&self, schema: u32)

src/ram/chunk.rs:1728

↓ 2 callersFunctionowned_value_string

(value: &OwnedValue)

src/query/planner/expr.rs:1457

↓ 2 callersFunctionowned_value_to_f64

(value: &OwnedValue)

src/query/data_client/aggregate.rs:553

↓ 2 callersMethodpersist

( &self, deletion: &Arc<DeletionSet>, neb: &Arc<crate::client::AsyncClient>, )

src/index/ranged/tree/btree/cell_ref.rs:111

↓ 2 callersFunctionplan_write_array_len

( len: usize, offset: &mut usize, field: &Field, value: &'a OwnedValue, ins: &mut WriteIns

src/ram/io/writer.rs:248

↓ 2 callersFunctionplan_write_dynamic_map

( offset: &mut usize, map: HashMap<u64, &'a OwnedValue>, fields: &[String], ins: &mut WriteIns

src/ram/io/writer.rs:300

↓ 2 callersFunctionplan_write_dynamic_value

( offset: &mut usize, value: &'a OwnedValue, ins: &mut WriteInstructions<'a>, )

src/ram/io/writer.rs:359

↓ 2 callersFunctionplan_write_field

( tail_offset: &mut usize, field: &Field, value: &'a OwnedValue, mut ins: &mut WriteInstructio

src/ram/io/writer.rs:59

↓ 2 callersMethodpos_of

(&self, slice: &[Feature])

src/query/planner/range.rs:72

↓ 2 callersMethodprefix_ge

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

src/index/entry.rs:126

↓ 2 callersMethodprefix_le

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

src/index/entry.rs:139

↓ 2 callersMethodprint_summary

Print the status in a human-readable format

src/server/status.rs:55

↓ 2 callersFunctionpromote_segment

Promote a cold segment to hot storage with cell-level locking This operation uses cell-level locking to ensure safety: CRITICAL SAFETY**: We must lo

src/ram/tiered/promotion.rs:34

↓ 2 callersMethodptrs

(&self)

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

↓ 2 callersMethodpush_extnode

(&mut self, node: &NodeCellRef, first_key: EntryKey)

src/index/ranged/tree/btree/reconstruct.rs:54

↓ 2 callersMethodput_tombstone_by_cell_loc

(&self, cell_location: usize)

src/ram/chunk.rs:1068

↓ 2 callersFunctionrange_term_pos

(term: &ValueRangeTerm, histogram: &[[u8; 8]], start_side: bool)

src/query/cost/planner.rs:101

↓ 2 callersMethodread_all_cells_selected

( &self, ids: &Vec<Id>, fields: &Vec<u64>, need_header: bool, )

src/client/mod.rs:218

↓ 2 callersFunctionread_dynamic_value

(ptr: &'a mut usize, type_id: u8)

src/ram/io/reader.rs:256

↓ 2 callersFunctionread_field

Reads a field from memory at the given base pointer according to the field's schema. # Arguments `base_ptr` - Base memory address to read from `field

src/ram/io/reader.rs:24

↓ 2 callersFunctionread_lock_pid

(file: &mut File)

src/server/storage_lock.rs:167

↓ 2 callersMethodreconcile_chunk

(&self, chunk: &Chunk)

src/ram/tiered/manager.rs:265

↓ 2 callersMethodrefresh_batch

(&mut self)

src/query/data_client/cursor.rs:97

↓ 2 callersMethodrefresh_compression_plan

(&mut self)

src/ram/schema/mod.rs:217

↓ 2 callersMethodregister_internal_schema

Register an internal/system schema locally (allowed in release builds) Use this for system schemas that must be registered before recovery (e.g., inv

src/ram/schema/mod.rs:683

↓ 2 callersFunctionregister_schema

Helper to register a schema (works in both debug and release mode) In release mode, we bypass the debug-only check by using unsafe to access private f

benches/inverted_index.rs:42

↓ 2 callersFunctionregister_schema_state_machine_on_plane

( group_name: &str, database_name: &str, plane: &raft::PlaneHandle, recovering_flag: Arc<std::

src/server/mod.rs:223

↓ 2 callersMethodremove_cell_by

(&self, hash: u64, predict: P)

src/ram/chunk.rs:928

↓ 2 callersMethodremove_indices

(&self, cell: &SharedCell, schema: &Schema)

src/ram/chunk.rs:670

↓ 2 callersFunctionrender_sql_query

(query: &AlignQuery)

src/query/data_client/alignment_tests.rs:819

↓ 2 callersMethodreset_access_count

(&self)

src/ram/segs.rs:1087

↓ 2 callersMethodresidual

(&self)

src/query/planner/expr.rs:206

↓ 2 callersMethodroot

(&self)

src/index/ranged/tree/btree/reconstruct.rs:129

↓ 2 callersMethodrotate_log

Rotate to a new log file

src/server/transactions/undo_log.rs:312

↓ 2 callersFunctionrow_bytes

( schema: u32, projection: &Vec<u64>, meta: &Arc<ServerMeta>, stat: &Arc<SchemaStatistics>, )

src/query/cost/mod.rs:54

↓ 2 callersFunctionrun_aggregate_alignment_suite

( server: Arc<NebServer>, port: u16, datasets: Vec<AlignDataset>, schema_mode: AlignSchemaMode

src/query/data_client/alignment_tests.rs:566

↓ 2 callersFunctionrun_insert_pressure_test

(server_group: &str, server_addr: &str, multiplier: usize)

src/index/ranged/mod.rs:28

↓ 2 callersFunctionscan_all_prices

( idx_client: &crate::query::data_client::IndexedDataClient, schema_id: u32, )

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

↓ 2 callersMethodscan_dir_recursive

Helper function to recursively scan directories for segment files

src/ram/file_manager.rs:358

↓ 2 callersFunctionscan_segment_from_data

Scan recovered segment data from a slice and update the recovery index state. The scan runs against the deterministic virtual address range for the s

src/ram/recovery.rs:515

↓ 2 callersFunctionschema

()

src/index/ranged/mod.rs:305

↓ 2 callersMethodschema_pattern

Create schema scan pattern

src/client/ranged.rs:217

↓ 2 callersFunctionscore_candidates

( candidates: Vec<IndexedClausePlan>, disjunction: bool, schema_stats: Option<&SchemaStatistics>,

src/query/planner/expr.rs:415

↓ 2 callersMethodsearch

( &self, schema_id: u32, field_id: u64, _query_vector: &[f32], limit:

src/query/data_client/tests.rs:66

↓ 2 callersMethodsearch

(&self, key: &EntryKey)

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

↓ 2 callersMethodsearch

(&self, key: &EntryKey)

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

↓ 2 callersFunctionsearch_node

( node_ref: &NodeCellRef, key: &EntryKey, ordering: Ordering, deletion: &Arc<DeletionSet>,

src/index/ranged/tree/btree/search.rs:9

↓ 2 callersMethodsearch_unwindable

search may panic if another thread is writing, this will return error if panic occurred

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

↓ 2 callersMethodseek_raw

(&self, key: &EntryKey, ordering: Ordering)

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

↓ 2 callersMethodsegs_for_combine_cleaner

(&self)

src/ram/chunk.rs:1152

↓ 2 callersMethodsegs_for_combine_cleaner_full

(&self)

src/ram/chunk.rs:1156

↓ 2 callersMethodsegs_for_combine_cleaner_impl

(&self, full: bool)

src/ram/chunk.rs:1192

↓ 2 callersMethodset_binding

(&mut self, sym_id: u64, expr: Expr)

src/exec/query/env.rs:36

↓ 2 callersMethodset_ptr

(&mut self, ptr: usize)

src/ram/chunk.rs:2013

↓ 2 callersFunctionset_transaction_context

Set the transaction context for the current thread

src/ram/chunk.rs:146

↓ 2 callersFunctionshared_value_by_path

( value: &'a SharedValue<'a>, path: &[u64], )

src/ram/cell.rs:574

↓ 2 callersFunctionshould_trace_cursor

(key: &EntryKey, pattern: Option<&[u8]>)

src/index/ranged/client/cursor.rs:23

↓ 2 callersMethodsites_end

( &self, tid: &TxnId, changed_objs: &AffectedObjs, data_sites: &DataSitesMap,

src/server/transactions/manager.rs:943

↓ 2 callersMethodsort_ids_by_field

( &self, field_id: u64, ids: &mut [Id], ordering: QueryOrdering, tie_b

src/query/data_client/sort.rs:35

↓ 2 callersFunctionthread_stripe

()

src/ram/tiered/mod.rs:33

↓ 2 callersMethodto_bytes

Serialize entry to bytes

src/server/transactions/undo_log.rs:127

← previous next →601–700 of 2,177, ranked by callers