Functions — github.com/KShivendu/smoldb

hub / github.com/KShivendu/smoldb / functions

Functions308 in github.com/KShivendu/smoldb

⨍ Functions 308◇ Types & classes 113

↓ 1 callersMethodcalculate_tf_component

(&self, tf: u64, doc_id: u64, avg_dl: f64)

src/storage/segment/index/text/bm25.rs:146

↓ 1 callersFunctioncheck_signals

Check if the receiver has received a terminate signal or disconnected.

tools/raft-playground/src/main.rs:194

↓ 1 callersMethodconnect

Attempt to create a new client by connecting to a given endpoint.

src/api/grpc/schema.rs:131

↓ 1 callersMethodcount_points

(&self)

src/storage/segment/mod.rs:201

↓ 1 callersMethodcreate

( segments_dir: &Path, payload_schema: BTreeMap<String, IndexConfig>, )

src/storage/segment/mod.rs:35

↓ 1 callersFunctiondecoded_integer_value

Reverse of `encoded_integer_value`

src/storage/segment/index/payload_index.rs:27

↓ 1 callersFunctiondelete_collection

Strongly recommend to use `wait=true`

tools/smolbench/src/apis.rs:160

↓ 1 callersFunctionencode_vector

(vector: &[DimType])

src/storage/segment/index/vector/mod.rs:169

↓ 1 callersFunctiongenerate_integer_values

Generates integer values for indexing benchmarks

benches/collection/common.rs:213

↓ 1 callersFunctiongenerate_text_values

Generates text values for indexing benchmarks

benches/collection/common.rs:220

↓ 1 callersFunctiongenerate_vector_values

Generates vector values for indexing benchmarks

benches/collection/common.rs:227

↓ 1 callersFunctionget_cluster_info

(url: &Uri)

tools/smolbench/src/apis.rs:51

↓ 1 callersMethodget_cluster_info

(&self)

src/consensus/manager.rs:26

↓ 1 callersMethodget_or_create_channel

(&self, uri: Uri)

src/channel_service.rs:46

↓ 1 callersMethodget_other_peer_ids

(&self)

src/channel_service.rs:61

↓ 1 callersMethodget_peer_id

(&self)

src/storage/replicas/mod.rs:64

↓ 1 callersMethodget_peer_id

(&self)

src/api/dispatcher.rs:30

↓ 1 callersMethodget_peer_id

(&self)

src/consensus/mod.rs:65

↓ 1 callersMethodget_peer_uri

(&self, peer_id: PeerId)

src/consensus/mod.rs:120

↓ 1 callersFunctionget_raft_client

(uri: Uri)

src/consensus/broker.rs:12

↓ 1 callersFunctionget_smoldb_exec

()

tools/smolbench/src/tests/utils.rs:8

↓ 1 callersMethodget_uri

(&self, peer_id: PeerId)

src/channel_service.rs:39

↓ 1 callersMethodhandle_conf_change

(&mut self, entry: Entry)

src/consensus/ready_processor.rs:180

↓ 1 callersMethodhandle_conf_change_v2

(&self, _entry: Entry)

src/consensus/ready_processor.rs:190

↓ 1 callersMethodhandle_hard_state_change

(&self, new_hard_state: &raft::eraftpb::HardState)

src/consensus/ready_processor.rs:119

↓ 1 callersMethodhandle_hard_state_commit_change

(&self, commit: u64)

src/consensus/ready_processor.rs:136

↓ 1 callersMethodhandle_normal

(&self, entry: Entry)

src/consensus/ready_processor.rs:150

↓ 1 callersMethodhandle_soft_state_change

Handle soft state change.

src/consensus/ready_processor.rs:104

↓ 1 callersMethodindexing_queue_length

Get the current indexing queue length

src/storage/segment/mod.rs:206

↓ 1 callersMethodinitialize_raft_from_message

Initialize raft for followers.

tools/raft-playground/src/main.rs:255

↓ 1 callersMethodinsert_batch

(&self, points: &[Point])

src/storage/segment/index/payload_index.rs:251

↓ 1 callersMethodinto_grpc

(self)

src/api/grpc/conversion.rs:25

↓ 1 callersMethodis_ready

(&self)

src/consensus/manager.rs:18

↓ 1 callersMethodlog

(&self, prefix: &str)

src/consensus/debuggables.rs:53

↓ 1 callersMethodnum_docs

(&self)

src/storage/segment/index/text/bm25.rs:154

↓ 1 callersMethodnum_replicas

(&self)

src/storage/replicas/mod.rs:92

↓ 1 callersFunctionon_ready

( node_idx: usize, raft_group: &mut RawNode<MemStorage>, kv_pairs: &mut HashMap<u16, String>,

tools/raft-playground/src/main.rs:280

↓ 1 callersMethodon_ready

Tries to process raft's ready state. Should be called on each tick. [`raft::Ready`] is the outstanding work that the application needs to handle. [`

src/consensus/ready_processor.rs:20

↓ 1 callersMethodopen

(db: &Db, name: &str, use_in_memory: bool)

src/storage/segment/index/integer.rs:24

↓ 1 callersFunctionparse_args

()

tools/smolbench/src/args.rs:102

↓ 1 callersFunctionparse_args

()

src/args.rs:29

↓ 1 callersFunctionparse_number_impl

(n: &str)

tools/smolbench/src/args.rs:4

↓ 1 callersMethodpoint_id

(&self)

src/storage/replicas/mod.rs:137

↓ 1 callersFunctionpropose

(raft_group: &mut RawNode<MemStorage>, proposal: &mut Proposal)

tools/raft-playground/src/main.rs:467

↓ 1 callersMethodpropose_consensus_op

( &self, operation: ConsensusOperation, )

src/consensus/manager.rs:30

↓ 1 callersMethodquery

( &self, value: i64, operation: &FilterOperator, limit: Option<usize>, )

src/storage/segment/index/integer.rs:80

↓ 1 callersFunctionquery_points

( url: &Uri, collection_name: &str, payload: Value, )

tools/smolbench/src/apis.rs:325

↓ 1 callersFunctionquery_points

( collection_name: web::Path<String>, dispatcher: web::Data<Dispatcher>, query: Json<Query>, )

src/api/points.rs:155

↓ 1 callersMethodquery_points

( &self, query: Query, local_only: bool, )

src/storage/collection.rs:284

↓ 1 callersMethodquery_points

( &mut self, request: impl tonic::IntoRequest<super::QueryPointsRequest>, )

src/api/grpc/schema.rs:521

↓ 1 callersMethodqueue_for_indexing

Send some points to be indexed to the indexing queue It takes a lock, so it's better to call it for a batch of points at once

src/storage/segment/mod.rs:107

↓ 1 callersFunctionrandom_vector

Generate random vector

benches/collection/common.rs:76

↓ 1 callersFunctionread_point

Read points by their IDs

tools/smolbench/src/apis.rs:276

↓ 1 callersFunctionread_points

Scroll through all points in a collection by pagination? ToDo: Implement pagination logic in smoldb APIs

tools/smolbench/src/apis.rs:305

↓ 1 callersFunctionroot_api

()

src/api/service.rs:20

↓ 1 callersMethodrun_indexing_loop

Runs the background indexing loop, batching points efficiently.

src/storage/segment/mod.rs:219

↓ 1 callersMethodrun_loop

Run the consensus loop at each tick. Process is as follows: 1. Wait for messages from the local receiver channel 2. If a message is received, pass it

src/consensus/mod.rs:286

↓ 1 callersMethodscore_documents

Calculate BM25 scores for documents matching the given posting lists

src/storage/segment/index/text/bm25.rs:85

↓ 1 callersMethodset_hardstate_commit

(&self, commit: u64)

src/consensus/raft_storage.rs:35

↓ 1 callersMethodset_replica_state

Proposes an operation to set replica state provided the it matches the existing state.

src/storage/replicas/mod.rs:186

↓ 1 callersFunctionsetup_logging

()

src/main.rs:19

↓ 1 callersMethodshutdown

Signals the indexing loop to shutdown

src/storage/segment/mod.rs:214

↓ 1 callersFunctionstart_http_server

// Function to start the Actix Web server

src/api/mod.rs:72

↓ 1 callersFunctionstart_p2p_server

// Function to start the Tonic internal (p2p) gRPC server

src/api/mod.rs:106

↓ 1 callersFunctionstart_smoldb

( peer_dir: &Path, log_file: &str, peer_id: u64, port: u32, p2p_port: u32, bootstrap:

tools/smolbench/src/tests/utils.rs:42

↓ 1 callersFunctiontop_k_by_score

Efficiently get top-k documents by score using a min-heap

src/storage/segment/index/text/mod.rs:248

↓ 1 callersMethodupsert

ToDo: Support updating existing points in the index. This would require removing old values and adding new ones. ToDo: Decoupling indexing from upsert

src/storage/segment/index/payload_index.rs:238

↓ 1 callersMethodupsert

todo: Upserting should also remove the point id from the index? these should be decoupled from upsert so we can batch them

src/storage/segment/index/integer.rs:40

↓ 1 callersMethodupsert_batch

(&self, point_ids: &[u64], values: &[i64])

src/storage/segment/index/integer.rs:147

↓ 1 callersFunctionupsert_points

( collection_name: web::Path<String>, operation: Json<UpsertPoints>, dispatcher: web::Data<Dispatc

src/api/points.rs:34

↓ 1 callersMethodupsert_points

Upserts points into the collection. This is not cancel safe at the moment.

src/storage/collection.rs:160

↓ 1 callersMethodupsert_points

( &mut self, request: impl tonic::IntoRequest<super::UpsertPointsRequest>, )

src/api/grpc/schema.rs:473

↓ 1 callersFunctionwait_for_indexing

Wait for indexing to complete by polling the collection info API and checking that pending_indexing_count reaches 0

tools/smolbench/src/apis.rs:348

↓ 1 callersFunctionwait_peer_start

(uri: &str)

tools/smolbench/src/tests/utils.rs:14

↓ 1 callersFunctionwait_stop_signal

(for_what: &str)

src/api/grpc/mod.rs:30

Methodaccept_compressed

(mut self, encoding: CompressionEncoding)

src/api/grpc/schema.rs:185

Methodadd_peer_to_known

Cancel safety??

src/api/grpc/raft_service.rs:64

Methodadd_point

(&self, point_id: u64, value: &Value)

src/storage/segment/index/integer.rs:120

Methodadd_points

(&self, point_ids: &[u64], values: &[Value])

src/storage/segment/index/vector/mod.rs:74

Methodcall

(&mut self, req: http::Request<B>)

src/api/grpc/schema.rs:640

Methodconf_change

(cc: &ConfChange)

tools/raft-playground/src/main.rs:442

Methodcount_points

(&self)

src/storage/replicas/local_shard.rs:171

Functioncreate_collection

( collection_name: web::Path<String>, config: Json<CollectionConfig>, dispatcher: web::Data<Dispat

src/api/collection.rs:190

Methodcreate_raft_follower

Create a raft follower.

tools/raft-playground/src/main.rs:242

Methodcreate_raft_leader

Create a raft leader only with itself in its configuration.

tools/raft-playground/src/main.rs:214

Methoddecode

(data: &[u8])

src/storage/segment/point.rs:59

Methoddecode_list

(data: &[u8])

src/storage/segment/index/text/posting.rs:55

Methoddecode_payload

(data: &[u8])

src/storage/segment/point.rs:84

Methoddefault

()

src/storage/segment/index/text/bm25.rs:166

Functiondefault_avg_dl

()

src/storage/segment/index/text/bm25.rs:120

Functiondelete_collection

( collection_name: web::Path<String>, dispatcher: web::Data<Dispatcher>, )

src/api/collection.rs:76

Functiondistance_bench

(c: &mut Criterion)

benches/distance.rs:5

Methoddrop

(&mut self)

tools/smolbench/src/tests/utils.rs:35

Methoddrop

(&mut self)

src/storage/replicas/local_shard.rs:189

Methoddummy

()

src/storage/replicas/mod.rs:169

Methodempty

(peer_id: PeerId)

src/channel_service.rs:23

Methodencode_list

(posting_list: &[Self])

src/storage/segment/index/text/posting.rs:50

Methodfirst_index

(&self)

src/consensus/raft_storage.rs:64

Methodfrom

(entry: &Entry)

tools/raft-playground/src/main.rs:34

Methodfrom

(status: tonic::Status)

src/error.rs:45

← previous next →101–200 of 308, ranked by callers