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

↓ 1 callersMethodset_ctime_to_value

(&mut self)

src/storage/src/format_base_data_value.rs:128

↓ 1 callersMethodset_ctime_to_value

(&mut self)

src/storage/src/format_list_meta_value.rs:204

↓ 1 callersMethodset_ctime_to_value

(&mut self)

src/storage/src/format_base_meta_value.rs:163

↓ 1 callersMethodset_data_type_to_value

(&mut self, data_type: DataType)

src/storage/src/format_list_meta_value.rs:190

↓ 1 callersMethodset_etime

(&mut self, etime: u64)

src/storage/src/format_list_meta_value.rs:258

↓ 1 callersMethodset_etime_to_value

(&mut self)

src/storage/src/format_strings_value.rs:163

↓ 1 callersMethodset_etime_to_value

(&mut self)

src/storage/src/format_list_meta_value.rs:211

↓ 1 callersMethodset_etime_to_value

(&mut self)

src/storage/src/format_base_meta_value.rs:170

↓ 1 callersMethodset_key_etime

(&self, key: &[u8], etime: u64)

src/storage/src/redis_strings.rs:68

↓ 1 callersMethodset_max_gap

(&mut self, gap: u64)

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

↓ 1 callersMethodset_name

(&self, name: &[u8])

src/client/src/lib.rs:86

↓ 1 callersMethodset_options

(&self, options: &[(&str, &str)])

src/engine/src/rocksdb_engine.rs:81

↓ 1 callersMethodset_pause_controller

Set pause controller for coordinating with StorageServer.

src/raft/src/state_machine.rs:222

↓ 1 callersMethodset_version

(&mut self, version: RespVersion)

src/resp/src/parse.rs:81

↓ 1 callersMethodset_version_to_value

(&mut self)

src/storage/src/format_list_meta_value.rs:197

↓ 1 callersMethodset_version_to_value

(&mut self)

src/storage/src/format_base_meta_value.rs:156

↓ 1 callersMethodsetnx

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

src/storage/src/storage_impl.rs:230

↓ 1 callersMethodseverity

Get the severity level of this error

src/common/runtime/error.rs:277

↓ 1 callersMethodshared_db

(&self)

src/engine/src/rocksdb_engine.rs:42

↓ 1 callersMethodshould_allow_request

Check if a request should be allowed through

src/common/runtime/message.rs:274

↓ 1 callersMethodshould_attempt_recovery

Check if recovery should be attempted

src/common/runtime/message.rs:682

↓ 1 callersMethodsimulate_partition

(&self)

src/common/runtime/stress_tests.rs:109

↓ 1 callersMethodsimulate_partition

(&self)

tests/dual_runtime_stress_tests.rs:107

↓ 1 callersMethodsinterstore

Store the intersection of all the given sets into a destination key

src/storage/src/redis_sets.rs:2161

↓ 1 callersMethodsize

Queue length

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

↓ 1 callersMethodskip_empty_lines

(&mut self)

src/resp/src/parse.rs:134

↓ 1 callersMethodsmove

Move member from source set to destination set

src/storage/src/redis_sets.rs:661

↓ 1 callersMethodspop

Remove and return random members from a set

src/storage/src/redis_sets.rs:519

↓ 1 callersMethodsrandmember

Get random members from a set

src/storage/src/redis_sets.rs:315

↓ 1 callersMethodsrem

Remove one or more members from a set

src/storage/src/redis_sets.rs:429

↓ 1 callersFunctionstack_trace_style_impl

(args: TokenStream2, input: TokenStream2)

src/common/macro/src/macro_stack_trace_debug.rs:24

↓ 1 callersMethodstart_batch_processor

Start the background batch processor

src/net/src/pipeline.rs:170

↓ 1 callersMethodstart_cleanup_task

Start the background cleanup task

src/storage/src/expiration_manager.rs:54

↓ 1 callersMethodstart_health_monitoring

Start background health monitoring

src/common/runtime/manager.rs:517

↓ 1 callersMethodstart_pool_cleanup

Start background task for connection pool cleanup

src/net/src/network_server.rs:123

↓ 1 callersMethodstart_pool_cleanup

Start background task for resource pool cleanup

src/net/src/tcp.rs:137

↓ 1 callersFunctionstart_pool_cleanup_task

Start background cleanup task for a connection pool

src/net/src/tcp.rs:49

↓ 1 callersFunctionstart_server

( protocol: &str, addr: &str, runtime_manager: &mut RuntimeManager, global_storage: &GlobalSto

src/server/src/main.rs:239

↓ 1 callersMethodstate

Get the current state

src/common/runtime/message.rs:310

↓ 1 callersMethodstats

Get buffer statistics

src/net/src/buffer.rs:245

↓ 1 callersMethodstorage_client

Get the storage client

src/net/src/network_server.rs:151

↓ 1 callersFunctionstorage_err_to_raft

(e: storage::error::Error)

src/raft/src/state_machine.rs:47

↓ 1 callersMethodstore_scan_next_point

( &self, dtype: DataType, key: &[u8], pattern: &[u8], cursor: u64,

src/storage/src/redis.rs:685

↓ 1 callersMethodstrip_suffix

(&mut self)

src/storage/src/format_list_meta_value.rs:311

↓ 1 callersMethodstrlen

(&self, key: &[u8])

src/storage/src/storage_impl.rs:200

↓ 1 callersMethodsunionstore

Store the union of all the given sets into a destination key

src/storage/src/redis_sets.rs:2177

↓ 1 callersFunctiontest_atomicity

独立测试函数 - 原子性测试

tests/python/test_mset.py:338

↓ 1 callersFunctiontest_basic

独立测试函数 - 基本功能

tests/python/test_mset.py:255

↓ 1 callersFunctiontest_large_batch

独立测试函数 - 大批量操作

tests/python/test_mset.py:318

↓ 1 callersFunctiontest_overwrite

独立测试函数 - 覆盖测试

tests/python/test_mset.py:287

↓ 1 callersFunctiontest_single_pair

独立测试函数 - 单个键值对

tests/python/test_mset.py:303

↓ 1 callersFunctiontest_with_mget

独立测试函数 - 与 MGET 配合

tests/python/test_mset.py:271

↓ 1 callersMethodtimeout

(msg: &str)

src/kstd/src/status.rs:43

↓ 1 callersMethodto_command

(&self)

src/resp/src/command.rs:531

↓ 1 callersMethodto_debug_match_arm

(&self)

src/common/macro/src/error_variant.rs:98

↓ 1 callersMethodto_rocksdb

(&self)

src/conf/src/config.rs:39

↓ 1 callersMethodtry_multi_lock

Attempt to acquire multiple locks without blocking. Returns `None` as soon as any lock is unavailable and releases all previously acquired locks.

src/kstd/src/lock_mgr.rs:85

↓ 1 callersMethodupdate_buffer_utilization

Update buffer utilization

src/common/runtime/metrics.rs:1053

↓ 1 callersMethodupdate_metrics

Update error metrics

src/common/runtime/error_logging.rs:408

↓ 1 callersMethodvalidate_fault_injection_config

Validate fault injection configuration

src/conf/src/runtime_config.rs:403

↓ 1 callersFunctionvalidate_loaded_config

(config: &Config)

src/conf/src/config.rs:295

↓ 1 callersMethodvalidate_priority_config

Validate priority configuration

src/conf/src/runtime_config.rs:353

↓ 1 callersMethodvalidate_raft_metrics_config

Validate Raft metrics configuration

src/conf/src/runtime_config.rs:378

↓ 1 callersMethodvalidate_scaling_config

Validate scaling configuration

src/conf/src/runtime_config.rs:308

↓ 1 callersMethodwrite

(&self, batch: WriteBatch)

src/engine/src/rocksdb_engine.rs:73

↓ 1 callersMethodwrite_to_dir

(&self, dir: &Path)

src/storage/src/checkpoint.rs:112

↓ 1 callersMethodwrite_to_dir_atomically

Write metadata atomically using temp file + rename pattern. This ensures that the file is either completely written or not present at all. Atomic ren

src/storage/src/checkpoint.rs:123

↓ 1 callersMethodzcount

Count the number of members in a sorted set with scores within the given values

src/storage/src/redis_zsets.rs:252

↓ 1 callersMethodzincrby

Increment the score of a member in a sorted set

src/storage/src/redis_zsets.rs:312

↓ 1 callersFunctionzsets_score_key_comparator_name

()

src/storage/src/custom_comparator.rs:30

↓ 1 callersFunctionzsets_score_key_compare

(a: &[u8], b: &[u8])

src/storage/src/custom_comparator.rs:122

Methodacl_category

(&self)

src/cmd/src/lib.rs:224

Methodactivate_isolation

Activates fault isolation for a component

src/common/runtime/fault_isolation.rs:53

Methodadd_command

(&mut self, command: PipelineCommand)

src/net/src/pipeline.rs:82

Methodadd_learner

添加学习者节点

src/raft/src/grpc/admin.rs:128

Methodadd_request

Add a request to the batch

src/common/runtime/storage_server.rs:686

Methodaddr

Get the server address

src/net/src/network_server.rs:146

Methodappend

Append a value to a key Returns the length of the string after the append operation

src/storage/src/redis_strings.rs:425

Methodappend

( &mut self, entries: I, callback: LogFlushed<KiwiTypeConfig>, )

src/raft/src/log_store.rs:118

Methodappend

( &mut self, entries: I, callback: openraft::storage::LogFlushed<KiwiTypeConfig>,

src/raft/src/log_store_rocksdb.rs:412

Methodappend_entries

( &mut self, rpc: AppendEntriesRequest<KiwiTypeConfig>, _option: RPCOption, )

src/raft/src/network.rs:222

Methodappend_entries

追加日志条目 RPC - 日志复制使用

src/raft/src/grpc/core.rs:92

Methodappend_map

(&mut self, pairs: &[(RespData, RespData)])

src/resp/src/encode.rs:522

Methodappend_push

(&mut self, items: &[RespData])

src/resp/src/encode.rs:541

Methodappend_set

(&mut self, items: &[RespData])

src/resp/src/encode.rs:532

Methodappend_simple_string

(&mut self, value: &str)

src/resp/src/encode.rs:325

Methodappend_string_raw

(&mut self, value: &str)

src/resp/src/encode.rs:320

Methodappend_string_vec

(&mut self, values: &[String])

src/resp/src/encode.rs:340

Methodapplied_state

( &mut self, )

src/raft/src/state_machine.rs:444

Methodapply

( &mut self, entries: I, )

src/raft/src/state_machine.rs:238

Functionarb_entry

生成随机 Entry 的策略

src/raft/src/log_store_rocksdb.rs:633

Functionarb_vote

生成随机 Vote 的策略

src/raft/src/log_store_rocksdb.rs:589

Methodarg_count

(&self)

src/resp/src/command.rs:516

Methodarg_string

(&self, index: usize)

src/resp/src/command.rs:520

Methodas_boolean

Convert to boolean (RESP3 specific)

src/resp/src/types.rs:194

Methodas_bytes

Returns a u8 slice containing the copy of the referenced data.

src/kstd/src/slice.rs:93

Methodas_double

Convert to double (RESP3 specific)

src/resp/src/types.rs:210

Methodas_integer

(&self)

src/resp/src/types.rs:174

Functionauth_carries_no_auth_flag

()

src/cmd/src/auth.rs:220

Functionauth_with_user_and_password_is_rejected

()

src/cmd/src/auth.rs:206

← previous next →701–800 of 2,670, ranked by callers