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

↓ 6 callersFunctionclose_storage

(storage: Arc<Storage>, name: &str)

src/raft/tests/snapshot_roundtrip_test.rs:29

↓ 6 callersMethodcreate_partition

创建网络分区：将节点分成两组

tests/raft_network_partition_tests.rs:68

↓ 6 callersFunctioncreate_string_value

(value: &[u8], etime: u64)

src/storage/tests/redis_basic_test.rs:186

↓ 6 callersFunctiondecode_log_key

解码 RocksDB 键为日志索引

src/raft/src/log_store_rocksdb.rs:503

↓ 6 callersMethoddo_truncate

截断指定索引及之后的所有日志条目

src/raft/src/log_store_rocksdb.rs:259

↓ 6 callersMethodget

Get the value of a key

src/storage/src/redis_strings.rs:495

↓ 6 callersMethodget_cf_flushed

(&self, cf_id: usize)

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

↓ 6 callersMethodhget

Get the value of a hash field

src/storage/src/redis_hashes.rs:137

↓ 6 callersMethodis_ok

(&self)

src/kstd/src/status.rs:56

↓ 6 callersMethoditerator_cf

( &'a self, cf: &ColumnFamilyRef<'a>, mode: IteratorMode, )

src/engine/src/rocksdb_engine.rs:160

↓ 6 callersMethodlog_error

Log an error event with full context

src/common/runtime/error_logging.rs:211

↓ 6 callersMethodlrem

Removes the first count occurrences of elements equal to value from the list

src/storage/src/redis_lists.rs:830

↓ 6 callersMethodmget

MGET command - multiple get operations

src/net/src/storage_client.rs:234

↓ 6 callersMethodmset

MSET key value [key value ...] Sets the given keys to their respective values. MSET replaces existing values with new values, just like regular SET.

src/storage/src/redis_strings.rs:1156

↓ 6 callersFunctionparse_lex_range

Parse lexicographical range specifier Returns (member, is_exclusive) - "-" means negative infinity (None, false) - "+" means positive infinity (None,

src/storage/src/redis_zsets.rs:2094

↓ 6 callersMethodpush_core

Core implementation for pushing values to a list position: true for left (head), false for right (tail) allow_create: if true, creates new list when k

src/storage/src/redis_lists.rs:43

↓ 6 callersMethodput

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

src/engine/src/rocksdb_engine.rs:57

↓ 6 callersMethodrecord_success

Record a successful request

src/common/runtime/message.rs:294

↓ 6 callersMethodrequest_sender

Get the request sender (for network runtime)

src/common/runtime/message.rs:361

↓ 6 callersMethodscard

Get the number of members in a set

src/storage/src/redis_sets.rs:174

↓ 6 callersMethodset_ctime

(&mut self, ctime: u64)

src/storage/src/format_base_data_value.rs:123

↓ 6 callersMethodvalidate

Validate the configuration parameters

src/conf/src/runtime_config.rs:257

↓ 6 callersMethodzrangebylex

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

src/storage/src/redis_zsets.rs:1306

↓ 5 callersMethodcf_read

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

src/raft/src/log_store_rocksdb.rs:78

↓ 5 callersMethodclear

(&mut self)

src/storage/src/batch.rs:219

↓ 5 callersMethodcmd_name

(&self)

src/client/src/lib.rs:101

↓ 5 callersFunctioncreate_test_base_meta_value

()

src/storage/src/format_base_meta_value.rs:251

↓ 5 callersFunctioncreate_test_lists_meta_value

()

src/storage/src/format_list_meta_value.rs:335

↓ 5 callersMethodctime

(&self)

src/storage/src/format_base_value.rs:207

↓ 5 callersFunctiondecode_fixed

(buf: &[u8])

src/storage/src/coding.rs:76

↓ 5 callersFunctiondeserialize

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

src/raft/src/log_store_rocksdb.rs:488

↓ 5 callersMethoddo_read_vote

从持久化存储读取投票信息

src/raft/src/log_store_rocksdb.rs:198

↓ 5 callersMethoddo_save_vote

保存投票信息到持久化存储

src/raft/src/log_store_rocksdb.rs:182

↓ 5 callersMethodencode

(&self)

src/storage/src/format_lists_data_key.rs:67

↓ 5 callersFunctionerror_response

错误响应

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

↓ 5 callersMethodexists

EXISTS command - check if keys exist

src/net/src/storage_client.rs:123

↓ 5 callersMethodfinish

(&mut self)

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

↓ 5 callersMethodforce_shutdown

Force a graceful shutdown with timeout

src/common/runtime/manager.rs:358

↓ 5 callersMethodget_logindex_collector

Get logindex collector for specified instance

src/storage/src/storage.rs:545

↓ 5 callersMethodget_stats

Get runtime statistics

src/common/runtime/manager.rs:379

↓ 5 callersMethodgetbit

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

src/storage/src/storage_impl.rs:242

↓ 5 callersMethodload_cursor_start_key

(&self, dtype: DataType, cursor: i64)

src/storage/src/storage.rs:428

↓ 5 callersFunctionmake_client

()

src/cmd/src/auth.rs:134

↓ 5 callersMethodmetrics

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

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

↓ 5 callersMethodnext_command

(&mut self)

src/resp/src/parse.rs:496

↓ 5 callersFunctionok_response

()

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

↓ 5 callersMethodon_binlog_write

Apply a Raft binlog entry to the underlying RocksDB instance and record `(raft_log_index, seqno)` in the LogIndex collector. Single-writer invariant*

src/storage/src/storage.rs:501

↓ 5 callersMethodopen

打开或创建指定路径的 RocksDB 日志存储

src/raft/src/log_store_rocksdb.rs:354

↓ 5 callersFunctionparse_bool_from_string

Parse boolean from string (for config parsing, not serde)

src/conf/src/de_func.rs:48

↓ 5 callersFunctionput_meta

(db: &Arc<DB>, user_key: &[u8], data_type: DataType, version: u64, etime: u64)

src/storage/src/data_compaction_filter.rs:293

↓ 5 callersMethodrecord_request_sent

Update statistics when a request is sent

src/common/runtime/message.rs:406

↓ 5 callersMethodreturn_buffer

Return a buffer to the pool

src/net/src/buffer.rs:192

↓ 5 callersMethodrun

Start the storage server and begin processing requests

src/common/runtime/storage_server.rs:250

↓ 5 callersMethodsend_request_with_priority

Send a storage request with custom timeout and priority

src/common/runtime/message.rs:837

↓ 5 callersMethodset_expiration

Set expiration time for a key

src/storage/src/expiration_manager.rs:128

↓ 5 callersMethodset_key_etime_for_instance

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

src/storage/src/storage_impl.rs:35

↓ 5 callersMethodset_left_index

(&mut self, index: u64)

src/storage/src/format_list_meta_value.rs:283

↓ 5 callersMethodzrangebyscore

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

src/storage/src/redis_zsets.rs:1405

↓ 5 callersMethodzrem

Remove one or more members from a sorted set

src/storage/src/redis_zsets.rs:776

↓ 5 callersMethodzremrangebyrank

Remove all members in a sorted set within the given indexes

src/storage/src/redis_zsets.rs:1603

↓ 5 callersMethodzrevrangebyscore

Return a range of members in a sorted set, by score, with scores ordered from high to low

src/storage/src/redis_zsets.rs:1926

↓ 5 callersMethodzunionstore

Compute the union of multiple sorted sets and store the result

src/storage/src/redis_zsets.rs:1071

↓ 4 callersFunctionauth_cmd_with

(password: Option<&str>)

src/cmd/src/auth.rs:143

↓ 4 callersMethodbuild_append_batch

将日志条目序列化为 WriteBatch

src/raft/src/log_store_rocksdb.rs:88

↓ 4 callersFunctionbuild_test_buffer

()

src/storage/src/format_strings_value.rs:239

↓ 4 callersMethodcalculate_percentiles

(&self)

src/common/runtime/metrics.rs:625

↓ 4 callersMethodcapacity

(&self)

src/net/src/buffer.rs:93

↓ 4 callersMethodclose

Close all RocksDB instances and release file handles. Used before reopening Storage after snapshot installation.

src/storage/src/storage.rs:229

↓ 4 callersFunctioncreate_list_meta_value

(count: u64, etime: u64)

src/storage/tests/redis_basic_test.rs:180

↓ 4 callersMethoddata

(&self)

src/storage/src/format_member_data_key.rs:144

↓ 4 callersMethoddo_cmd

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

src/cmd/src/auth.rs:74

↓ 4 callersMethoddo_compact_range

(&self, _dtype: DataType, _start: &str, _end: &str)

src/storage/src/storage.rs:381

↓ 4 callersMethodencode

(&self)

src/storage/src/format_base_data_value.rs:49

↓ 4 callersMethodencode_hash_data_prefix

Helper method to encode hash data prefix

src/storage/src/redis_multi.rs:481

↓ 4 callersMethodencode_list_data_prefix

Helper method to encode list data prefix

src/storage/src/redis_multi.rs:508

↓ 4 callersMethodencode_zsets_member_prefix

Helper method to encode zsets member prefix

src/storage/src/redis_multi.rs:535

↓ 4 callersMethodexists

Check if a key exists

src/storage/src/redis_multi.rs:130

↓ 4 callersMethodexport_state

Export state for snapshot serialization. Returns a list of `"log_index:seqno"` strings where both values are decimal integers. This on-disk format is

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

↓ 4 callersMethodget_current_snapshot

( &mut self, )

src/raft/src/state_machine.rs:438

↓ 4 callersMethodget_health_status

Get current health status

src/common/runtime/metrics.rs:1281

↓ 4 callersMethodget_key_type

Get the data type of a key # Arguments `key` - The key to check # Returns `Ok(DataType)` - the data type of the key `Err(RedisErr)` - if there's a d

src/storage/src/redis_strings.rs:2092

↓ 4 callersFunctionget_largest_log_index_from_collection

Find the largest log index from TablePropertiesCollection

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

↓ 4 callersMethodget_smallest_log_index

Get smallest applied/flushed log index (used for Purge, SetFlushedLogIndexGlobal) `flush_cf`: index of CF currently being flushed, `None` means none

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

↓ 4 callersMethodhash

(&self, state: &mut H)

src/storage/src/statistics.rs:45

↓ 4 callersMethodhll_add_to_registers

Add an element to HyperLogLog registers

src/storage/src/redis_hyperloglog.rs:252

↓ 4 callersMethodincr_decr

(&self, key: &[u8], incr: i64)

src/storage/src/storage_impl.rs:188

↓ 4 callersFunctionio_err_to_raft

(e: std::io::Error)

src/raft/src/state_machine.rs:55

↓ 4 callersMethodlen

Get the number of commands in this batch

src/net/src/async_resp_parser.rs:209

↓ 4 callersMethodlog_simple_error

Log an error with minimal context (convenience method)

src/common/runtime/error_logging.rs:286

↓ 4 callersMethodltrim

Trims the list to the specified range

src/storage/src/redis_lists.rs:732

↓ 4 callersFunctionmake_storage

()

src/cmd/src/auth.rs:139

↓ 4 callersMethodname

(&self)

src/storage/src/redis.rs:73

↓ 4 callersMethodnetwork_handle

Get a handle to the network runtime

src/common/runtime/manager.rs:314

↓ 4 callersFunctionok_response

成功响应

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

↓ 4 callersMethodopen

( &mut self, options: Arc<StorageOptions>, db_path: impl AsRef<Path>, )

src/storage/src/storage.rs:165

↓ 4 callersMethodpsetex

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

src/storage/src/storage_impl.rs:224

↓ 4 callersMethodpurge

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

src/raft/src/log_store.rs:151

↓ 4 callersFunctionread_stats_from_table_props

Parse log_index/seqno from TableProperties' user_collected_properties

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

↓ 4 callersMethodrecord_request_received

Update statistics when a request is received

src/common/runtime/message.rs:418

↓ 4 callersMethodrecord_response_sent

Update statistics when a response is sent

src/common/runtime/message.rs:424

← previous next →201–300 of 2,670, ranked by callers