Functions — github.com/arana-db/kiwi

hub / github.com/arana-db/kiwi / functions

Functions2,670 in github.com/arana-db/kiwi

⨍ Functions 2,670◇ Types & classes 421

↓ 424 callersMethodset_reply

(&self, reply: RespData)

src/client/src/lib.rs:116

↓ 369 callersMethodencode

(&self)

src/storage/src/format.rs:79

↓ 294 callersMethodlen

(&self)

src/net/src/buffer.rs:97

↓ 262 callersMethodclone

(&self)

src/cmd/src/lib.rs:262

↓ 235 callersMethodpush

(items: Vec<RespData>)

src/resp/src/types.rs:268

↓ 214 callersMethodargv

(&self)

src/client/src/lib.rs:81

↓ 150 callersMethodlock

Acquire the lock for `key`, blocking until it becomes available.

src/kstd/src/lock_mgr.rs:53

↓ 145 callersMethodmap

(pairs: Vec<(RespData, RespData)>)

src/resp/src/types.rs:260

↓ 144 callersMethodclone

(&self)

src/raft/src/network.rs:211

↓ 129 callersMethodis_empty

(&self)

src/net/src/buffer.rs:101

↓ 124 callersMethodlen

Get the current queue size

src/common/runtime/message.rs:571

↓ 117 callersFunctionsafe_cleanup_test_db

Safe cleanup function that handles Windows file locking issues

src/storage/src/util.rs:43

↓ 113 callersMethodparse

(&mut self, data: Bytes)

src/resp/src/parse.rs:485

↓ 112 callersMethodput

(&mut self, cf_idx: ColumnFamilyIndex, key: &[u8], value: &[u8])

src/storage/src/batch.rs:195

↓ 112 callersFunctionunique_test_db_path

Utility functions and data structures for the storage engine

src/storage/src/util.rs:20

↓ 107 callersMethodget_instance_id

Calculate the instance ID from given slot ID.

src/storage/src/slot_indexer.rs:49

↓ 104 callersFunctionkey_to_slot_id

Map key to slot ID using CRC16-ARC (compatible with Redis Cluster hash slot)

src/storage/src/slot_indexer.rs:63

↓ 93 callersMethodopen

(&mut self, db_path: &str)

src/storage/src/redis.rs:177

↓ 86 callersMethodclone

(&self)

src/net/src/buffer.rs:328

↓ 85 callersMethodclone

(&self)

src/common/runtime/global_storage.rs:85

↓ 82 callersMethodset_key

(&self, key: &[u8])

src/client/src/lib.rs:106

↓ 79 callersMethodversion

(&self)

src/storage/src/format_base_value.rs:203

↓ 78 callersMethodis_stale

check if the encoded value of any type is expired (type-agnostic) This function can check the expired status without parsing the value. The etime fi

src/storage/src/redis.rs:725

↓ 75 callersMethoddelete

(&mut self, cf_idx: ColumnFamilyIndex, key: &[u8])

src/storage/src/batch.rs:202

↓ 73 callersMethodcount

(&self)

src/storage/src/format_list_meta_value.rs:244

↓ 71 callersMethodzadd

Add one or more members to a sorted set, or update its score if it already exists

src/storage/src/redis_zsets.rs:40

↓ 69 callersMethodcommit

(self: Box<Self>)

src/storage/src/batch.rs:209

↓ 65 callersMethodcreate_batch

Create a new batch for atomic write operations. This method creates a batch appropriate for the current deployment mode: - In standalone mode, return

src/storage/src/redis.rs:446

↓ 63 callersMethodkey

(&self)

src/client/src/lib.rs:111

↓ 60 callersFunctioncreate_test_redis

()

src/storage/tests/redis_zset_test.rs:29

↓ 60 callersMethodstart

Start both runtimes

src/common/runtime/manager.rs:125

↓ 56 callersMethodget_cf_handle

Get column-family handle

src/storage/src/redis.rs:412

↓ 54 callersMethodget

GET command - retrieve a value by key

src/net/src/storage_client.rs:72

↓ 54 callersMethodset

Set key to hold the string value. if key already holds a value, it is overwritten

src/storage/src/storage_impl.rs:48

↓ 53 callersMethodset_need_close

Set whether to close the database

src/storage/src/redis.rs:365

↓ 50 callersMethodsend_request

Send a storage request and wait for the response

src/common/runtime/message.rs:818

↓ 49 callersMethodget_opt

(&self, key: &[u8], readopts: &ReadOptions)

src/engine/src/rocksdb_engine.rs:53

↓ 48 callersMethodstop

Stop both runtimes gracefully

src/common/runtime/manager.rs:225

↓ 47 callersMethodcheck_type

(&self, key: &[u8], key_type: DataType)

src/storage/src/redis.rs:647

↓ 47 callersMethodget

(&self, key: &[u8])

src/storage/src/storage_impl.rs:54

↓ 47 callersMethodlrange

Returns the specified elements of the list stored at key

src/storage/src/redis_lists.rs:595

↓ 46 callersMethodis_valid

(&self)

src/storage/src/format_base_value.rs:227

↓ 45 callersMethodllen

Returns the length of the list stored at key

src/storage/src/redis_lists.rs:522

↓ 44 callersMethodsadd

Add one or more members to a set

src/storage/src/redis_sets.rs:41

↓ 43 callersMethoduser_value

When used to represent MetaValue, this function will not be called

src/storage/src/format_base_value.rs:196

↓ 42 callersMethodrpush

Insert all the specified values at the tail of the list stored at key

src/storage/src/redis_lists.rs:266

↓ 41 callersMethodwrite

(&self, data: &[u8])

src/client/src/lib.rs:71

↓ 40 callersFunctioncreate_test_db_with_cfs

Helper function to create a test database with required column families

src/raft/src/log_store_rocksdb.rs:679

↓ 39 callersMethodas_bytes

(&self)

src/resp/src/types.rs:156

↓ 39 callersMethodcf_handle

Column family operations

src/engine/src/rocksdb_engine.rs:94

↓ 39 callersMethodload

load config from file - supports Redis-style key-value format

src/conf/src/config.rs:309

↓ 34 callersFunctionencode_log_key

编码日志索引为 RocksDB 键

src/raft/src/log_store_rocksdb.rs:498

↓ 34 callersMethodput_cf

(&'a self, cf: &ColumnFamilyRef<'a>, key: &[u8], value: &[u8])

src/engine/src/rocksdb_engine.rs:111

↓ 33 callersFunctioncreate_test_redis

()

src/storage/tests/redis_list_test.rs:32

↓ 32 callersMethodencode_seek_key

(&self)

src/storage/src/format_zset_score_key.rs:88

↓ 32 callersMethodget_cf_opt

( &'a self, cf: &ColumnFamilyRef<'a>, key: &[u8], readopts: &ReadOptions,

src/engine/src/rocksdb_engine.rs:102

↓ 32 callersMethodlpush

Insert all the specified values at the head of the list stored at key

src/storage/src/redis_lists.rs:258

↓ 32 callersMethodset_etime

(&mut self, etime: u64)

src/storage/src/format_base_value.rs:111

↓ 31 callersMethodget_cf

(&'a self, cf: &ColumnFamilyRef<'a>, key: &[u8])

src/engine/src/rocksdb_engine.rs:98

↓ 31 callersMethoditerator_cf_opt

( &'a self, cf: &ColumnFamilyRef<'a>, readopts: ReadOptions, mode: IteratorMod

src/engine/src/rocksdb_engine.rs:168

↓ 31 callersMethodread

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

src/client/src/lib.rs:66

↓ 31 callersMethodwrite

( &self, request: Request<WriteRequest>, )

src/raft/src/grpc/client.rs:78

↓ 30 callersMethodappend_crlf

(&mut self)

src/resp/src/encode.rs:187

↓ 30 callersMethodencode_resp_data

(&mut self, data: &RespData)

src/resp/src/encode.rs:364

↓ 29 callersFunctioncreate_redis_instance

()

src/storage/tests/redis_basic_test.rs:166

↓ 28 callersMethodleft_index

(&self)

src/storage/src/format_list_meta_value.rs:75

↓ 27 callersMethodshutdown

(&mut self)

src/storage/src/storage.rs:214

↓ 27 callersMethodupdate

Append new mapping (with step_length_mask sampling) Only append when (log_index & step_length_mask) == 0 Note: LogIndex is i64 but expected to be no

src/storage/src/logindex/collector.rs:95

↓ 26 callersFunctionserialize

序列化数据结构为字节序列

src/raft/src/log_store_rocksdb.rs:478

↓ 26 callersMethodset_count

(&mut self, count: u64)

src/storage/src/format_list_meta_value.rs:248

↓ 26 callersMethodzscore

Get the score associated with the given member in a sorted set

src/storage/src/redis_zsets.rs:440

↓ 25 callersMethodis_empty

Check if the queue is empty

src/common/runtime/message.rs:576

↓ 24 callersMethoddo_try_get_log_entries

读取指定范围的日志条目

src/raft/src/log_store_rocksdb.rs:134

↓ 24 callersMethodmset

MSET command - multiple set operations

src/net/src/storage_client.rs:223

↓ 24 callersMethodok

Create a success status.

src/kstd/src/status.rs:39

↓ 23 callersMethodbuild

(self)

src/executor/src/builder.rs:43

↓ 23 callersMethodencoded

Get encoded bytes of the meta value

src/storage/src/format_base_meta_value.rs:234

↓ 23 callersMethodfilter

(&mut self, _level: u32, key: &[u8], _value: &[u8])

src/storage/src/data_compaction_filter.rs:199

↓ 23 callersMethodlindex

Returns the element at index in the list stored at key

src/storage/src/redis_lists.rs:542

↓ 23 callersMethodsend

(&self, task: BgTask)

src/storage/src/storage.rs:85

↓ 22 callersMethodset

(items: Vec<RespData>)

src/resp/src/types.rs:264

↓ 22 callersMethodtry_into

(self)

src/raft/src/conversion.rs:106

↓ 21 callersMethodhset

(&self, key: &[u8], field: &[u8], value: &[u8])

src/storage/src/redis_hashes.rs:279

↓ 21 callersMethodload

Get the current Storage instance. This is a cheap atomic read (~1-2ns overhead).

src/common/runtime/global_storage.rs:56

↓ 21 callersMethodzlexcount

Count the members in a sorted set within the given lexicographical range

src/storage/src/redis_zsets.rs:876

↓ 20 callersMethodclone_box

(&self)

src/cmd/src/lib.rs:299

↓ 20 callersFunctionencode_user_key

(user_key: &[u8], dst: &mut BytesMut)

src/storage/src/storage_define.rs:49

↓ 20 callersMethodttl

Get the time to live for a key in seconds

src/storage/src/redis_multi.rs:194

↓ 19 callersMethodencode

(&self)

src/storage/src/format_zset_score_key.rs:67

↓ 19 callersMethodfilter

(&mut self, _level: u32, key: &[u8], value: &[u8])

src/storage/src/meta_compaction_filter.rs:40

↓ 19 callersMethodkey

(&self)

src/storage/src/format_base_key.rs:88

↓ 18 callersMethodhealth_check

Create a health check error

src/common/runtime/error.rs:99

↓ 16 callersMethodseqno

(&self)

src/storage/src/logindex/types.rs:108

↓ 16 callersMethodset_line_string

(&mut self, value: &str)

src/resp/src/encode.rs:348

↓ 16 callersMethodzcard

Get the number of members in a sorted set

src/storage/src/redis_zsets.rs:225

↓ 15 callersMethodclear

(&mut self)

src/resp/src/encode.rs:354

↓ 15 callersMethoddelete_keys_with_prefix

Helper method to delete keys with a specific prefix

src/storage/src/redis_multi.rs:459

↓ 15 callersFunctionencode_fixed

(buf: &mut [u8], value: T)

src/storage/src/coding.rs:68

↓ 15 callersMethodinto_inner

(mut self)

src/kstd/src/lock_mgr.rs:137

↓ 15 callersFunctionparse_usize_value

(key: &str, value: &str)

src/conf/src/config.rs:285

next →1–100 of 2,670, ranked by callers