Functions — github.com/KShivendu/smoldb

hub / github.com/KShivendu/smoldb / functions

Functions308 in github.com/KShivendu/smoldb

⨍ Functions 308◇ Types & classes 113

↓ 122 callersMethodclone

(&self)

src/api/grpc/schema.rs:708

↓ 65 callersMethoditer

(&self)

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

↓ 41 callersMethodget

(&self, term: &str)

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

↓ 39 callersMethodinsert

(&self, value: i64, point_ids: Vec<u64>)

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

↓ 16 callersMethodsend

Send Raft message to this peer

src/api/grpc/schema.rs:318

↓ 13 callersFunctioncreate_tempdir

Creates a temporary directory for benchmark storage

benches/collection/common.rs:44

↓ 12 callersFunctioncreate_channel_service

Creates a default channel service

benches/collection/common.rs:49

↓ 10 callersFunctiongenerate_points

Generates points with IDs from 0 to num_points-1 and payloads of the form "Hello world {id}"

benches/collection/common.rs:81

↓ 10 callersMethodinsert

(&mut self, term: String, posting_list: Vec<PostingListItem>)

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

↓ 10 callersFunctiontime

Response wrapper for a `Future` returning `Result`.

src/api/helpers.rs:22

↓ 9 callersFunctioncreate_collection_with_points

Creates a collection and initializes it with the given points

benches/collection/common.rs:163

↓ 8 callersMethodas_str

(&self)

src/storage/segment/index/filter.rs:15

↓ 8 callersFunctionbenchmark_group

Creates a benchmark group with default configuration

benches/collection/common.rs:192

↓ 8 callersFunctioninit

( host: String, grpc_port: u16, dispatcher: Arc<Dispatcher>, )

src/api/grpc/mod.rs:64

↓ 7 callersFunctioncosine_similarity_unit_simd

SIMD-accelerated cosine similarity for unit vectors. Assumes both vectors are normalized to unit length. For unit vectors: cosine_similarity(a, b) = a

src/storage/segment/index/vector/simd.rs:9

↓ 7 callersMethodsnapshot

(&self, request_index: u64, to: u64)

src/consensus/raft_storage.rs:72

↓ 6 callersMethodadd_points

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

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

↓ 6 callersFunctioncreate_temp_db

Creates a temporary database for benchmark storage

benches/collection/common.rs:206

↓ 6 callersFunctiondecoded_point_ids

(data: &[u8])

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

↓ 6 callersMethodquery

( &self, value: &str, _operation: &FilterOperator, limit: Option<usize>, )

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

↓ 6 callersMethodquery_points

( &self, collection_name: &str, query: Query, )

src/storage/toc.rs:199

↓ 6 callersMethodread_points

( &self, collection_name: &str, ids: Option<Vec<PointId>>, )

src/storage/toc.rs:185

↓ 5 callersFunctioncreate_runtime

Creates a new multi-threaded tokio runtime for benchmarks

benches/collection/common.rs:36

↓ 5 callersMethodget_collection

( &self, collection_name: &str, )

src/storage/toc.rs:152

↓ 5 callersMethodget_points

(&self, ids: Option<Vec<PointId>>)

src/storage/segment/mod.rs:116

↓ 5 callersMethodpartial_cmp

(&self, other: &Self)

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

↓ 4 callersFunctioncreate_collection

Creates a collection with default configuration

benches/collection/common.rs:54

↓ 4 callersMethodencode

(&self)

src/storage/segment/point.rs:38

↓ 4 callersMethodentries

( &self, low: u64, high: u64, max_size: impl Into<Option<u64>>, contex

src/consensus/raft_storage.rs:49

↓ 4 callersMethodget_consensus

Get the consensus manager if it exists, otherwise return [`ConsensusError::NotEnabled`].

src/api/dispatcher.rs:22

↓ 4 callersFunctiontokenize_and_count_frequencies

(text: &str)

src/storage/segment/index/text/tokenizer.rs:161

↓ 4 callersMethodupsert_points

( &self, collection_name: &str, points: Vec<Point>, )

src/storage/toc.rs:171

↓ 3 callersMethodadd_index

( &mut self, db: &Db, name: &str, index_config: IndexConfig, )

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

↓ 3 callersFunctionadd_peer_to_toc_and_consensus_state

( consensus_state: &Arc<ConsensusState>, toc: &Arc<TableOfContent>, peer_id: PeerId, uri: Uri,

src/consensus/utils.rs:7

↓ 3 callersMethodapply_snapshot

(&self, snapshot: Snapshot)

src/consensus/raft_storage.rs:22

↓ 3 callersFunctioncreate_collection

Strongly recommend to use `wait=true`

tools/smolbench/src/apis.rs:62

↓ 3 callersMethoddoc_length

(&self, doc_id: u64)

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

↓ 3 callersFunctionencoded_integer_value

Converts the number into a big-endian value which is suitable for querying/storing in sled This allows lexicographical ordering and hence numeric comp

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

↓ 3 callersFunctionencoded_point_ids

(point_ids: &[u64])

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

↓ 3 callersMethodexecute_cluster_operation

Executes the operation on the local shard and then on all the remote shards. If `local_only` is true, it only executes on the local shard.

src/storage/replicas/mod.rs:98

↓ 3 callersFunctionexists_collection

(url: &Uri, collection_name: &str)

tools/smolbench/src/apis.rs:142

↓ 3 callersMethodget_pending_indexing_count

( &self, shard_holder: Option<&RwLockReadGuard<'_, ReplicaHolder>>, )

src/storage/collection.rs:320

↓ 3 callersMethodgroup_by_shards

Find shards that are expected to hold the points based on the hash ring. If returned `point_ids` is `None`, it means the caller should read/write all

src/storage/replicas/mod.rs:226

↓ 3 callersMethodinsert

(&mut self, point_id: u64, vector: Vec<DimType>)

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

↓ 3 callersMethodinto_bytes

(&self)

src/consensus/mod.rs:376

↓ 3 callersFunctionlog_latencies

( batch_responses: &[ApiSuccessResponse<T>], p9: usize, for_what: &str, )

tools/smolbench/src/utils.rs:3

↓ 3 callersMethodquery

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

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

↓ 3 callersMethodrecompute_avg_dl

(&mut self)

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

↓ 3 callersMethodsave

(&self, collection_dir: &Path)

src/storage/collection.rs:345

↓ 3 callersMethodsend_messages

Sends Raft messages via p2p gRPC APIs to other peers

src/consensus/broker.rs:19

↓ 3 callersMethodwith_points_client

( &self, f: impl Fn(PointsInternalClient<Channel>) -> O, )

src/storage/replicas/remote_shard.rs:46

↓ 2 callersMethodadd_point

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

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

↓ 2 callersMethodadd_remote_replicas

ToDo: Should only add a remote replica, but only for one shard at a time

src/storage/collection.rs:78

↓ 2 callersMethodcmp

(&self, other: &Self)

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

↓ 2 callersFunctiondecode_vector

(data: &[u8])

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

↓ 2 callersMethoddelete

(&self)

src/storage/collection.rs:87

↓ 2 callersMethodencode_payload

(&self)

src/storage/segment/point.rs:79

↓ 2 callersFunctionexample_config

()

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

↓ 2 callersFunctiongenerate_int_queries

Generate queries for integer index

benches/collection/common.rs:125

↓ 2 callersFunctiongenerate_points_with_vector

Generates points with IDs from 0 to num_points-1 and payloads of the form "Hello world {id}", price, and vector of dimension 4

benches/collection/common.rs:94

↓ 2 callersFunctiongenerate_text_queries

Generate queries for text index

benches/collection/common.rs:135

↓ 2 callersFunctiongenerate_vector_queries

Generate queries for vector index

benches/collection/common.rs:149

↓ 2 callersFunctionget_collection

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

tools/smolbench/src/apis.rs:126

↓ 2 callersMethodget_point_ids

(&self, value: i64)

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

↓ 2 callersMethodget_replica_set

(&self, shard_id: ShardId)

src/storage/replicas/mod.rs:176

↓ 2 callersMethodhandle_committed_entries

ToDo: This function should actually apply the committed entries to the state machine. However it currently pushes forwards ones to other peers via gR

src/consensus/ready_processor.rs:84

↓ 2 callersMethodinsert_points

Insert a batch of points into the segment

src/storage/segment/mod.rs:84

↓ 2 callersFunctionis_initial_msg

The message can be used to initialize a raft node or not.

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

↓ 2 callersMethodlast_index

(&self)

src/consensus/raft_storage.rs:68

↓ 2 callersMethodload

(path: &PathBuf)

src/storage/segment/mod.rs:64

↓ 2 callersFunctionmake_default_grpc_channel

(uri: Uri)

src/api/grpc/mod.rs:54

↓ 2 callersFunctionmake_grpc_channel

( timeout: Duration, connection_timeout: Duration, uri: Uri, )

src/api/grpc/mod.rs:42

↓ 2 callersFunctionmerge_sorted_posting_lists

Merge two sorted posting lists, preferring items from `new` when doc_ids collide

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

↓ 2 callersMethodnew

(child: std::process::Child)

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

↓ 2 callersMethodperform_collection_op

( &self, operation: CollectionOperation, )

src/storage/toc.rs:98

↓ 2 callersMethodpersist

Persist stats to sled

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

↓ 2 callersMethodread_points

( &self, ids: Option<Vec<PointId>>, shard_id: Option<ShardId>, local_only: boo

src/storage/collection.rs:241

↓ 2 callersMethodset_conf_state

(&self, conf_state: raft::eraftpb::ConfState)

src/consensus/raft_storage.rs:39

↓ 2 callersMethodset_hardstate

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

src/consensus/raft_storage.rs:31

↓ 2 callersMethodstep

Step a raft message, initialize the raft if need.

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

↓ 2 callersMethodsubmit_collection_op

( &self, operation: CollectionOperation, )

src/api/dispatcher.rs:34

↓ 2 callersFunctiontokenize

Tokenize the text into terms, filtering out stop words

src/storage/segment/index/text/tokenizer.rs:152

↓ 2 callersFunctionupsert_points

( url: &Uri, collection_name: &str, num_points: usize, batch_size: usize, delay: Option<us

tools/smolbench/src/apis.rs:210

↓ 2 callersFunctionwait_consensus_ready

(url: &Uri)

tools/smolbench/src/apis.rs:13

↓ 1 callersFunctionadd_all_followers

Proposes some conf change for peers [2, 5].

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

↓ 1 callersMethodadd_document

Add or update a single document's stats

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

↓ 1 callersMethodadd_documents

Add or update multiple documents' stats in batch

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

↓ 1 callersMethodadd_peer

Adds a peer to ToC and Consensus. local consensus state, updates remote shards, and notifies the Raft consensus loop. Not cancel safe

src/api/dispatcher.rs:62

↓ 1 callersMethodadd_peer

( &self, peer_id: PeerId, uri: Uri, )

src/consensus/mod.rs:102

↓ 1 callersMethodadd_peer_to_known

Send to bootstrap peer Proposes to add this peer as participant of consensus Returns all peers

src/api/grpc/schema.rs:359

↓ 1 callersMethodadd_point

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

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

↓ 1 callersMethodadd_point

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

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

↓ 1 callersMethodadd_points

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

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

↓ 1 callersMethodadd_points

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

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

↓ 1 callersMethodadd_remote

Add a remote shard to the replica set

src/storage/replicas/mod.rs:69

↓ 1 callersMethodappend_entries

Append entries to the Raft log.

src/consensus/raft_storage.rs:27

↓ 1 callersFunctionavx_dot_product_f64

(v1: &[DimType], v2: &[DimType])

src/storage/segment/index/vector/simd.rs:35

↓ 1 callersMethodbootstrap

Bootstrap the consensus from existing node (leader)

src/consensus/mod.rs:143

↓ 1 callersFunctionbuild_proto_files

()

build.rs:3

↓ 1 callersMethodcalculate_idf

(&self, df: usize)

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

next →1–100 of 308, ranked by callers