Functions — github.com/ShisoftResearch/Nebuchadnezzar

hub / github.com/ShisoftResearch/Nebuchadnezzar / functions

Functions2,177 in github.com/ShisoftResearch/Nebuchadnezzar

⨍ Functions 2,177◇ Types & classes 366

↓ 5 callersFunctionmin_entry_key

()

src/index/ranged/trees.rs:101

↓ 5 callersMethodnew_schema

( &self, mut schema: Schema, )

src/client/mod.rs:559

↓ 5 callersMethodnew_schema

(fields: Vec<Field>)

src/ram/schema/mod.rs:304

↓ 5 callersFunctionnew_test_file_manager

()

src/ram/tests/segment_alignment_test.rs:8

↓ 5 callersMethodrange_seek

( &'a self, range: Range, buffer_size: u16, pattern: Option<u8>, )

src/index/mod.rs:143

↓ 5 callersFunctionranged_tree_cell

Create a cell for storing tree metadata

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

↓ 5 callersMethodread

(&self, id: Id)

src/client/transaction.rs:101

↓ 5 callersMethodread_cells_from_ids

( &self, ids: &[Id], projection: &Vec<u64>, selection: &Expr, proc: &E

src/query/data_client/read.rs:136

↓ 5 callersFunctionread_unchecked

(node: &NodeCellRef)

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

↓ 5 callersFunctionreconcile_global_hot_segments

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

src/ram/tiered/tests.rs:165

↓ 5 callersMethodrefresh_key_mapping

( &self, key: &EntryKey, )

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

↓ 5 callersMethodremove

Remove an index from the indexer clients

src/index/builder.rs:292

↓ 5 callersMethodremove_cell

(&self, id: Id)

src/client/mod.rs:339

↓ 5 callersMethodrev_topological_sort

(&self)

src/exec/dag.rs:79

↓ 5 callersFunctionscoped_txn_client

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

src/server/transactions/tests.rs:12

↓ 5 callersFunctionselection_to_dnf_conjunctions

(selection: &Expr)

src/query/planner/expr.rs:969

↓ 5 callersFunctionshared_meta_plane_id

(_group_name: &str)

src/server/mod.rs:163

↓ 5 callersMethodsql_name

(self)

src/query/data_client/alignment_tests.rs:44

↓ 5 callersMethodstring

(&self, key: &str)

src/ram/cell.rs:434

↓ 5 callersFunctiontiered_txn_client

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

src/ram/tiered/tests.rs:24

↓ 5 callersMethodupdate_cell

( &self, cell: OwnedCell, )

src/client/mod.rs:325

↓ 5 callersMethodupdate_clock

(&self, clock: &StandardVectorClock)

src/server/transactions/data_site.rs:169

↓ 5 callersMethodused_spaces

(&self)

src/ram/segs.rs:377

↓ 5 callersFunctionwrite_targeted

( mut search_page: NodeWriteGuard<KS, PS>, key: &EntryKey, )

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

↓ 4 callersMethodadd_compound_index

(&mut self, name: &str, fields: Vec<String>, indices: Vec<IndexType>)

src/ram/schema/mod.rs:185

↓ 4 callersMethodadjust_delta

(&self, delta: isize)

src/ram/tiered/mod.rs:96

↓ 4 callersMethodaggregate

( &self, schema: u32, query: AggregateQuery, projection: Vec<ProjectionItem>,

src/query/data_client.rs:350

↓ 4 callersFunctionalign_ptr_addr

(addr: usize)

src/ram/io/mod.rs:27

↓ 4 callersMethodall_chunk_statistics

(&self, schema_id: u32)

src/ram/chunk.rs:1717

↓ 4 callersMethodalloc_seg_at_id_with

( &self, seg_id: u64, seq_id: u64, file_manager: &Arc<SegmentFileManager>,

src/ram/segs.rs:1393

↓ 4 callersFunctionare_keys_serial

(keys: &[EntryKey])

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

↓ 4 callersFunctionbuild_histogram

(partitations: Vec<&(Vec<HistogramKey>, usize, usize)>)

src/query/statistics/mod.rs:316

↓ 4 callersMethodcell_count

(&self)

src/ram/chunk.rs:1310

↓ 4 callersMethodcell_meta_mutex

(&self, id: &Id)

src/server/transactions/data_site.rs:208

↓ 4 callersFunctionchunk_and_segment_from_addr

Calculate chunk ID and segment ID from a fault address Returns: Some((chunk_id, segment_id)) or None if address not in range

src/ram/chunk.rs:58

↓ 4 callersMethodcmp

(&self, other: &EntryKey)

src/index/entry.rs:223

↓ 4 callersFunctioncollect_query_rows

(mut cursor: QueryResultCursor)

src/query/data_client/tests.rs:5480

↓ 4 callersMethodcollect_registered_chunk_sets

(&self)

src/ram/tiered/manager.rs:200

↓ 4 callersFunctioncompare_owned_values

( left: &OwnedValue, right: &OwnedValue, ordering: QueryOrdering, )

src/query/data_client/aggregate.rs:505

↓ 4 callersMethodcount

(&self)

src/server/cell_rpc.rs:166

↓ 4 callersFunctioncreate_test_chunks

Helper to create test chunks

benches/inverted_index.rs:95

↓ 4 callersFunctioncreate_test_meta

Helper to create test document metadata

benches/inverted_index.rs:197

↓ 4 callersFunctiondefault_fields

()

src/ram/tiered/bench.rs:21

↓ 4 callersMethoddelete_index

Delete a vector index.

src/index/vector/mod.rs:342

↓ 4 callersMethodensure_indices_with_res

( &self, cell: &OwnedCell, old_indices: Option<Vec<IndexRes>>, schema: &Schema

src/ram/chunk.rs:676

↓ 4 callersFunctionexpect_schema_registration_ok

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

src/client/tests.rs:436

↓ 4 callersMethodexplicit_evict

Explicitly evict a specific number of segments from one chunk (test-only) NOTE: This method is kept for tests compatibility. Production code should r

src/ram/tiered/manager.rs:326

↓ 4 callersFunctionexpr_field_id

(expr: &Expr)

src/query/planner/expr.rs:1472

↓ 4 callersMethodextnode

(&self)

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

↓ 4 callersMethodfield_id

(self)

src/query/data_client/alignment_tests.rs:54

↓ 4 callersFunctionfields_with_score

Helper to create fields with a score counter for transaction tests

src/ram/tiered/tests.rs:44

↓ 4 callersFunctionfind_owned_doc_ids

Helper to find owned document IDs

benches/inverted_index.rs:209

↓ 4 callersMethodfind_transaction

(&self, tid: &TxnId)

src/server/transactions/data_site.rs:183

↓ 4 callersMethodget_by_seq_id

Get a segment by seq_id Returns a cloned Arc if the segment exists

src/ram/segment_list.rs:171

↓ 4 callersFunctionget_hash_partitioner

(env: &mut Environment)

src/exec/query/partitioning.rs:22

↓ 4 callersFunctionget_join_partitioner

( env: &mut query::env::Environment, )

src/exec/funcs/reducer/mod.rs:73

↓ 4 callersMethodget_server_id_by_id

(&self, id: &Id)

src/server/transactions/manager.rs:47

↓ 4 callersMethodget_term_postings

Get postings for a specific term by iterating ALL Chunks on this server Returns: (doc_id, term_freq, doc_length) Note: Version is stored for GC but no

src/index/full_text/shard.rs:730

↓ 4 callersMethodgroup_into_stages

(&self, rev_topo_sorted: Vec<u32>)

src/exec/dag.rs:128

↓ 4 callersMethodincr_references

(&self)

src/ram/segs.rs:791

↓ 4 callersMethodinsert_at

(&mut self, item: T, pos: usize, len: &mut usize)

src/index/ranged/trees.rs:41

↓ 4 callersFunctionis_cjk_char

(c: char)

src/index/full_text/tokenizer.rs:168

↓ 4 callersMethoditer_values

Iterate over all active segments Returns an iterator over Arc<Segment> Uses bitmap for efficient iteration

src/ram/segment_list.rs:239

↓ 4 callersMethodkey_at

(&self, index: usize)

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

↓ 4 callersMethodleft_ref_mut

(&mut self)

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

↓ 4 callersMethodlive_entries

(&'a self, seg: &'a Segment)

src/ram/chunk.rs:1241

↓ 4 callersFunctionmake_feature

(n: u64)

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

↓ 4 callersFunctionmodeled_total_size

(schema: &Schema, payload_len: usize)

src/ram/tests/blob_schema.rs:69

↓ 4 callersFunctionnull_check_clause

(clause: &Expr)

src/query/planner/expr.rs:1302

↓ 4 callersMethodold_index_res

(&self, schema: &Schema)

src/ram/chunk.rs:2003

↓ 4 callersMethodpersist_root

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

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

↓ 4 callersMethodprepare_read

( &self, clock: &StandardVectorClock, tid: &TxnId, id: &Id, )

src/server/transactions/data_site.rs:353

↓ 4 callersMethodprint

(&self)

src/ram/tiered/bench.rs:110

↓ 4 callersFunctionprojection_fields

(fields: &[&str])

src/query/data_client/tests.rs:5488

↓ 4 callersFunctionrandom_id

Helper function to create a random Id

src/server/transactions/undo_log.rs:932

↓ 4 callersFunctionread_by_schema

(ptr: usize, schema: &Schema)

src/ram/io/reader.rs:353

↓ 4 callersMethodread_selected

( &self, tid: TxnId, id: Id, fields: Vec<u64>, )

src/server/transactions/manager.rs:251

↓ 4 callersMethodreduce_with

(&mut self, key: K, value: V)

src/exec/funcs/reducer/mod.rs:37

↓ 4 callersMethodremove_document

Remove a document from the index Note: For now, we don't actually remove from posting lists (append-only). The document will be filtered out at query

src/index/full_text/shard.rs:642

↓ 4 callersFunctionrender_sql_ordering

(ordering: QueryOrdering)

src/query/data_client/alignment_tests.rs:896

↓ 4 callersFunctionreserve_addr

()

tests/storage_lock_process.rs:108

↓ 4 callersFunctionrun_alignment_suite

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

src/query/data_client/alignment_tests.rs:487

↓ 4 callersFunctionrun_projection_alignment_suite

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

src/query/data_client/alignment_tests.rs:526

↓ 4 callersMethodscan_by_expr_with_options

( &'a self, schema: u32, selection: Expr, ordering: QueryOrdering, ord

src/query/data_client.rs:314

↓ 4 callersMethodscan_schema_ids

( &self, schema: u32, _ordering: QueryOrdering, )

src/query/data_client/read.rs:52

↓ 4 callersFunctionscoped_storage_path

( base_path: &Option<String>, database_name: &str, should_scope: bool, )

src/server/database.rs:138

↓ 4 callersFunctionscoped_txn_client_for_database

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

src/server/transactions/manager.rs:1100

↓ 4 callersMethodsearch

(&self, key: &EntryKey)

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

↓ 4 callersMethodselect_victim

Select a victim segment for eviction using the CLOCK algorithm Algorithm: 1. Start at current clock hand position 2. For each segment: - Skip if it's

src/ram/tiered/clock.rs:43

↓ 4 callersFunctionsetup_test_conshash

Helper to set up ConsistentHashing for testing

benches/inverted_index.rs:115

↓ 4 callersMethodshared_pool

Access the shared server-wide memory pool.

src/ram/tiered/manager.rs:677

↓ 4 callersFunctionstart_manager_test_server

(address: &str, group: &str)

src/server/transactions/manager.rs:1110

↓ 4 callersFunctionstart_transaction_test_server

( address: &str, group: &str, )

src/server/transactions/data_site.rs:782

↓ 4 callersMethodthreshold_limit

(&self)

src/ram/tiered/manager.rs:79

↓ 4 callersFunctiontiered_manager_for_test

(physical_memory_limit: usize)

src/ram/recovery.rs:1183

↓ 4 callersMethodupdate_version

(&mut self, version: u64)

src/ram/chunk.rs:1863

↓ 4 callersMethodwith_compression

(mut self, compression: FieldCompression)

src/ram/schema/mod.rs:296

↓ 4 callersFunctionwrite_u64

(buffer: &mut W, value: u64)

src/ram/tombstone.rs:21

↓ 3 callersMethodabort

(&self)

src/client/transaction.rs:245

↓ 3 callersMethodadd

(&mut self, doc_id: Id, version: u64, tf: u32, doc_len: u32)

src/index/full_text/shard.rs:336

← previous next →301–400 of 2,177, ranked by callers