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/server/src/main.rs:68

src/raft/build.rs:21

( &self, _request: Request<MembersRequest>, )

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

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

src/storage/src/storage_impl.rs:60

Methodmilliseconds_to_expire_time

Convert milliseconds to microseconds timestamp

src/storage/src/expiration_manager.rs:240

Functionmkdir_with_path

(path: P, _mode: u32)

src/kstd/src/env.rs:34

tests/python/test_list_commands.py:233

Methodmonitor_compaction

Monitor RocksDB compaction operations

src/common/runtime/storage_server.rs:1114

Methodmonitor_flush

Monitor RocksDB flush operations

src/common/runtime/storage_server.rs:1175

Methodmset_batch

设置一批键

tests/python/test_mset_concurrent.py:114

Methodmset_mget_operation

MSET 后立即 MGET

tests/python/test_mset_concurrent.py:282

Methodmset_operation

每个线程执行的 MSET 操作

tests/python/test_mset_concurrent.py:43

Methodmset_operation

tests/python/test_mset_concurrent.py:357

MSETNX key value [key value ...] Sets the given keys to their respective values, only if all keys don't exist. MSETNX is atomic, so either all keys a

src/storage/src/redis_strings.rs:1195

Methodmulti_del

Delete multiple keys

src/storage/src/redis_multi.rs:113

Functionmurmur3_32

(data: T, seed: u32)

src/storage/src/storage_murmur3.rs:20

Functionmv_test_base_key_encode_and_decode

src/storage/src/format_base_key.rs:99

Functionmv_test_member_data_key_encode_and_decode

src/storage/src/format_member_data_key.rs:155

Functionmv_test_member_data_key_with_empty_key_and_data

src/storage/src/format_member_data_key.rs:210

src/client/src/lib.rs:91

src/resp/src/command.rs:508

src/storage/src/data_compaction_filter.rs:195

src/storage/src/meta_compaction_filter.rs:36

src/storage/src/logindex/table_properties.rs:68

Methodneeds_compaction

Check if buffer needs to be reset due to fragmentation

src/net/src/buffer.rs:416

Methodnetwork_runtime

Create a network runtime error

src/common/runtime/error.rs:69

Methodnetwork_tracker

Get network metrics tracker for recording network events

src/common/runtime/metrics.rs:426

Create a new benchmark runner with the given configuration

benches/dual_runtime_performance_benchmark.rs:135

(stream: Box<dyn StreamTrait>)

src/client/src/lib.rs:50

(command_type: CommandType, args: Vec<Bytes>, is_pipeline: bool)

src/resp/src/command.rs:500

(version: RespVersion)

src/resp/src/parse.rs:67

src/resp/src/negotiation.rs:41

(version: RespVersion)

src/resp/src/encode.rs:166

Create a new RuntimeConfig with custom parameters

src/conf/src/runtime_config.rs:231

(user_value: T)

src/storage/src/format_strings_value.rs:38

(key: Vec<u8>, version: u64)

src/storage/src/format.rs:63

(user_value: T)

src/storage/src/format_base_data_value.rs:40

src/storage/src/format_base_key.rs:42

Create a new RocksBatch. # Arguments `db` - Reference to the database engine `write_options` - Write options for the batch commit `cf_handles` - Colu

src/storage/src/batch.rs:120

(window_size: usize)

src/storage/src/statistics.rs:55

(key: &[u8], version: u64, index: u64)

src/storage/src/format_lists_data_key.rs:47

(db: Option<Arc<DB>>, data_type: DataType)

src/storage/src/data_compaction_filter.rs:59

src/storage/src/format_list_meta_value.rs:55

Create a new SlotIndexer with a defined instance number.

src/storage/src/slot_indexer.rs:40

(score: f64, member: Vec<u8>)

src/storage/src/format_zset_score_key.rs:36

( storage: Arc<StorageOptions>, index: i32, bg_task_handler: Arc<BgTaskHandler>,

src/storage/src/redis.rs:135

Create a new snapshot meta with current version

src/storage/src/checkpoint.rs:53

(key: &[u8], version: u64, data: &[u8])

src/storage/src/format_member_data_key.rs:42

(user_value: T)

src/storage/src/format_base_meta_value.rs:56

Create a new StorageOptions with default values

src/storage/src/options.rs:109

(data_type: DataType, user_value: T)

src/storage/src/format_base_value.rs:97

Create a new expiration manager

src/storage/src/expiration_manager.rs:44

src/storage/src/storage.rs:80

(log_index: LogIndex, seqno: SequenceNumber)

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

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

src/storage/src/logindex/db_access.rs:47

(collector: Arc<LogIndexAndSequenceCollector>)

src/storage/src/logindex/table_properties.rs:47

( collector: Arc<LogIndexAndSequenceCollector>, cf_tracker: Arc<LogIndexOfColumnFamilies>,

src/storage/src/logindex/event_listener.rs:66

Create Collector When step_length_bit=0, full sampling; when >0, sample at 2^bit intervals to save memory

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

Create a new RocksdbEngine instance

src/engine/src/rocksdb_engine.rs:34

Creates a slice referring to d[0,n-1].

src/kstd/src/slice.rs:33

Create a new lock manager with at least `num_shards` mutexes. The actual number of mutexes is rounded up to the next power of two so that we can use a

src/kstd/src/lock_mgr.rs:37

src/cmd/src/bitcount.rs:33

src/cmd/src/hscan.rs:33

src/cmd/src/msetnx.rs:33

src/cmd/src/bitpos.rs:38

src/cmd/src/setbit.rs:33

src/cmd/src/zrevrangebyscore.rs:32

src/cmd/src/spop.rs:33

src/cmd/src/append.rs:33

src/cmd/src/admin.rs:36

src/cmd/src/group_client.rs:47

src/cmd/src/incrby.rs:34

src/cmd/src/srandmember.rs:33

src/cmd/src/zrangebylex.rs:32

src/cmd/src/expireat.rs:33

src/cmd/src/smove.rs:33

src/cmd/src/randomkey.rs:33

src/cmd/src/ping.rs:34

src/cmd/src/del.rs:33

src/cmd/src/hexists.rs:32

src/cmd/src/setex.rs:33

src/cmd/src/zremrangebylex.rs:32

src/cmd/src/zadd.rs:31

src/cmd/src/mset.rs:33

src/cmd/src/zremrangebyrank.rs:32

src/cmd/src/zremrangebyscore.rs:32

src/cmd/src/hincrbyfloat.rs:33

src/cmd/src/pttl.rs:33

src/cmd/src/zscan.rs:33

src/cmd/src/setrange.rs:33

src/cmd/src/setnx.rs:33

src/cmd/src/zrangebyscore.rs:32

src/cmd/src/zrem.rs:32

(name: String, arity: i16, flags: CmdFlags, acl_category: AclCategory)

src/cmd/src/lib.rs:277

src/cmd/src/getset.rs:33

src/cmd/src/zrange.rs:32

src/cmd/src/hset.rs:32

src/cmd/src/srem.rs:33

src/cmd/src/sinterstore.rs:33

← previous next →1,301–1,400 of 2,670, ranked by callers