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 callersMethodaddress

(&self)

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

↓ 3 callersFunctionalign_to

(alignment: usize, value: usize)

src/ram/tests/blob_schema.rs:60

↓ 3 callersFunctionalignment_schema

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

src/query/data_client/alignment_tests.rs:644

↓ 3 callersMethodapply_in_ranged_tree

( &'a self, id: Id, entry: EntryKey, epoch: u64, _route_pending_migrat

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

↓ 3 callersMethodassert_address_aligned_for_read

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

src/ram/chunk.rs:264

↓ 3 callersFunctionawait_ranged_indices_ready

()

src/query/data_client/tests.rs:550

↓ 3 callersFunctionbm25_score

(tf: f32, doc_len: f32, avg_doc_len: f32, idf: f32)

src/index/full_text/mod.rs:224

↓ 3 callersMethodbm25_search

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

src/query/data_client.rs:659

↓ 3 callersMethodclauses

(&self)

src/query/planner/expr.rs:141

↓ 3 callersMethodcleanup_transaction

(&self, tid: &TxnId)

src/server/transactions/manager.rs:987

↓ 3 callersFunctionclient_by_rpc_client_for_database

( rpc: &Arc<RPCClient>, group_name: &str, database_name: &str, )

src/client/mod.rs:660

↓ 3 callersMethodcmp_prefix

Compare two EntryKeys by their prefix (schema + field + feature), ignoring the ID part. This is useful for range queries where we want to compare by f

src/index/entry.rs:113

↓ 3 callersFunctioncompare_values

(left: &OwnedValue, right: &OwnedValue, op: CompareOp)

src/query/data_client/read.rs:519

↓ 3 callersFunctioncomparison_clause

(clause: &Expr)

src/query/planner/expr.rs:1280

↓ 3 callersFunctioncompute_idf

(doc_count: u64, df: u64)

src/index/full_text/mod.rs:215

↓ 3 callersFunctionconjunction_expr

(clauses: &[Expr])

src/query/planner/expr.rs:1093

↓ 3 callersMethodcount

(&self)

src/ram/chunk.rs:1318

↓ 3 callersFunctioncrc32_checksum

(data: &[u8])

src/ram/compression.rs:14

↓ 3 callersFunctioncursor_trace_gap

(ids: &[Id])

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

↓ 3 callersMethoddata_sites_for_objs

( &self, changed_objs: &AffectedObjs, )

src/server/transactions/manager.rs:762

↓ 3 callersMethoddatabase

(&self, database_name: &str)

src/server/mod.rs:960

↓ 3 callersFunctiondatabase_meta_plane_seed_nodes

(server_addr: &str, seed_nodes: &[String])

src/server/mod.rs:167

↓ 3 callersFunctiondecompress_field

(compressed_data: &[u8])

src/ram/compression.rs:143

↓ 3 callersMethoddecrement_hot_count_by

Decrement the server-wide hot-segment count by `by`, saturating at zero.

src/ram/tiered/manager.rs:643

↓ 3 callersMethoddelete_wal

Delete WAL file

src/ram/file_manager.rs:194

↓ 3 callersFunctiondiscover_databases_for_startup_schema_registration

( raft_storage_root: Option<&str>, non_raft_storage_roots: &[Option<&str>], default_database_name:

src/server/mod.rs:135

↓ 3 callersFunctiondiscover_known_databases_from_raft_storage

( raft_storage_root: Option<&str>, default_database_name: &str, )

src/server/mod.rs:70

↓ 3 callersFunctionempty_segment_bytes

()

src/ram/recovery.rs:1200

↓ 3 callersMethodensured_refresh_chunk

(&self, chunk: &Chunk)

src/query/statistics/mod.rs:71

↓ 3 callersMethodevict_globally_until_target

(&self, target: usize)

src/ram/tiered/manager.rs:409

↓ 3 callersMethodextnode_mut_no_persist

(&mut self)

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

↓ 3 callersMethodfinalize

( self, group_by_fields: &[u64], specs: &[ValidatedAggregateSpec], )

src/query/data_client/aggregate.rs:234

↓ 3 callersMethodget_all

(&self)

src/ram/schema/mod.rs:696

↓ 3 callersMethodget_all_server_ids

Get all active server IDs from the consistent hash ring

src/index/full_text/coordinator.rs:53

↓ 3 callersMethodget_by_name

(&self, name: &str)

src/ram/schema/mod.rs:752

↓ 3 callersMethodget_cell_segment_info

Get segment information for a cell based on its memory address. Returns (segment_id, seq_id) for the segment containing the cell.

src/ram/chunk.rs:1232

↓ 3 callersMethodget_client

Get RPC client for a specific server

src/index/full_text/coordinator.rs:65

↓ 3 callersMethodget_data_site_by_id

( &self, id: &Id, )

src/server/transactions/manager.rs:540

↓ 3 callersMethodhead_segment_id

(&self, partition: u64)

src/index/full_text/shard.rs:193

↓ 3 callersFunctionideal_capacity_from_node_size

(size: usize)

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

↓ 3 callersMethodincrement_access_count

(&self)

src/ram/segs.rs:1079

↓ 3 callersFunctionindexed_clause_candidate

(schema: &Schema, clause: &Expr)

src/query/planner/expr.rs:1173

↓ 3 callersFunctionindexed_clause_priority

( supports_hashed: bool, supports_ranged: bool, is_equality: bool, start_open: bool, end_o

src/query/cost/planner.rs:162

↓ 3 callersMethodinnode

(&self)

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

↓ 3 callersMethodinsert

( &mut self, key: EntryKey, new_node: NodeCellRef, parent: &NodeCellRef, )

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

↓ 3 callersMethodis_active_head

(&self, seg_id: u64)

src/ram/chunk.rs:385

↓ 3 callersMethodis_dirty

(&self)

src/ram/segs.rs:1112

↓ 3 callersFunctionis_japanese_char

(c: char)

src/index/full_text/tokenizer.rs:180

↓ 3 callersFunctionis_node_serial

(node: &NodeWriteGuard<KS, PS>)

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

↓ 3 callersMethodis_pure_relevance_ranked_scan

(&self)

src/query/planner/expr.rs:179

↓ 3 callersFunctionis_stop_word

Check if a token is a stop word (checks all languages)

src/index/full_text/tokenizer.rs:254

↓ 3 callersMethoditerate

Iterate through all postings in this Chunk's posting list for this term Returns: (doc_id, version, term_freq, doc_length) chunk_index: used to identif

src/index/full_text/shard.rs:280

↓ 3 callersMethodkill

(&mut self)

tests/storage_lock_process.rs:102

↓ 3 callersFunctionlarge_string_cell

(schema_id: u32, id: Id, payload_len: usize, prefix: &str)

src/ram/tiered/tests.rs:83

↓ 3 callersMethodleft_ref

(&self)

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

↓ 3 callersMethodlocate_segment_ensured

(&self, cell_location: usize, cell_id: &Id)

src/ram/chunk.rs:1089

↓ 3 callersMethodlocate_server_id

(&self, id: &Id)

src/client/mod.rs:164

↓ 3 callersMethodlock_cell_for_write

( &self, hash: u64, has_read: bool, )

src/ram/chunk.rs:1331

↓ 3 callersFunctionmaterialize_neb_dataset

( client: &crate::client::AsyncClient, schema_id: u32, rows: &[AlignRow], )

src/query/data_client/alignment_tests.rs:655

↓ 3 callersFunctionmaterialize_sqlite_dataset

(rows: &[AlignRow])

src/query/data_client/alignment_tests.rs:677

↓ 3 callersMethodmerge_keys

Merge keys from another source (for tree splitting/migration)

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

↓ 3 callersMethodmerge_with_keys

(&self, keys: Vec<EntryKey>)

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

↓ 3 callersFunctionmigration_retry_delay_ms

(retried: i32, key: &EntryKey)

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

↓ 3 callersMethodmove_to

(mut self, key: EntryKey)

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

↓ 3 callersFunctionnew_chunks_with_schema

(schema: Schema)

src/ram/tests/field_compression.rs:13

↓ 3 callersMethodnext_raw_candidate

(&mut self)

src/index/ranged/tree/btree/cursor.rs:90

↓ 3 callersMethodno_references

(&self)

src/ram/segs.rs:777

↓ 3 callersMethodpersist_tree

(&self)

src/index/ranged/sm.rs:304

↓ 3 callersMethodpivot_key

Get pivot key for tree splitting

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

↓ 3 callersFunctionprepare_recovered_segment

( chunk: &Chunk, file_info: &SegmentFileInfo, hot: bool, segment_class: SegmentClass, )

src/ram/recovery.rs:383

↓ 3 callersMethodpromote

Promote a cold segment to hot.

src/ram/tiered/manager.rs:557

↓ 3 callersMethodquery_ids_with_options_and_hits

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

src/query/data_client.rs:491

↓ 3 callersFunctionquery_row_value

(row: &'a QueryRow, name: &str)

src/query/data_client/tests.rs:5498

↓ 3 callersMethodquery_with_options

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

src/query/data_client.rs:234

↓ 3 callersMethodread_all_cells

( &self, ids: &Vec<Id>, )

src/client/mod.rs:273

↓ 3 callersMethodread_all_cells_proced

( &self, keys: &Vec<Id>, colums: &Vec<u64>, filter: &Expr, proc: &Expr

src/server/cell_rpc.rs:170

↓ 3 callersMethodread_cell_owned

(&mut self)

src/ram/chunk.rs:1887

↓ 3 callersMethodread_selected

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

src/client/transaction.rs:114

↓ 3 callersMethodremove_at

(&mut self, ptr_pos: usize)

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

↓ 3 callersMethodremove_cell

(&self, key: Id)

src/server/cell_rpc.rs:135

↓ 3 callersMethodrender_lisp

(&self)

src/query/data_client/alignment_tests.rs:144

↓ 3 callersMethodrequeue_dirty_field_stats_keys

(&self, dirty_keys: HashMap<u64, (u32, u64)>)

src/index/full_text/shard.rs:549

↓ 3 callersMethodrollback_incomplete_transactions

Perform rollback for all incomplete transactions Must be called after segment recovery is complete Takes the txn_index built during recovery as a para

src/server/transactions/undo_log.rs:434

↓ 3 callersMethodrun_on_destinated_tree

( &'a self, key: &EntryKey, action: A, proc: P, )

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

↓ 3 callersMethodscan_by_expr_plan

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

src/query/data_client.rs:338

↓ 3 callersMethodseek

Seek to a specific key and iterate from there # Arguments `key` - Starting entry key `order` - Scan direction `buffer_size` - Number of IDs per batch

src/client/ranged.rs:185

↓ 3 callersMethodseek

( &self, id: Id, range: Range, pattern: &Option<Vec<u8>>, buffer_size:

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

↓ 3 callersFunctionsegment_id_for_cell

(chunks: &Arc<Chunks>, id: &Id)

src/ram/tiered/tests.rs:100

↓ 3 callersFunctionselect_from_chunk_raw

( ptr: usize, chunk: &Chunk, fields: &[u64], need_header: bool, )

src/ram/cell.rs:744

↓ 3 callersMethodshared_hot_segments

Return the current shared-pool hot-segment counter without performing any reconciliation.

src/ram/tiered/manager.rs:618

↓ 3 callersMethodshrink

(&self, size: usize)

src/ram/segs.rs:250

↓ 3 callersMethodskip_deleted_current

(&mut self)

src/index/ranged/tree/btree/cursor.rs:84

↓ 3 callersFunctionsort_ids_by_query_order

(ids: &mut [Id], ordering: QueryOrdering)

src/query/data_client/ids.rs:29

↓ 3 callersMethodsplit

(&mut self, src_tree: Id, new_tree: Id, pivot: EntryKey)

src/index/ranged/sm.rs:125

↓ 3 callersMethodsplit_insert

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

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

↓ 3 callersFunctionsqlite_value_to_owned_value

( row: &rusqlite::Row<'_>, index: usize, field: Option<AlignField>, )

src/query/data_client/alignment_tests.rs:1141

↓ 3 callersMethodstats

Get memory statistics.

src/ram/tiered/manager.rs:658

↓ 3 callersMethodto_cell_with_version

Convert to cell for updating an existing cell (preserves version for proper incrementing)

src/index/full_text/shard.rs:413

↓ 3 callersMethodto_key_range

(self, schema: u32, field: u64, ordering: Ordering)

src/query/planner/range.rs:25

↓ 3 callersFunctiontokenize_chinese

Tokenize Chinese text using jieba

src/index/full_text/tokenizer.rs:301

← previous next →401–500 of 2,177, ranked by callers