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

↓ 4 callersMethodrecord_timeout

Record timeout event

src/common/runtime/metrics.rs:1088

↓ 4 callersMethodreset

Reset network metrics

src/common/runtime/metrics.rs:774

↓ 4 callersMethodright_index

(&self)

src/storage/src/format_list_meta_value.rs:83

↓ 4 callersMethodset_authenticated

(&self, val: bool)

src/client/src/lib.rs:131

↓ 4 callersMethodset_flushed_log_index_global

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

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

↓ 4 callersMethodset_index_to_value

(&mut self)

src/storage/src/format_list_meta_value.rs:225

↓ 4 callersMethodstorage_handle

Get a handle to the storage runtime

src/common/runtime/manager.rs:322

↓ 4 callersMethodstore_cursor_start_key

( &self, dtype: DataType, cursor: i64, cursor_type: char, next_key: St

src/storage/src/storage.rs:449

↓ 4 callersMethodtake_reply

(&self)

src/client/src/lib.rs:121

↓ 4 callersMethodtry_send_request

Try to send a single request without retry logic

src/common/runtime/message.rs:980

↓ 4 callersFunctionunpack_tar_to_dir

Unpack a tar archive (from `build_snapshot` / OpenRaft `SnapshotData`) into `dst`. Security: validates paths to prevent path traversal attacks. - Rej

src/raft/src/snapshot_archive.rs:70

↓ 4 callersMethodupdate_version

(&mut self)

src/storage/src/format_base_meta_value.rs:65

↓ 4 callersMethodwait_for_state

Wait for the RuntimeManager to reach a specific state

src/common/runtime/manager.rs:292

↓ 3 callersMethodas_string

(&self)

src/resp/src/types.rs:138

↓ 3 callersMethodavailable_data

Get available data as bytes slice

src/net/src/buffer.rs:388

↓ 3 callersMethodblock_connection

阻止两个节点之间的通信

tests/raft_network_partition_tests.rs:55

↓ 3 callersMethodbuild_snapshot

(&mut self)

src/raft/src/state_machine.rs:474

↓ 3 callersFunctionbuild_test_buffer_with_value

(value: &[u8])

src/storage/src/format_base_data_value.rs:166

↓ 3 callersMethodchannel_stats

Get channel statistics

src/net/src/storage_client.rs:65

↓ 3 callersMethodcleanup_idle

Clean up idle connections

src/net/src/pool.rs:219

↓ 3 callersMethodclear_and_store_set

Helper method to clear a destination set and store new members atomically This method performs all operations (delete old data + add new members) in

src/storage/src/redis_sets.rs:2197

↓ 3 callersMethodclear_current_task_type

(&self)

src/storage/src/storage.rs:273

↓ 3 callersMethodcreate_checkpoint

Create a RocksDB physical checkpoint at `path`.

src/storage/src/redis.rs:371

↓ 3 callersFunctioncreate_test_db

()

src/engine/src/rocksdb_engine.rs:241

↓ 3 callersFunctioncreate_test_storage

()

tests/dual_runtime_integration_tests.rs:485

↓ 3 callersFunctioncreate_test_storage_client

()

src/net/src/storage_client.rs:394

↓ 3 callersFunctioncreate_test_string_value

()

src/storage/src/format_strings_value.rs:187

↓ 3 callersMethoddelete_cf

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

src/engine/src/rocksdb_engine.rs:125

↓ 3 callersMethodencode_zsets_score_prefix

Helper method to encode zsets score prefix

src/storage/src/redis_multi.rs:547

↓ 3 callersMethodfind_applied_log_index

Binary search for log index corresponding to seqno (including seqno or earlier) seqno=0 (e.g., during compaction) returns 0

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

↓ 3 callersMethodflushdb

Remove all keys from the current database

src/storage/src/storage_impl.rs:723

↓ 3 callersMethodget_cf_applied

(&self, cf_id: usize)

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

↓ 3 callersFunctionget_global_error_logger

Get the global error logger instance

src/common/runtime/error_logging.rs:539

↓ 3 callersMethodget_leader

(&self)

src/raft/src/node.rs:54

↓ 3 callersMethodget_logindex_cf_tracker

Get logindex cf_tracker for specified instance

src/storage/src/storage.rs:555

↓ 3 callersMethodget_snapshot_builder

(&mut self)

src/raft/src/state_machine.rs:270

↓ 3 callersMethodgetrange

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

src/storage/src/storage_impl.rs:206

↓ 3 callersMethodhas_flag

(&self, flag: CmdFlags)

src/cmd/src/lib.rs:220

↓ 3 callersMethodindex_for

(&self, key: &str)

src/kstd/src/lock_mgr.rs:102

↓ 3 callersMethodinit

Restore applied/flushed state from each CF's SST

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

↓ 3 callersMethodinstall_snapshot

( &mut self, _rpc: InstallSnapshotRequest<KiwiTypeConfig>, _option: RPCOption, )

src/raft/src/network.rs:272

↓ 3 callersFunctionis_in_lex_range

Check if a member is within the lexicographical range

src/storage/src/redis_zsets.rs:2115

↓ 3 callersMethodis_leader

(&self)

src/raft/src/node.rs:48

↓ 3 callersMethodis_null

Check if this is a null value

src/resp/src/types.rs:225

↓ 3 callersMethodkey_etime_for_instance

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

src/storage/src/storage_impl.rs:31

↓ 3 callersFunctionlog_id_option_to_proto

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

src/raft/src/conversion.rs:70

↓ 3 callersMethodmodify_left_index

(&mut self, index: u64)

src/storage/src/format_list_meta_value.rs:79

↓ 3 callersFunctionpack_dir_to_vec

Pack a directory (checkpoint root) into a GNU tar archive in memory.

src/raft/src/snapshot_archive.rs:27

↓ 3 callersFunctionproto_binlog_to_binlog

( proto_binlog: Option<crate::raft_proto::Binlog>, )

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

↓ 3 callersFunctionproto_to_node

NodeConfig 转 KiwiNode

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

↓ 3 callersMethodput_opt

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

src/engine/src/rocksdb_engine.rs:61

↓ 3 callersMethodrecord_send_failure

Record send failure

src/common/runtime/metrics.rs:1101

↓ 3 callersFunctionreply_text

(client: &Client)

src/cmd/src/auth.rs:148

↓ 3 callersMethodreset

(&mut self)

src/net/src/buffer.rs:88

↓ 3 callersFunctionrestore_checkpoint_layout

Copy checkpoint layout from `checkpoint_root` into `target_db_path` (`0/`, `1/`, …). Uses atomic replacement pattern to avoid data loss: 1. Validate

src/storage/src/checkpoint.rs:194

↓ 3 callersMethodrestore_collector_states

Restore collector states for each Storage instance from snapshot metadata. `collectors[i]` receives the entries originally exported from instance `i`

src/storage/src/checkpoint.rs:81

↓ 3 callersFunctionrunning_under_sanitizer

These tests open a full RocksDB via `Storage::open`. RocksDB keeps process-lifetime allocations (block cache, table readers) that LeakSanitizer report

src/storage/src/storage.rs:654

↓ 3 callersMethodsend_request_with_timeout

Send a storage request with a custom timeout

src/common/runtime/message.rs:827

↓ 3 callersMethodset_append_log_fn

Inject the Raft append-log callback into every Redis instance, switching the storage into cluster mode.

src/storage/src/storage.rs:487

↓ 3 callersMethodset_cmd_name

(&self, name: &[u8])

src/client/src/lib.rs:96

↓ 3 callersMethodset_current_task_type

(&self, task_type: TaskType)

src/storage/src/storage.rs:268

↓ 3 callersMethodset_flushed_log_index

(&self, cf_id: usize, log_index: LogIndex, seqno: SequenceNumber)

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

↓ 3 callersMethodsismember

Check if member is a member of the set stored at key

src/storage/src/redis_sets.rs:269

↓ 3 callersMethodsize

Returns the length (in bytes) of the referenced data.

src/kstd/src/slice.rs:51

↓ 3 callersMethodtouch

(&mut self)

src/net/src/buffer.rs:80

↓ 3 callersMethodupdate_last_health_check

Update last health check timestamp

src/common/runtime/metrics.rs:1364

↓ 3 callersMethodwrite_opt

(&self, batch: WriteBatch, writeopts: &WriteOptions)

src/engine/src/rocksdb_engine.rs:77

↓ 3 callersMethodzremrangebylex

Remove all members in a sorted set within the given lexicographical range

src/storage/src/redis_zsets.rs:1493

↓ 3 callersMethodzremrangebyscore

Remove all members in a sorted set within the given scores

src/storage/src/redis_zsets.rs:1726

↓ 3 callersMethodzrevrange

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

src/storage/src/redis_zsets.rs:1829

↓ 2 callersMethodadd_compact_key_task_if_needed

( &self, dtype: DataType, key: &str, total: u64, duration: u64, )

src/storage/src/redis.rs:575

↓ 2 callersMethodadd_sub_cmd

(&mut self, cmd: Box<dyn Cmd>)

src/cmd/src/lib.rs:290

↓ 2 callersFunctionaggregate_scores

Aggregate scores based on the specified method

src/storage/src/redis_zsets.rs:2016

↓ 2 callersMethodappend_array_len

(&mut self, len: i64)

src/resp/src/encode.rs:311

↓ 2 callersMethodappend_bulk_string

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

src/resp/src/encode.rs:330

↓ 2 callersMethodas_string

Returns a string that contains the copy of the referenced data.

src/kstd/src/slice.rs:74

↓ 2 callersFunctionatomic_replace_file

( src: &std::path::Path, dst: &std::path::Path, )

src/raft/src/state_machine.rs:135

↓ 2 callersMethodavg_duration

(&self)

src/storage/src/statistics.rs:70

↓ 2 callersMethodbuild_resp2_hello_response

(&self)

src/resp/src/negotiation.rs:131

↓ 2 callersMethodcalculate_retry_delay

Calculate the delay for the next retry attempt using exponential backoff

src/common/runtime/message.rs:1076

↓ 2 callersFunctioncf_not_found_read

将 CF 不存在包装为读操作的 StorageError::IO

src/raft/src/log_store_rocksdb.rs:467

↓ 2 callersMethodcheck_arg

(&self, num: usize)

src/cmd/src/lib.rs:211

↓ 2 callersMethodclient_write

(&self, binlog: Binlog)

src/raft/src/node.rs:66

↓ 2 callersMethodclone

(&self)

src/engine/src/rocksdb_engine.rs:220

↓ 2 callersMethodconsume

Consume bytes from buffer

src/net/src/buffer.rs:401

↓ 2 callersMethodcreate_bytes_slice

Create a zero-copy slice from buffer

src/net/src/buffer.rs:214

↓ 2 callersMethodcreate_rocks_batch

Always build a direct RocksDB batch, bypassing cluster-mode routing. Used by the Raft apply path (on_binlog_write) to avoid recursive propose.

src/storage/src/redis.rs:463

↓ 2 callersFunctioncreate_test_db_without_cfs

Helper function to create a test database without column families

src/raft/src/log_store_rocksdb.rs:700

↓ 2 callersMethoddel

Delete a key

src/storage/src/redis_multi.rs:36

↓ 2 callersMethoddel

DEL command - delete one or more keys

src/net/src/storage_client.rs:107

↓ 2 callersMethoddel_key

Delete a key (works for all data types)

src/storage/src/redis_strings.rs:2127

↓ 2 callersMethoddelete

(&self, key: &[u8])

src/engine/src/rocksdb_engine.rs:65

↓ 2 callersMethoddelete_range_cf

( &'a self, cf: &ColumnFamilyRef<'a>, from: &[u8], to: &[u8], )

src/engine/src/rocksdb_engine.rs:129

↓ 2 callersMethodencode

(&self)

src/storage/src/format_strings_value.rs:51

↓ 2 callersMethodencode

(&self)

src/storage/src/format_list_meta_value.rs:91

↓ 2 callersMethodencode

(&self)

src/storage/src/format_member_data_key.rs:52

↓ 2 callersMethodencode

(&self)

src/storage/src/format_base_meta_value.rs:74

↓ 2 callersFunctionerror_response

(msg: String)

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

↓ 2 callersMethodexpire

EXPIRE command - set expiration time for a key

src/net/src/storage_client.rs:139

↓ 2 callersMethodflush_db

Flush all keys from the current database

src/storage/src/redis_strings.rs:2278

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