Functions — github.com/cosdata/cosdata

hub / github.com/cosdata/cosdata / functions

Functions1,701 in github.com/cosdata/cosdata

⨍ Functions 1,701◇ Types & classes 375↳ Endpoints 1

↓ 302 callersMethodclone

(&self)

src/models/versioned_vec.rs:95

↓ 255 callersMethoditer

( &self, )

src/models/lru_cache.rs:334

↓ 218 callersMethodpush

(&self, version: VersionNumber, quotient: u64, value: T)

src/models/tree_map.rs:350

↓ 215 callersMethodlen

(&self)

src/models/atomic_array.rs:57

↓ 206 callersMethodread

(&self)

src/models/wal.rs:265

↓ 197 callersMethodget

(&self, quotient: u64)

src/models/tree_map.rs:363

↓ 172 callersMethodseek_with_cursor

(&self, cursor_id: u64, pos: u64)

src/models/buffered_io.rs:418

↓ 168 callersMethodappend

(&self, op: VectorOp)

src/models/wal.rs:173

↓ 161 callersMethodinsert

(&self, k: K, v: V)

src/models/common.rs:520

↓ 157 callersMethodload

Loads collections map from lmdb

src/models/types.rs:581

↓ 121 callersMethodopen_cursor

(&self)

src/models/buffered_io.rs:169

↓ 111 callersMethodclose_cursor

@DOUBT: The caller will need to remember to call close_cursor, other wise the cursors will keep accumulating. One way to prevent that can be to implem

src/models/buffered_io.rs:183

↓ 110 callersMethodread_u32_with_cursor

(&self, cursor_id: u64)

src/models/buffered_io.rs:227

↓ 103 callersMethodupdate_u32_with_cursor

(&self, cursor_id: u64, value: u32)

src/models/buffered_io.rs:302

↓ 96 callersFunctionws

(inner: F)

org/src/cosql.rs:28

↓ 86 callersFunctionws

(inner: F)

src/cosql/common.rs:15

↓ 44 callersMethodget_collection

Returns the `Collection` by collection's name If not found, None is returned Note that it tried to look up the Collections in the DashMap only and d

src/models/types.rs:1358

↓ 34 callersFunctionwrite_len

Encode `len` into 1–3 bytes: - 1 byte if < 2⁷ - 2 bytes if < 2¹⁴ - 3 bytes otherwise (uses all 8 bits of the final byte, giving 22 bits total)

src/models/wal.rs:42

↓ 33 callersMethodtry_get_data

(&self, cache: &HNSWIndexCache)

src/models/lazy_item.rs:118

↓ 30 callersMethodserialize

( &self, dim_bufman: &BufferManager, data_bufmans: &BufferManagerFactory<VersionNumber

src/models/serializer/tree_map/node.rs:17

↓ 27 callersMethod_get_headers

(self)

tests/rps-test.py:379

↓ 27 callersMethodadd_version

(&mut self, version: u32, data: bool)

org/src/version_tree.rs:97

↓ 27 callersMethodwrite_with_cursor

( &self, cursor_id: u64, buf: &[u8], append: bool, )

src/models/buffered_io.rs:321

↓ 26 callersMethodwrite_to_end_of_file

(&self, cursor_id: u64, buf: &[u8])

src/models/buffered_io.rs:406

↓ 25 callersMethodremove

(&self, idx: u8)

src/models/lru_cache.rs:84

↓ 23 callersMethodflush

(self, root_path: &Path, version: VersionNumber)

src/models/wal.rs:154

↓ 23 callersMethodread_with_cursor

(&self, cursor_id: u64, buf: &mut [u8])

src/models/buffered_io.rs:253

↓ 23 callersMethodupdate_with_cursor

(&self, cursor_id: u64, buf: &[u8])

src/models/buffered_io.rs:317

↓ 22 callersMethodadd

(&mut self, id: u64)

org/src/cuckoo_filter_tree.rs:35

↓ 21 callersMethodread_u8_with_cursor

(&self, cursor_id: u64)

src/models/buffered_io.rs:239

↓ 21 callersMethodserialize

( &self, dim_bufman: &BufferManager, data_bufmans: &BufferManagerFactory<VersionNumber

src/models/serializer/tf_idf/term.rs:15

↓ 20 callersMethoddelete

(&self, k: &K)

src/models/common.rs:526

↓ 20 callersMethodinsert

( &self, id: InternalId, pairs: Vec<SparsePair>, version: VersionNumber, )

src/indexes/usv.rs:71

↓ 20 callersMethodis_empty

(&self)

src/models/atomic_array.rs:87

↓ 20 callersMethodmax

(metric: DistanceMetric)

src/models/types.rs:451

↓ 18 callersMethodcursor_position

(&self, cursor_id: u64)

src/models/buffered_io.rs:245

↓ 17 callersMethodread_u16_with_cursor

(&self, cursor_id: u64)

src/models/buffered_io.rs:233

↓ 17 callersFunctionwrite_len

Encode `len` into 1–3 bytes: - 1 byte if < 2⁷ - 2 bytes if < 2¹⁴ - 3 bytes otherwise (uses all 8 bits of the final byte, giving 22 bits total)

src/models/serializer/mod.rs:26

↓ 16 callersMethodget_id

(&self)

src/models/prob_node.rs:199

↓ 16 callersMethodmin

(metric: DistanceMetric)

src/models/types.rs:438

↓ 16 callersMethodok

(self, name)

tests/test-key-value-store.py:102

↓ 15 callersMethodserialize

( &self, dim_bufman: &BufferManager, data_bufmans: &BufferManagerFactory<VersionNumber

src/models/serializer/inverted/data.rs:15

↓ 15 callersFunctionsetup_test

()

src/models/serializer/tree_map/tests.rs:20

↓ 15 callersMethodupdate_collection_for_query

(&self, name: &str)

src/app_context.rs:57

↓ 14 callersFunctioncreate_tmp_file

Test util function to create a temp file of size calculated from `num_regions` and `extra` bytes after that. E.g. `create_tmp_file(5, 20)` will creat

src/models/buffered_io.rs:860

↓ 14 callersMethodget_path

creates a path out of the collection name

src/models/collection.rs:330

↓ 14 callersMethodread_f32_with_cursor

(&self, cursor_id: u64)

src/models/buffered_io.rs:203

↓ 14 callersMethodto_list

(&self)

src/models/common.rs:692

↓ 13 callersFunctioncalculate_path

Calculates the path from `current_dim_index` to `target_dim_index`. Decomposes the difference into powers of 4 and returns the indices.

src/models/utils.rs:13

↓ 13 callersMethodsearch

( &self, collection: &Collection, query: Self::SearchInput, options: &Self::Se

src/indexes/mod.rs:250

↓ 13 callersMethodupdate_u64_with_cursor

(&self, cursor_id: u64, value: u64)

src/models/buffered_io.rs:297

↓ 12 callersMethodcontains

(&self, id: u64)

org/src/cuckoo_filter_tree.rs:39

↓ 12 callersMethodfail

(self, name, expected, actual)

tests/test-key-value-store.py:106

↓ 12 callersMethodflush_all

(&self)

src/models/buffered_io.rs:131

↓ 12 callersFunctiongenerate_headers

()

tests/load-test.py:25

↓ 12 callersMethodhash_key

(&self, k: &K)

src/models/common.rs:514

↓ 12 callersFunctionlookup

(name, key)

tests/test-key-value-store.py:80

↓ 12 callersMethodpop

(&mut self)

src/models/sparse_ann_query.rs:342

↓ 12 callersMethodupdate_u8_with_cursor

(&self, cursor_id: u64, value: u8)

src/models/buffered_io.rs:312

↓ 12 callersMethodvalues

(&self)

src/models/lru_cache.rs:340

↓ 11 callersFunctioncosine_similarity

(v1: &Vector, v2: &Vector)

org/src/cluster_hierarchy.rs:327

↓ 11 callersFunctionfile_offset

(region: usize, region_offset: usize)

src/models/buffered_io.rs:876

↓ 11 callersFunctiongenerate_headers

()

tests/rps-test.py:26

↓ 11 callersMethodget_hnsw_index

(&self)

src/models/collection.rs:375

↓ 11 callersMethodget_latest

(&self, quotient: u64)

src/models/tree_map.rs:318

↓ 10 callersMethodget

(&self, key: K)

src/models/buffered_io.rs:112

↓ 10 callersMethodget_inverted_index

(&self)

src/models/collection.rs:379

↓ 10 callersFunctionis_filter_json

Creates the JSON dictionary for a Filter::Is variant.

tests/test_metadata_filters.py:222

↓ 10 callersMethodis_indexing

(&self)

src/models/collection.rs:312

↓ 10 callersMethodpeek

(&self)

src/models/sparse_ann_query.rs:346

↓ 10 callersMethodpre_commit_transaction

( &self, collection: &Collection, version: VersionNumber, config: &Config,

src/indexes/mod.rs:143

↓ 10 callersFunctionupsert

(name, txn_id, key: str, value: str)

tests/test-key-value-store.py:65

↓ 9 callersFunctionapi_info

()

src/api/openapi.rs:3

↓ 9 callersFunctioncount_ones_simd_avx2_256i

(input: __m256i)

src/models/dot_product/x86_64.rs:190

↓ 9 callersMethodget_or_create_region

(&self, position: u64)

src/models/buffered_io.rs:189

↓ 9 callersMethodget_tf_idf_index

(&self)

src/models/collection.rs:383

↓ 9 callersFunctionmake_predicate_json

Creates the JSON dictionary for a Predicate.

tests/test_metadata_filters.py:213

↓ 9 callersMethodquantize

(&self, value: f32, values_upper_bound: f32)

src/models/usv_index.rs:241

↓ 9 callersMethodread_u64_with_cursor

(&self, cursor_id: u64)

src/models/buffered_io.rs:221

↓ 9 callersFunctionrun_in_txn

Helper to run operations in a transaction with auto-commit/abort

tests/test-key-value-store.py:125

↓ 9 callersMethodupdate_collection_for_transaction

(&self, name: &str)

src/app_context.rs:53

↓ 9 callersMethodwith_value

(&self, k: &K, f: F)

src/models/common.rs:647

↓ 8 callersFunctioncreate_tmp_file_of_size

Test util function to create a temp file of a specific size

src/models/buffered_io.rs:870

↓ 8 callersMethodembed

(self, texts: List[str], max_retries: int = 3)

tests/modal_remote_vllm/remote_cache_dense.py:212

↓ 8 callersFunctiongenerate_headers

()

tests/test_metadata_filters.py:54

↓ 8 callersMethodget_or_create

(&self, k: K, f: F)

src/models/common.rs:555

↓ 8 callersFunctionget_tokenizer

Get tokenizer instance, loading it lazily.

tests/modal_remote_vllm/remote_cache_dense.py:49

↓ 8 callersMethodinsert

Inserts an entry into the cache Note that if the entry is already present in cache, it will be overwritten

src/models/lru_cache.rs:226

↓ 8 callersFunctionrandom_string

(len: usize)

src/models/durable_wal.rs:179

↓ 8 callersFunctionrandom_string

(len: usize)

src/models/wal.rs:393

↓ 8 callersFunctionsetup_test

()

src/models/serializer/tf_idf/tests.rs:31

↓ 7 callersMethodcmp

(&self, other: &Self)

src/models/types.rs:405

↓ 7 callersFunctiondelete

Route: `/vectordb/{database_name}/transactions/{transaction_id}/delete`

src/api/vectordb/transactions/delete.rs:5

↓ 7 callersMethodfind_or_create_node

(&self, path: &[u8])

src/models/tree_map.rs:296

↓ 7 callersMethodget_child

(&self)

src/models/prob_node.rs:191

↓ 7 callersFunctionget_collections_path

()

src/models/types.rs:1594

↓ 7 callersMethodget_raw_emb_by_internal_id

Returns the raw embedding mapped to an internal id It's recommended to call this method instead of directly accessing the 'internal_to_external' fiel

src/models/collection.rs:405

↓ 7 callersMethodindex_embeddings

( &self, embeddings: Vec<RawVectorEmbedding>, version: VersionNumber, config:

src/models/collection.rs:476

↓ 7 callersMethodkey

(&self)

src/models/tree_map.rs:27

↓ 7 callersMethodkey

(&self)

src/models/types.rs:280

next →1–100 of 1,701, ranked by callers