Functions — github.com/ShisoftResearch/Nebuchadnezzar

hub / github.com/ShisoftResearch/Nebuchadnezzar / functions

Functions2,177 in github.com/ShisoftResearch/Nebuchadnezzar

⨍ Functions 2,177◇ Types & classes 366

↓ 3 callersFunctiontokenize_japanese

Tokenize Japanese text using lindera

src/index/full_text/tokenizer.rs:330

↓ 3 callersFunctiontokenize_korean

Tokenize Korean text (character n-gram based, since we don't have a Korean tokenizer)

src/index/full_text/tokenizer.rs:363

↓ 3 callersFunctiontokenize_latin

Tokenize Latin-script text

src/index/full_text/tokenizer.rs:272

↓ 3 callersFunctiontokenize_mixed

Tokenize mixed-script content by processing segments separately

src/index/full_text/tokenizer.rs:472

↓ 3 callersFunctiontokenize_query

(query: &str)

src/index/full_text/mod.rs:210

↓ 3 callersFunctiontokenize_segment

Tokenize a segment of known script type

src/index/full_text/tokenizer.rs:519

↓ 3 callersMethodtrim_old_logs

Trim old log files that only contain committed/aborted transactions

src/server/transactions/undo_log.rs:725

↓ 3 callersMethodtry_acquire

(&self, size: u32)

src/ram/segs.rs:224

↓ 3 callersMethodupdate_cell_by

(&self, hash: u64, update: U)

src/ram/chunk.rs:837

↓ 3 callersMethodupdate_cell_write

(&self, cell_id: &Id, tid: &TxnId)

src/server/transactions/data_site.rs:296

↓ 3 callersFunctionvalues_semantically_equal

(left: &OwnedValue, right: &OwnedValue)

src/ram/types.rs:78

↓ 3 callersMethodwait_ready

(&mut self)

tests/storage_lock_process.rs:65

↓ 3 callersMethodwrite_abort_marker

Write an abort marker for a transaction

src/server/transactions/undo_log.rs:402

↓ 3 callersFunctionwritten_segment_id

(chunks: &Chunks, id: &Id)

src/ram/tests/blob_schema.rs:55

↓ 2 callersMethodacquire_segment_guard

( &self, chunk_idx: usize, segment_id: u64, )

src/server/transactions/data_site.rs:246

↓ 2 callersFunctionaggregate_row_value

( row: &'a AggregateRow, target: &AggregateOrderTarget, )

src/query/data_client/aggregate.rs:473

↓ 2 callersMethodallocation_eviction_target

(&self, hot_segments_count: usize)

src/ram/tiered/manager.rs:96

↓ 2 callersMethodappend_header

(&self)

src/ram/segs.rs:316

↓ 2 callersMethodapply_commit_ops

( &self, txn_lock: &TxnMutex, tid: &TxnId, effective_ts: &TxnId, cells

src/server/transactions/data_site.rs:508

↓ 2 callersMethodarchive_all

Archive all dirty segments to backup storage across all chunks This ensures all in-memory data is persisted to backup files before shutdown

src/ram/chunk.rs:1574

↓ 2 callersFunctionassert_shared_counter_matches_scanned_total

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

src/ram/tiered/tests.rs:135

↓ 2 callersFunctionbase_opts

()

src/server/database.rs:185

↓ 2 callersMethodbm25_search

( &self, schema_id: u32, field_id: u64, query: &str, limit: usize,

src/index/mod.rs:166

↓ 2 callersFunctionboundary_payload_lengths

(schema: &Schema, max_cell_size: u32)

src/ram/tests/blob_schema.rs:75

↓ 2 callersFunctionbuild_embedding_index_meta

Build embedding index metadata from a cell value. Extracts text content from String or String array values.

src/index/builder.rs:38

↓ 2 callersFunctionbuild_index_meta

( cell_id: Id, version: u64, schema_id: u32, field_id: u64, value: OwnedValue, )

src/index/full_text/mod.rs:153

↓ 2 callersFunctioncell_matches_selection

(cell: &OwnedCell, selection: &Expr)

src/query/data_client/read.rs:381

↓ 2 callersFunctionclause_constant_truth

(schema: &Schema, clause: &Expr)

src/query/planner/expr.rs:812

↓ 2 callersMethodclear_dirty

(&self)

src/ram/segs.rs:1107

↓ 2 callersFunctionclear_node

(mut node: NodeWriteGuard<KS, PS>, right_ref: &NodeCellRef)

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

↓ 2 callersFunctionclear_nodes

(nodes: Vec<NodeReadHandler<KS, PS>>, right_ref: &NodeCellRef)

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

↓ 2 callersFunctionclient_by_server_id_for_database

( conshash: &Arc<ConsistentHashing>, server_id: u64, group_name: &str, database_name: &str, )

src/client/mod.rs:680

↓ 2 callersFunctioncollect_embedding_metas

(indices: Vec<IndexRes>)

src/index/builder.rs:903

↓ 2 callersFunctioncollect_versions_for_hash

Helpers scoped to this test

src/ram/recovery.rs:2250

↓ 2 callersFunctioncompress_field

(data: &[u8])

src/ram/compression.rs:130

↓ 2 callersFunctioncompression_kind_for_path

( plan: Option<&SchemaCompressionPlan>, path: &[u64], )

src/ram/cell.rs:585

↓ 2 callersMethodcontains_address

(&self, addr: usize)

src/ram/segs.rs:1098

↓ 2 callersMethodcoordinator

Create the coordinator for search operations

src/client/fulltext.rs:63

↓ 2 callersMethodcreate_database

( &self, name: impl Into<String>, )

src/client/mod.rs:142

↓ 2 callersFunctioncurrent_segment_entry_content_length

( data_base: usize, segment_base: usize, data_len: usize, addr: usize, )

src/ram/recovery.rs:494

↓ 2 callersMethoddead_space

(&self)

src/ram/segs.rs:327

↓ 2 callersMethoddecrement_by

(&self, n: usize)

src/ram/tiered/mod.rs:83

↓ 2 callersMethoddecrement_hot_count

Decrement the server-wide hot-segment count by 1.

src/ram/tiered/manager.rs:638

↓ 2 callersMethoddecrement_segment_references

(&self)

src/ram/chunk.rs:1997

↓ 2 callersFunctiondefault_fields

()

src/ram/recovery.rs:1160

↓ 2 callersMethoddelete

Delete an entry from the tree

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

↓ 2 callersMethoddelete_database_storage_unchecked

Delete database storage, bypassing the default-database protection. Used when intentionally resetting the default database.

src/server/mod.rs:1112

↓ 2 callersMethodderef

(&self)

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

↓ 2 callersFunctiondetect_script

(text: &str)

src/index/full_text/tokenizer.rs:208

↓ 2 callersMethoddiscover_files

Discover all segment files in storage directories

src/ram/file_manager.rs:288

↓ 2 callersFunctiondiscover_known_databases_from_storage_roots

( storage_roots: &[Option<&str>], default_database_name: &str, )

src/server/mod.rs:104

↓ 2 callersFunctiondistinct_estimate_from_stats

(stats: &SchemaStatistics, field_id: u64)

src/query/cost/planner.rs:95

↓ 2 callersFunctiondyn_data_type_id

(value: &'a OwnedValue)

src/ram/io/writer.rs:349

↓ 2 callersMethodend

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

src/server/transactions/data_site.rs:1282

↓ 2 callersMethodensure_database

(&self)

src/client/mod.rs:159

↓ 2 callersMethodensure_txn_state

(&self, txn: &TxnGuard, state: TxnState)

src/server/transactions/manager.rs:977

↓ 2 callersFunctionestimate_hashed_eq_rows

( row_count: usize, distinct_estimate: Option<usize>, )

src/query/cost/planner.rs:20

↓ 2 callersFunctionestimate_or_marginal_rows

( estimated_rows: Option<usize>, union_rows_so_far: usize, total_rows: usize, )

src/query/planner/expr.rs:556

↓ 2 callersMethodevict_for_allocation_reconciled

Check if allocating a new segment would exceed the threshold after forcing a full global reconcile. This is intended for low-frequency background call

src/ram/tiered/manager.rs:523

↓ 2 callersFunctionevict_segment

Evict a hot segment to cold storage with cell-level locking CRITICAL SAFETY**: We must lock ALL cells in the segment during eviction to prevent concu

src/ram/tiered/eviction.rs:26

↓ 2 callersMethodexecute_clause_ids

( &self, schema: u32, clause: &IndexedClausePlan, _ordering: QueryOrdering,

src/query/data_client/execute.rs:27

↓ 2 callersFunctionexpand_special_clause

(expr: &Expr)

src/query/planner/expr.rs:1319

↓ 2 callersMethodexplain

(&self)

src/query/planner/expr.rs:184

↓ 2 callersFunctionexpr_field_id

(expr: &Expr)

src/query/data_client/read.rs:564

↓ 2 callersFunctionexpr_field_name

(expr: &Expr)

src/query/planner/expr.rs:1479

↓ 2 callersFunctionexpr_owned_value

(expr: &Expr)

src/query/planner/expr.rs:1502

↓ 2 callersFunctionexpr_owned_value

(expr: &Expr)

src/query/data_client/read.rs:571

↓ 2 callersFunctionexpr_unary_field_name

(expr: &Expr)

src/query/planner/expr.rs:1492

↓ 2 callersMethodext_id

(&self)

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

↓ 2 callersFunctionextract_shared_value

( exec: &mut Interpreter<'a>, expr: &SExpr<'a>, x: SharedValue<'a>, )

src/exec/sort/shared_value.rs:30

↓ 2 callersMethodfilter_ids_by_selection_limit

( &self, candidate_ids: &[Id], selection: &Expr, limit: Option<usize>, )

src/query/data_client/read.rs:76

↓ 2 callersFunctionfixed_queries

(dataset: &AlignDataset)

src/query/data_client/alignment_tests.rs:1712

↓ 2 callersFunctionfixed_scan_queries

(dataset: &AlignDataset)

src/query/data_client/alignment_tests.rs:1964

↓ 2 callersFunctionforce_new_segment

( chunks: &Chunks, chunk: &Chunk, filler_counter: &mut i32, pa

src/ram/recovery.rs:2286

↓ 2 callersMethodfree_memory

(&self)

src/ram/segs.rs:310

↓ 2 callersFunctiongenerate_scoped_service_id

(group: &str, database_name: &str)

src/server/transactions/manager.rs:30

↓ 2 callersFunctiongenerated_queries

(dataset: &AlignDataset)

src/query/data_client/alignment_tests.rs:1825

↓ 2 callersFunctiongenerated_scan_queries

(dataset: &AlignDataset)

src/query/data_client/alignment_tests.rs:2028

↓ 2 callersMethodget

Get a segment by key (segment ID) Returns a cloned Arc if the segment exists

src/ram/segment_list.rs:156

↓ 2 callersMethodget

(&self, id: u32)

src/ram/schema/sm.rs:53

↓ 2 callersMethodget_all_databases

(&self)

src/client/mod.rs:138

↓ 2 callersMethodget_data_site

( &self, server_id: u64, )

src/server/transactions/manager.rs:519

↓ 2 callersFunctionget_hash_id_from_value

(schema: u32, field: u64, value: &OwnedValue)

src/index/hash/mod.rs:379

↓ 2 callersFunctionget_id_partition

(data_ptr: *mut (), partitioner: &Box<dyn Partitioner>)

src/exec/query/partitioning.rs:28

↓ 2 callersMethodget_interpreter

(&mut self)

src/exec/query/env.rs:51

↓ 2 callersMethodget_node

(&self, node_id: u32)

src/exec/dag.rs:58

↓ 2 callersFunctionget_null_hash_id

(schema: u32, field: u64)

src/index/hash/mod.rs:375

↓ 2 callersFunctionget_segment_for_fault

Access a segment by chunk_id and segment_id from the global Chunks Used by signal handler to flip reference bits

src/ram/chunk.rs:100

↓ 2 callersFunctionget_sorting_partition

( data_ptr: *mut (), partitioner: &Box<dyn crate::exec::partitioner::Partitioner>, )

src/exec/sort/shared_value.rs:76

↓ 2 callersFunctionget_sorting_partitioner

Due to complexity, we are going to use hash partition on higher bits for now The information for range partition exists in statistics and histogram bu

src/exec/sort/shared_value.rs:70

↓ 2 callersMethodget_term_postings_with_version

Get postings with version information (for GC or verified search)

src/index/full_text/shard.rs:752

↓ 2 callersMethodgraceful_shutdown

(&self)

src/index/builder.rs:405

↓ 2 callersFunctionhas_recoverable_raft_state_at

(raft_path: &Path)

src/server/mod.rs:47

↓ 2 callersMethodhash

(&self, state: &mut H)

src/index/builder.rs:171

↓ 2 callersFunctionhash_index_schema

()

src/index/hash/mod.rs:332

↓ 2 callersFunctionhash_indexable_owned_value

(value: &OwnedValue)

src/ram/types.rs:70

↓ 2 callersMethodhead

(&self, id: Id)

src/client/transaction.rs:173

↓ 2 callersMethodhot_count_cached

Return the server-wide hot segment count, reconciling this chunk's contribution via per-chunk state every 10 seconds to correct drift.

src/ram/tiered/manager.rs:612

↓ 2 callersMethodincrement

(&self)

src/ram/tiered/mod.rs:75

↓ 2 callersMethodincrement_hot_count

Increment the server-wide hot-segment count.

src/ram/tiered/manager.rs:633

← previous next →501–600 of 2,177, ranked by callers