Functions — github.com/arana-db/kiwi

CodeHub MCPcopy Create free account

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

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

⨍ Functions 2,670◇ Types & classes 421

src/common/runtime/storage_server.rs:93

src/common/runtime/health.rs:167

src/common/runtime/error_logging.rs:39

src/common/runtime/metrics.rs:327

src/common/runtime/tests.rs:42

src/common/runtime/fault_isolation.rs:79

src/common/runtime/message.rs:53

src/common/runtime/stress_tests.rs:56

src/common/runtime/additional_unit_tests.rs:51

tests/dual_runtime_unit_tests.rs:51

tests/dual_runtime_integration_tests.rs:51

tests/comprehensive_test_suite.rs:62

tests/dual_runtime_stress_tests.rs:54

Functiondefault_batch_timeout

src/conf/src/runtime_config.rs:45

Functiondefault_fault_injection_drop_rate

src/conf/src/runtime_config.rs:37

Functiondefault_fault_injection_network_delay

src/conf/src/runtime_config.rs:33

Functiondefault_raft_metrics_collection_interval

src/conf/src/runtime_config.rs:25

Functiondefault_raft_metrics_retention_period

src/conf/src/runtime_config.rs:29

Functiondefault_request_timeout

src/conf/src/runtime_config.rs:41

Functiondefault_scaling_evaluation_interval

src/conf/src/runtime_config.rs:21

Delete one or more keys

src/storage/src/storage_impl.rs:684

Methoddelete_cf_opt

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

src/engine/src/rocksdb_engine.rs:138

Functiondelete_dir

src/kstd/src/env.rs:51

Methoddelete_operation

tests/python/test_mset_concurrent.py:351

Methoddelete_opt

(&self, key: &[u8], writeopts: &WriteOptions)

src/engine/src/rocksdb_engine.rs:69

Functiondequeue

(client: redis.Redis, queue_name: str)

tests/tcl/tests/helpers/redis_queue.py:25

Functiondeserialize_bool_from_yes_no

(deserializer: D)

src/conf/src/de_func.rs:22

Functiondeserialize_memory

(deserializer: D)

src/conf/src/de_func.rs:36

Methoddetect_version

Detect protocol version from the first byte of input

src/resp/src/parse.rs:86

Methoddetermine_overall_status

Determine overall system status from component health

src/common/runtime/metrics.rs:1896

Methoddetermine_priority

Determine the priority of the batch based on commands

src/net/src/async_resp_parser.rs:180

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/bitcount.rs:73

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hscan.rs:62

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/msetnx.rs:82

Process the BITPOS command # Arguments `client` - The client that sent the command `storage` - The storage instance # Command Format BITPOS key bit

src/cmd/src/bitpos.rs:83

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/setbit.rs:71

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zrevrangebyscore.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/spop.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/append.rs:58

(&self, client: &Client, _storage: Arc<Storage>)

src/cmd/src/admin.rs:57

(&self, client: &Client, _storage: Arc<Storage>)

src/cmd/src/group_client.rs:68

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/incrby.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/srandmember.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zrangebylex.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/expireat.rs:65

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/smove.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/randomkey.rs:60

(&self, client: &Client, _storage: Arc<Storage>)

src/cmd/src/ping.rs:55

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/del.rs:60

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hexists.rs:53

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/setex.rs:58

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zremrangebylex.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zadd.rs:68

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/mset.rs:85

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zremrangebyrank.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zremrangebyscore.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hincrbyfloat.rs:54

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/pttl.rs:67

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zscan.rs:62

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/setrange.rs:58

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/setnx.rs:67

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zrangebyscore.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zrem.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/getset.rs:67

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zrange.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hset.rs:60

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/srem.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/sinterstore.rs:62

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hmget.rs:54

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/decrby.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zincrby.rs:70

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hlen.rs:53

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zrevrange.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/ttl.rs:67

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/sadd.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/sdiffstore.rs:62

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zrevrank.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/sismember.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zscore.rs:70

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zrank.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zunionstore.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/pexpire.rs:64

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/mget.rs:72

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/strlen.rs:58

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zinterstore.rs:56

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/sdiff.rs:62

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/zcard.rs:59

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/flushall.rs:61

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/expire.rs:64

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/incr.rs:57

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hdel.rs:53

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hmset.rs:60

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/keys.rs:62

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hincrby.rs:53

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hsetnx.rs:53

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/pexpireat.rs:64

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/hstrlen.rs:53

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/sinter.rs:62

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/sunionstore.rs:62

(&self, client: &Client, storage: Arc<Storage>)

src/cmd/src/type_cmd.rs:64

← previous next →901–1,000 of 2,670, ranked by callers