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

↓ 14 callersMethodappend

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

src/storage/src/storage_impl.rs:194

↓ 14 callersMethoddata_type

(&self)

src/storage/src/redis.rs:84

↓ 14 callersMethodetime

(&self)

src/storage/src/format_base_value.rs:211

↓ 14 callersMethodinitial_meta_value

(&mut self)

src/storage/src/format_list_meta_value.rs:180

↓ 14 callersMethodlpop

Removes and returns the first element of the list stored at key

src/storage/src/redis_lists.rs:290

↓ 14 callersMethodmember

(&self)

src/storage/src/format_zset_score_key.rs:208

↓ 14 callersMethodstrip_suffix

(&mut self)

src/storage/src/format_strings_value.rs:131

↓ 13 callersFunctiondecode_user_key

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

src/storage/src/storage_define.rs:70

↓ 13 callersMethodheal_partition

恢复所有连接

tests/raft_network_partition_tests.rs:95

↓ 13 callersMethodset_version

(&mut self, version: u64)

src/storage/src/format_base_value.rs:119

↓ 13 callersMethodstats

Get current channel statistics

src/common/runtime/message.rs:377

↓ 13 callersMethodupdate_version

(&mut self)

src/storage/src/format_list_meta_value.rs:66

↓ 13 callersMethodvalue

(&self)

src/storage/src/format_strings_value.rs:173

↓ 13 callersMethodzrevrank

Get the rank of a member in a sorted set, with scores ordered from high to low (0-based index)

src/storage/src/redis_zsets.rs:684

↓ 12 callersMethodbitcount

(&self, key: &[u8], start: Option<i64>, end: Option<i64>)

src/storage/src/storage_impl.rs:248

↓ 12 callersFunctioncleanup_keys

清理指定的键

tests/python/test_mset.py:354

↓ 12 callersFunctioncreate_hash_meta_value

(data_type: DataType, count: u64, etime: u64)

src/storage/tests/redis_basic_test.rs:173

↓ 12 callersFunctionformat_storage_error

Format storage error for RESP response

src/net/src/executor_ext.rs:457

↓ 12 callersMethodget_log_state

(&mut self)

src/raft/src/log_store.rs:81

↓ 12 callersFunctionnow_micros

()

src/storage/tests/redis_basic_test.rs:162

↓ 12 callersMethodrpop

Removes and returns the last element of the list stored at key

src/storage/src/redis_lists.rs:442

↓ 12 callersMethodtake_request_receiver

Take the request receiver (for storage runtime) This can only be called once as the receiver is moved

src/common/runtime/message.rs:367

↓ 12 callersMethodupdate_specific_key_statistics

( &self, dtype: DataType, key: &str, count: u64, )

src/storage/src/redis.rs:545

↓ 11 callersMethodget_property

(&self, property: &str)

src/storage/src/redis.rs:398

↓ 11 callersMethodget_response

(&self)

src/resp/src/encode.rs:360

↓ 11 callersFunctionkey_to_slot_id

Calculate slot ID from key for consistent hashing

src/common/runtime/storage_server.rs:1686

↓ 11 callersMethodlog_index

(&self)

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

↓ 11 callersMethodmodify_count

(&self)

src/storage/src/statistics.rs:104

↓ 11 callersMethodsetbit

(&self, key: &[u8], offset: i64, value: i64)

src/storage/src/storage_impl.rs:236

↓ 11 callersFunctionwrite_entries_directly

Helper function to write entries directly to RocksDB (bypassing the append callback issue)

src/raft/tests/log_store_rocksdb_test.rs:78

↓ 10 callersFunctionassert_wrongtype_error

Ensure the response matches Redis' WRONGTYPE error format.

tests/python/test_wrongtype_errors.py:34

↓ 10 callersFunctioncreate_test_entries

Helper function to create test log entries

src/raft/tests/log_store_rocksdb_test.rs:59

↓ 10 callersMethodflush

Maintenance operations

src/engine/src/rocksdb_engine.rs:178

↓ 10 callersMethodget_connection

Get a connection from the pool or create a new one

src/net/src/pool.rs:139

↓ 10 callersMethodget_log_reader

(&mut self)

src/raft/src/log_store.rs:236

↓ 10 callersMethodis_expired

(&self, timeout: Duration)

src/net/src/pipeline.rs:90

↓ 10 callersMethodset_ctime

(&mut self, ctime: u64)

src/storage/src/format_base_value.rs:115

↓ 10 callersMethodset_right_index

(&mut self, index: u64)

src/storage/src/format_list_meta_value.rs:297

↓ 10 callersMethodsetrange

(&self, key: &[u8], offset: i64, value: &[u8])

src/storage/src/storage_impl.rs:212

↓ 10 callersMethodsmembers

Get all the members in a set

src/storage/src/redis_sets.rs:209

↓ 10 callersMethodtry_get_log_entries

( &mut self, range: RB, )

src/raft/src/log_store.rs:69

↓ 9 callersMethodapplied_log_index

(&self)

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

↓ 9 callersMethodcreate

( &mut self, _context: rocksdb::compaction_filter_factory::CompactionFilterContext, )

src/storage/src/data_compaction_filter.rs:236

↓ 9 callersFunctioncreate_test_db

Helper function to create a test database with required column families

src/raft/tests/log_store_rocksdb_test.rs:39

↓ 9 callersMethoddo_purge

清理指定索引及之前的所有日志条目

src/raft/src/log_store_rocksdb.rs:277

↓ 9 callersMethodget_buffer

Get a buffer from the pool or create a new one

src/net/src/buffer.rs:163

↓ 9 callersMethodget_metrics

Get the latest metrics snapshot

src/common/runtime/metrics.rs:421

↓ 9 callersMethodkeys

Find all keys matching the given pattern

src/storage/src/storage_impl.rs:709

↓ 9 callersMethodlen

(&self)

src/kstd/src/lock_mgr.rs:48

↓ 9 callersMethodlinsert

Insert value in the list stored at key either before or after the reference value pivot

src/storage/src/redis_lists.rs:969

↓ 9 callersMethodlpushx

Insert all the specified values at the head of the list stored at key only if key exists

src/storage/src/redis_lists.rs:274

↓ 9 callersFunctionproto_to_log_id

(lid: &Option<&proto::LogId>)

src/raft/src/conversion.rs:51

↓ 9 callersMethodrpushx

Insert all the specified values at the tail of the list stored at key only if key exists

src/storage/src/redis_lists.rs:282

↓ 9 callersMethodscore

(&self)

src/storage/src/format_zset_score_key.rs:212

↓ 9 callersFunctionsetup_db_for_filter_test

(path: &std::path::Path)

src/storage/src/data_compaction_filter.rs:263

↓ 9 callersMethodstats

Get current pool statistics

src/net/src/pool.rs:206

↓ 9 callersMethodzrange

Return a range of members in a sorted set, by index

src/storage/src/redis_zsets.rs:954

↓ 9 callersMethodzrank

Get the rank of a member in a sorted set (0-based index)

src/storage/src/redis_zsets.rs:592

↓ 9 callersMethodzscan

Scan members and scores in a sorted set

src/storage/src/redis_zsets.rs:491

↓ 8 callersFunctionbuild_test_buffer

()

src/storage/src/format_list_meta_value.rs:345

↓ 8 callersMethodclear

Changes this slice to refer to an empty array.

src/kstd/src/slice.rs:68

↓ 8 callersFunctioncreate_command_table

(requirepass_provider: RequirepassProvider)

src/cmd/src/table.rs:53

↓ 8 callersMethoddo_get_log_state

获取日志存储的当前状态

src/raft/src/log_store_rocksdb.rs:298

↓ 8 callersFunctionencode_data_key

Helper to create a generic data key for testing purposes.

src/storage/src/data_compaction_filter.rs:281

↓ 8 callersMethodhandle_hello

Handle HELLO command for protocol negotiation

src/resp/src/negotiation.rs:57

↓ 8 callersMethodhscan

Scan hash fields with cursor-based iteration Returns (next_cursor, vec_of_(field, value)_tuples)

src/storage/src/redis_hashes.rs:1214

↓ 8 callersMethodlatest_sequence_number

(&self)

src/engine/src/rocksdb_engine.rs:207

↓ 8 callersMethodlset

Sets the list element at index to value

src/storage/src/redis_lists.rs:658

↓ 8 callersFunctionseek_userkey_delim

(data: &[u8])

src/storage/src/storage_define.rs:120

↓ 8 callersMethodsinter

Returns the members of the set resulting from the intersection of all the given sets

src/storage/src/redis_sets.rs:2005

↓ 8 callersMethodsnapshot

Snapshot operations

src/engine/src/rocksdb_engine.rs:196

↓ 8 callersMethodsscan

Scan set members with cursor-based iteration

src/storage/src/redis_sets.rs:2314

↓ 8 callersMethodsunion

Returns the members of the set resulting from the union of all the given sets

src/storage/src/redis_sets.rs:2098

↓ 8 callersMethodupdate

Update applied_index on write; if flushed==applied, also update flushed

src/storage/src/logindex/cf_tracker.rs:203

↓ 8 callersMethodzinterstore

Compute the intersection of multiple sorted sets and store the result

src/storage/src/redis_zsets.rs:1058

↓ 7 callersFunctionbuild_test_buffer

()

src/storage/src/format_base_data_value.rs:158

↓ 7 callersFunctionbuild_test_buffer

()

src/storage/src/format_base_meta_value.rs:341

↓ 7 callersMethodcheck_modify_count

(&mut self, delta: u64)

src/storage/src/format_base_meta_value.rs:211

↓ 7 callersMethoddo_read_committed

从持久化存储读取已提交日志 ID

src/raft/src/log_store_rocksdb.rs:238

↓ 7 callersMethoddo_save_committed

保存已提交日志 ID 到持久化存储

src/raft/src/log_store_rocksdb.rs:219

↓ 7 callersMethodexecute

(&self, exec: CmdExecution)

src/executor/src/executor.rs:85

↓ 7 callersMethodinner

Get a reference to the inner connection

src/net/src/pool.rs:96

↓ 7 callersFunctionparse_bool_value

(key: &str, value: &str)

src/conf/src/config.rs:291

↓ 7 callersFunctionproto_to_vote

(vote: &Option<&proto::Vote>)

src/raft/src/conversion.rs:74

↓ 7 callersMethodpttl

Get time to live for a key in milliseconds

src/storage/src/storage_impl.rs:521

↓ 7 callersMethodrecord_failure

Record a failed request

src/common/runtime/message.rs:301

↓ 7 callersMethodreset

(&mut self)

src/resp/src/parse.rs:500

↓ 7 callersMethodreturn_connection

Return a connection to the pool

src/net/src/pool.rs:191

↓ 7 callersMethodrpoplpush

Atomically returns and removes the last element (tail) of the list stored at source, and pushes it to the first element (head) of the list stored at d

src/storage/src/redis_lists.rs:1101

↓ 7 callersMethodsdiff

Returns the members of the set resulting from the difference between the first set and all the successive sets

src/storage/src/redis_sets.rs:1919

↓ 7 callersMethodset

(&mut self, log_index: LogIndex, seqno: SequenceNumber)

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

↓ 7 callersMethodset_argv

(&self, argv: &[Vec<u8>])

src/client/src/lib.rs:76

↓ 7 callersMethodsetex

(&self, key: &[u8], seconds: i64, value: &[u8])

src/storage/src/storage_impl.rs:218

↓ 7 callersMethodstrip_suffix

(&mut self)

src/storage/src/format_base_data_value.rs:136

↓ 7 callersMethodtruncate

(&mut self, log_id: LogId<u64>)

src/raft/src/log_store.rs:136

↓ 7 callersMethodtry_lock

Attempt to acquire the lock for `key` without blocking.

src/kstd/src/lock_mgr.rs:60

↓ 7 callersFunctionvote_to_proto

(vote: &Vote<u64>)

src/raft/src/conversion.rs:93

↓ 6 callersMethodadd_sample

(&mut self, latency_ms: u64, max_samples: usize)

src/common/runtime/metrics.rs:615

↓ 6 callersMethodallow_connection

允许两个节点之间的通信

tests/raft_network_partition_tests.rs:48

↓ 6 callersMethodcf_write

获取列族句柄，若不存在则返回写操作错误

src/raft/src/log_store_rocksdb.rs:68

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