Functions — github.com/KShivendu/smoldb

CodeHub MCPcopy Create free account

hub / github.com/KShivendu/smoldb / functions

Functions308 in github.com/KShivendu/smoldb

⨍ Functions 308◇ Types & classes 113

(collection: &Collection)

src/storage/collection.rs:378

src/storage/segment/point.rs:22

(toc: Arc<TableOfContent>, consensus: Option<Arc<ConsensusManager>>)

src/api/dispatcher.rs:17

(peer_id: PeerId, collection: &Collection)

src/api/collection.rs:117

(entry: &Entry)

src/consensus/debuggables.rs:16

(inner: Arc<T>)

src/api/grpc/schema.rs:578

Methodfrom_entry

(entry: &Entry)

src/consensus/mod.rs:381

Methodfrom_grpc

(query: Option<GrpcQueryPointsParams>)

src/api/grpc/conversion.rs:6

Functiongenerate_random_points

(num_points: usize)

benches/collection/common.rs:110

Functionget_cluster

(dispatcher: web::Data<Dispatcher>)

src/api/cluster.rs:14

Functionget_collection

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

src/api/collection.rs:45

Functionget_collection_cluster_info

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

src/api/collection.rs:158

Functionget_collections

(dispatcher: web::Data<Dispatcher>)

src/api/collection.rs:23

Methodget_index_names

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

Methodget_or_create

Read from the database to get existing indices and their types. If no indices are found, create a new empty index.

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

Methodget_pending_indexing_count

Get the total count of pending points in the indexing queue across all segments

src/storage/replicas/local_shard.rs:180

Functionget_point

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

src/api/points.rs:72

Methodget_points

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

src/storage/replicas/local_shard.rs:32

Methodget_points

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

src/storage/replicas/remote_shard.rs:66

Methodget_points

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

src/api/grpc/schema.rs:497

Methodget_points

( &self, request: tonic::Request<GetPointsRequest>, )

src/api/grpc/points_service.rs:31

( id: CollectionName, config: CollectionConfig, path: &Path, channel_service:

src/storage/collection.rs:39

( path: PathBuf, id: ShardId, payload_schema: Option<BTreeMap<String, IndexConfig>>,

src/storage/replicas/local_shard.rs:92

Methodinitial_state

src/consensus/raft_storage.rs:45

Functionint_indexing

(c: &mut Criterion)

benches/collection/index.rs:14

Functionint_query

(c: &mut Criterion)

benches/collection/query.rs:12

Functionlist_points

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

src/api/points.rs:116

( id: CollectionName, path: &Path, channel_service: Arc<ChannelService>, )

src/storage/collection.rs:102

(channel_service: ChannelService)

src/storage/toc.rs:37

(path: &PathBuf)

src/storage/replicas/local_shard.rs:124

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

tools/smolbench/src/main.rs:27

Methodmax_decoding_message_size

(mut self, limit: usize)

src/api/grpc/schema.rs:193

Methodmax_encoding_message_size

(mut self, limit: usize)

src/api/grpc/schema.rs:201

Methodmkdir_collection_dir

Creates a new directory at the expected collection path.

src/storage/toc.rs:79

(peer_id: PeerId, id_to_address: Arc<RwLock<HashMap<PeerId, Uri>>>)

src/channel_service.rs:31

(key: impl Into<String>, value: impl Into<Value>, op: FilterOperator)

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

Load in-memory index from disk

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

(tree: &sled::Tree)

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

(tree: &sled::Tree)

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

( local: LocalShard, collection_id: CollectionName, shard_id: ShardId, channel

src/storage/replicas/mod.rs:49

Init a remote shard in memory that can be used to communicate with replicas on a remote peer.

src/storage/replicas/remote_shard.rs:31

(dispatcher: Arc<Dispatcher>)

src/api/grpc/raft_service.rs:21

src/api/grpc/schema.rs:147

(toc: Arc<TableOfContent>)

src/api/grpc/points_service.rs:24

Create a new ConsensusState with a given p2p URI and optional default peer ID.

src/consensus/mod.rs:81

(peer_id: PeerId)

src/consensus/raft_storage.rs:17

(state: Arc<ConsensusState>, sender: Sender<Msg>)

src/consensus/manager.rs:14

Methodnew_numeric

(db: &Db, name: &str)

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

(db: &Db, name: &str)

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

Methodnew_vector

(db: &Db, name: &str)

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

(key: u16, value: String)

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

(_db: &Db, _name: &str, _use_in_memory: bool)

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

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

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

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

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

Create a new BM25Scorer instance, loading existing stats from sled

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

Functionparse_number

tools/smolbench/src/args.rs:25

Functionparse_uri

Methodpoll_ready

( &mut self, _cx: &mut Context<'_>, )

src/api/grpc/schema.rs:634

( &self, query: &[DimType], _operation: &FilterOperator, // todo: allow specifying dis

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

Methodquery_points

(&self, query: Query)

src/storage/segment/mod.rs:192

Methodquery_points

(&self, query: Query)

src/storage/replicas/local_shard.rs:58

Methodquery_points

(&self, query: Query)

src/storage/replicas/remote_shard.rs:147

Methodquery_points

( &self, request: tonic::Request<QueryPointsRequest>, )

src/api/grpc/points_service.rs:78

Functionrandom_vector

tools/smolbench/src/apis.rs:205

(c: &mut Criterion)

benches/collection/read.rs:12

( &self, _request: Request<RootApiRequest>, )

src/api/grpc/simple_service.rs:10

Returns the title and version of the service - useful for debugging

src/api/grpc/schema.rs:206

(&self, mut request: Request<RaftMessageBytes>)

src/api/grpc/raft_service.rs:28

Methodsend_compressed

(mut self, encoding: CompressionEncoding)

src/api/grpc/schema.rs:179

Methodspawn_indexing_thread

Spawns a dedicated thread to run the indexing loop for a segment

src/storage/replicas/local_shard.rs:75

Initialize consensus and run in loop with a dedicated thread.

src/consensus/mod.rs:198

(&self, idx: u64)

src/consensus/raft_storage.rs:60

Functiontest_collection_config_save

src/storage/collection.rs:444

Functiontest_collection_init

src/storage/collection.rs:408

Functiontest_collection_load

src/storage/collection.rs:466

Functiontest_collection_write_read_points

src/storage/collection.rs:493

Functiontest_cosine_similarity_unit_simd

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

Functiontest_cosine_similarity_unit_simd_larger

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

Functiontest_cosine_similarity_unit_simd_odd_length

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

Functiontest_merge_sorted_posting_lists

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

Functiontest_parse_number

tools/smolbench/src/args.rs:111

Functiontest_payload_index

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

Functiontest_point_encode_decode

src/storage/segment/point.rs:104

Functiontest_posting_list_encoding_size

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

Functiontest_segment_insert_read_points

src/storage/segment/mod.rs:286

Functiontest_shard_routing

src/storage/replicas/mod.rs:265

Functiontest_smoldb_consecutive_writes

tools/smolbench/src/tests/mod.rs:9

Functiontest_stop_words_filtered

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

Functiontest_text_index

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

Functiontest_text_index_only_disk

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

Functiontest_tokenizer

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

Functiontext_indexing

(c: &mut Criterion)

benches/collection/index.rs:49

Functiontext_query

Perf when bench was first implemented: single=1.5804 µs, concurrent=5.7696 µs

benches/collection/text_search.rs:13

src/storage/segment/point.rs:30

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

Methodupsert_points

(&self, points: Vec<Point>)

src/storage/replicas/local_shard.rs:46

Methodupsert_points

(&self, points: Vec<Point>)

src/storage/replicas/remote_shard.rs:114

← previous next →201–300 of 308, ranked by callers