Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ShisoftResearch/Nebuchadnezzar
/ functions
Functions
2,177 in github.com/ShisoftResearch/Nebuchadnezzar
⨍
Functions
2,177
◇
Types & classes
366
↓ 15 callers
Method
read_cell
(&self, key: Id)
src/server/cell_rpc.rs:71
↓ 15 callers
Method
seek
(&self, key: &EntryKey, ordering: Ordering)
src/index/ranged/tree/btree/mod.rs:182
↓ 15 callers
Method
spawn
(paths: &ProbePaths, server_addr: &str, group: &str, database: &str)
tests/storage_lock_process.rs:47
↓ 15 callers
Method
write_cell
(&self, mut cell: OwnedCell)
src/server/cell_rpc.rs:128
↓ 15 callers
Function
write_cells_for_partition
( chunks: &Arc<Chunks>, schema_id: u32, partition: u64, start_idx: usize, count: usize,
src/ram/tiered/tests.rs:54
↓ 14 callers
Method
as_mut_slice
(&mut self)
src/index/entry.rs:66
↓ 14 callers
Method
database_name
(&self)
src/server/mod.rs:568
↓ 14 callers
Method
head_seg_ids_for_test
(&self)
src/ram/chunk.rs:537
↓ 14 callers
Function
make_key
(n: u64)
src/index/ranged/tree/tree.rs:395
↓ 14 callers
Method
node_ref
(&self)
src/index/ranged/tree/btree/node.rs:555
↓ 14 callers
Method
remove
( &self, tid: TxnId, id: Id, )
src/server/transactions/manager.rs:469
↓ 14 callers
Function
u64_to_feature
(n: u64)
src/index/ranged/tree/service_test.rs:8
↓ 14 callers
Method
update_stats_for_add
Update in-memory stats cache (call after add_document) Now uses lock-free PtrHashMap - no longer needs async
src/index/full_text/shard.rs:589
↓ 13 callers
Method
address_of
(&self, key: &Id)
src/ram/chunk.rs:1698
↓ 13 callers
Function
bytes_cell
(schema_id: u32, id: Id, payload_len: usize)
src/ram/tests/blob_schema.rs:18
↓ 13 callers
Method
ensure_database_runtime
( &self, database_name: &str, )
src/server/mod.rs:971
↓ 13 callers
Method
extnode_mut
(&mut self)
src/index/ranged/tree/btree/node.rs:188
↓ 13 callers
Function
init
()
src/index/ranged/tree/btree/test.rs:66
↓ 13 callers
Function
is_symbol_named
(expr: &Expr, expected: &str)
src/query/data_client/read.rs:578
↓ 13 callers
Method
locate_chunk_by_key
(&self, key: &Id)
src/ram/chunk.rs:1635
↓ 13 callers
Method
mark_migration
Mark tree as migrating
src/index/ranged/tree/tree.rs:258
↓ 13 callers
Method
next
(&mut self)
src/exec/adapter/take.rs:23
↓ 13 callers
Method
push_node
(&mut self, symbol: NebSymbol, params: Vec<Expr>)
src/exec/dag.rs:51
↓ 13 callers
Method
read_selected
( &self, hash: u64, fields: &[u64], need_header: bool, )
src/ram/chunk.rs:629
↓ 13 callers
Method
remove
(&mut self, pos: usize)
src/index/ranged/tree/btree/node.rs:78
↓ 13 callers
Method
right_ref
(&self)
src/index/ranged/tree/btree/node.rs:262
↓ 13 callers
Method
segment_class
(&self)
src/ram/segs.rs:220
↓ 13 callers
Method
update_cell
(&self, cell: &mut OwnedCell)
src/ram/chunk.rs:724
↓ 12 callers
Method
commit
(&self, tid: TxnId)
src/server/transactions/manager.rs:332
↓ 12 callers
Function
create_test_server
Helper function to create a test server
src/index/hash/mod.rs:394
↓ 12 callers
Function
generate_scoped_service_id
(group: &str, database_name: &str)
src/server/cell_rpc.rs:23
↓ 12 callers
Method
id
(&self)
src/ram/schema/sm.rs:131
↓ 12 callers
Method
innode_mut
(&mut self)
src/index/ranged/tree/btree/node.rs:176
↓ 12 callers
Method
locate_segment
(&self, addr: usize)
src/ram/chunk.rs:1024
↓ 12 callers
Method
next
(&mut self)
src/index/ranged/client/cursor.rs:151
↓ 12 callers
Method
partial_cmp
(&self, other: &EntryKey)
src/index/entry.rs:217
↓ 12 callers
Method
query
( &'a self, schema: u32, selection: Expr, ordering: QueryOrdering, pro
src/query/data_client.rs:221
↓ 12 callers
Method
remove
Remove a segment by key (segment ID) Returns the removed segment if it existed
src/ram/segment_list.rs:182
↓ 12 callers
Method
schema_by_name
(&self, name: &String)
src/client/mod.rs:508
↓ 12 callers
Method
sync_all
Sync all buffered WAL data to disk across all chunks
src/ram/chunk.rs:1562
↓ 12 callers
Function
tokenize
Tokenize text and return hashed tokens This is the main entry point for tokenization. It: 1. Applies Unicode NFC normalization 2. Auto-detects the sc
src/index/full_text/tokenizer.rs:403
↓ 12 callers
Function
total_cold_segments
(chunks: &Arc<Chunks>)
src/ram/tiered/tests.rs:113
↓ 12 callers
Method
write
( &self, tid: TxnId, cell: OwnedCell, )
src/server/transactions/manager.rs:391
↓ 12 callers
Method
write_cell_to_chunk
( &self, cell: &OwnedCell, write_plan: &WritePlan, pending_entry: &PendingEntr
src/ram/chunk.rs:653
↓ 11 callers
Method
all
(&self)
src/query/planner/expr.rs:163
↓ 11 callers
Function
database_meta_plane_id
(group_name: &str, database_name: &str)
src/server/mod.rs:154
↓ 11 callers
Function
dump_tree
(tree: &BPlusTree<KS, PS>, f: &str)
src/index/ranged/tree/btree/dump.rs:23
↓ 11 callers
Method
insert
(&self, id: Id, entry: EntryKey, epoch: u64)
src/index/ranged/tree/service.rs:301
↓ 11 callers
Method
is_ext
(&self)
src/index/ranged/tree/btree/node.rs:85
↓ 11 callers
Method
link
(&mut self, from: u32, to: u32)
src/exec/dag.rs:66
↓ 11 callers
Method
locate_chunk_by_partition
(&self, partition: u64)
src/ram/chunk.rs:1631
↓ 11 callers
Function
make_tree
()
src/index/ranged/tree/tree.rs:375
↓ 11 callers
Function
max_entry_key
()
src/index/ranged/trees.rs:96
↓ 11 callers
Method
remove_cell
(&self, hash: u64)
src/ram/chunk.rs:903
↓ 11 callers
Function
schema_validation_context
( server_group: &str, port: u16, )
src/client/tests.rs:408
↓ 11 callers
Function
setup_test_chunks
()
src/ram/tests/chunk.rs:1280
↓ 10 callers
Method
alloc_seg
(&self, file_manager: &Arc<SegmentFileManager>)
src/ram/segs.rs:1288
↓ 10 callers
Method
append
Append a posting to the segmented list in a specific Chunk The version is stored with the entry for filtering stale data and GC partition: used to gen
src/index/full_text/shard.rs:200
↓ 10 callers
Function
create_alignment_test_server
(port: u16)
src/query/data_client/alignment_tests.rs:2093
↓ 10 callers
Method
evict_for_allocation
Check if allocating a new segment would exceed the threshold and evict globally if needed. Eviction is triggered when hot memory would exceed `physic
src/ram/tiered/manager.rs:488
↓ 10 callers
Method
group_name
(&self)
src/server/mod.rs:564
↓ 10 callers
Method
id
(&self)
src/index/entry.rs:87
↓ 10 callers
Method
key
(&self)
src/index/ranged/tree/service.rs:1288
↓ 10 callers
Function
new_async_client_for_database
( address: &String, group_name: &str, database_name: &str, )
src/server/transactions/mod.rs:163
↓ 10 callers
Method
plan_write
(&self, chunk: &Chunk)
src/ram/cell.rs:156
↓ 10 callers
Method
prepare
(&self)
src/client/transaction.rs:193
↓ 10 callers
Function
read_node
( node: &NodeCellRef, mut func: F, )
src/index/ranged/tree/btree/node.rs:440
↓ 10 callers
Method
retain
Retain only keys less than pivot (for tree splitting)
src/index/ranged/tree/tree.rs:251
↓ 10 callers
Method
right_bound
(&self)
src/index/ranged/tree/btree/node.rs:275
↓ 10 callers
Method
scan_all
( &'a self, schema: u32, projection: Vec<u64>, // Column array selection: Expr
src/query/data_client.rs:194
↓ 10 callers
Method
update
(&self, cell: OwnedCell)
src/client/transaction.rs:148
↓ 10 callers
Method
wal_path
Generate WAL file path for a segment
src/ram/file_manager.rs:67
↓ 9 callers
Function
align_address
(ty_align: usize, addr: usize)
src/ram/io/mod.rs:8
↓ 9 callers
Function
create_test_meta
Helper to create test document metadata
src/index/full_text/shard.rs:1189
↓ 9 callers
Method
data
(&self)
src/ram/cell.rs:657
↓ 9 callers
Method
database_runtime
(&self)
src/server/mod.rs:1143
↓ 9 callers
Method
get_transaction
(&self, tid: &TxnId)
src/server/transactions/manager.rs:561
↓ 9 callers
Method
hashed_query
( &self, schema: u32, field_id: u64, value: &OwnedValue, )
src/query/data_client.rs:634
↓ 9 callers
Function
inverted_stats_schema
()
src/index/full_text/mod.rs:121
↓ 9 callers
Method
len
(&self)
src/index/ranged/tree/btree/node.rs:150
↓ 9 callers
Method
locate_plain_server
( &self, id: Id, )
src/client/mod.rs:189
↓ 9 callers
Method
partition
(&self, key: u64)
src/exec/partitioner/hash.rs:13
↓ 8 callers
Method
allocate
(&self, chunk: &Chunk, full_gc: bool)
src/ram/cell.rs:323
↓ 8 callers
Function
bytes_schema
(schema_id: u32, name: &str, blobs: bool)
src/ram/tests/blob_schema.rs:30
↓ 8 callers
Method
compare_version_and_update_cell
( &self, hash: u64, version: u64, cell: &mut OwnedCell, )
src/ram/chunk.rs:1339
↓ 8 callers
Function
create_mock_client
Helper to create a mock AsyncClient (dummy for tests that don't need it)
src/index/full_text/tests.rs:46
↓ 8 callers
Function
create_test_chunks
Helper to create test chunks
src/index/full_text/tests.rs:29
↓ 8 callers
Function
estimate_clause_plan_cost
( supports_hashed: bool, supports_ranged: bool, open_start: bool, open_end: bool, estimate
src/query/cost/planner.rs:116
↓ 8 callers
Method
field_by_id_path
(&self, path: &[u64])
src/ram/schema/mod.rs:173
↓ 8 callers
Function
generate_scoped_sm_id
(group: &str, database_name: &str)
src/ram/schema/sm.rs:17
↓ 8 callers
Method
get_global_stats
Get global field statistics across all partitions
src/index/full_text/coordinator.rs:306
↓ 8 callers
Method
header
(&self)
src/ram/cell.rs:654
↓ 8 callers
Function
index_query_scalars
(value: &OwnedValue)
src/ram/types.rs:62
↓ 8 callers
Function
inverted_segment_schema
()
src/index/full_text/shard.rs:43
↓ 8 callers
Method
is_empty_node
(&self)
src/index/ranged/tree/btree/node.rs:51
↓ 8 callers
Function
page_schema
()
src/index/ranged/tree/btree/external.rs:476
↓ 8 callers
Method
read_cell
(&self, id: Id)
src/client/mod.rs:203
↓ 8 callers
Function
release_cursor
(cursor: RawMemCursor)
src/ram/mem_cursor.rs:19
↓ 8 callers
Method
remove_index
(&self, cell_id: &Id, index_id: &Id)
src/index/hash/mod.rs:168
↓ 8 callers
Method
right_ref_mut
(&mut self)
src/index/ranged/tree/btree/node.rs:253
← previous
next →
101–200 of 2,177, ranked by callers