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

↓ 2 callersMethodflushall

Remove all keys from all databases

src/storage/src/storage_impl.rs:731

↓ 2 callersMethodget

Basic KV operations

src/engine/src/rocksdb_engine.rs:49

↓ 2 callersFunctionget_cf_handle

Get the column family handle from the handles vector. This function provides validated access to column family handles, ensuring the handle exists at

src/storage/src/batch.rs:175

↓ 2 callersMethodget_correlated_errors

Get errors by correlation ID

src/common/runtime/error_logging.rs:342

↓ 2 callersMethodget_global_smallest_flushed_log_index

Get smallest flushed log index across all instances This is the safe upper bound for Raft log purge - we can only purge logs that have been flushed in

src/storage/src/storage.rs:581

↓ 2 callersMethodget_metrics

Get current error metrics

src/common/runtime/error_logging.rs:332

↓ 2 callersMethodget_pending_flush_gap

max - min of all applied/flushed log indexes

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

↓ 2 callersMethodget_properties_of_all_tables_cf

( &self, cf_id: usize, )

src/raft/tests/logindex_integration.rs:129

↓ 2 callersMethodget_scan_start_point

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

src/storage/src/redis.rs:663

↓ 2 callersFunctionglob_match

Simple glob pattern matching Supports * (match any sequence) and ? (match single character)

src/storage/src/redis_sets.rs:2416

↓ 2 callersMethodhas_backpressure

Check if the channel is experiencing backpressure

src/common/runtime/message.rs:394

↓ 2 callersMethodhexists

Determine if a hash field exists

src/storage/src/redis_hashes.rs:131

↓ 2 callersMethodhlen

Get the number of fields in a hash

src/storage/src/redis_hashes.rs:248

↓ 2 callersMethodhll_count_registers

Calculate cardinality from HyperLogLog registers

src/storage/src/redis_hyperloglog.rs:338

↓ 2 callersMethodhll_merge_registers

Merge two HyperLogLog register sets

src/storage/src/redis_hyperloglog.rs:299

↓ 2 callersMethodincr

INCR command - increment a numeric value

src/net/src/storage_client.rs:167

↓ 2 callersFunctioninvalid_config

(message: String)

src/conf/src/config.rs:279

↓ 2 callersMethodis_authenticated

(&self)

src/client/src/lib.rs:126

↓ 2 callersMethodis_idle

(&self, idle_timeout: Duration)

src/net/src/pool.rs:73

↓ 2 callersMethodis_ignoring_tasks

(&self)

src/storage/src/storage.rs:282

↓ 2 callersFunctionis_tail_wildcard

requires: 1. pattern's length >= 2 2. tail character is '*' 3. other position's charactor cannot be *, ?, [,]

src/storage/src/util.rs:72

↓ 2 callersMethodkey_exists_live

Check if a key exists and is not expired (type-agnostic) This helper is used for MSETNX to check key existence without type validation, preventing WR

src/storage/src/redis_strings.rs:1402

↓ 2 callersMethodlen

(&self)

src/net/src/pipeline.rs:94

↓ 2 callersFunctionload_current_snapshot

( work_dir: &std::path::Path, )

src/raft/src/state_machine.rs:104

↓ 2 callersMethodmget

MGET key [key ...] Returns the values of all specified keys. For every key that does not hold a string value or does not exist, the special value nil

src/storage/src/redis_strings.rs:582

↓ 2 callersMethodmodify_right_index

(&mut self, index: u64)

src/storage/src/format_list_meta_value.rs:87

↓ 2 callersMethodmulti_lock

Acquire locks for multiple keys using a deterministic order to avoid deadlocks. Duplicate keys are ignored.

src/kstd/src/lock_mgr.rs:69

↓ 2 callersMethodname

(&self)

src/cmd/src/lib.rs:207

↓ 2 callersMethodok

()

src/conf/src/raft_type.rs:88

↓ 2 callersFunctionpack

(gen: u64, cf_id: u32)

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

↓ 2 callersFunctionparse_memory

(input: &str)

src/conf/src/de_func.rs:59

↓ 2 callersFunctionparse_redis_config

Parse Redis-style configuration file content Supports comments starting with # and empty lines

src/conf/src/de_func.rs:103

↓ 2 callersFunctionpersist_current_snapshot

( work_dir: &std::path::Path, meta: &SnapshotMeta<u64, KiwiNode>, bytes: &[u8], )

src/raft/src/state_machine.rs:65

↓ 2 callersMethodpopulate_initial_buffers

Populate pool with initial buffers

src/net/src/buffer.rs:308

↓ 2 callersFunctionprocess_connection

( client: Arc<Client>, storage: Arc<Storage>, cmd_table: Arc<CmdTable>, executor: Arc<CmdExecu

src/net/src/handle.rs:33

↓ 2 callersMethodpurge

Clean up outdated mappings after flush Strategy: keep at least one element <= smallest_applied_log_index to ensure correct lookup next flush. When th

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

↓ 2 callersMethodqueue_request_for_later

Queue a request for later processing when storage is unavailable

src/common/runtime/message.rs:1195

↓ 2 callersMethodrandomkey

Return a random key from the database

src/storage/src/storage_impl.rs:739

↓ 2 callersMethodread_committed

(&mut self)

src/raft/src/log_store.rs:105

↓ 2 callersMethodread_data

Read data into buffer, returning number of bytes read

src/net/src/buffer.rs:368

↓ 2 callersMethodread_vote

(&mut self)

src/raft/src/log_store.rs:114

↓ 2 callersMethodrecord_connection_established

Record a new network connection

src/common/runtime/metrics.rs:671

↓ 2 callersMethodrecord_send_failure

Update statistics when a send operation fails

src/common/runtime/message.rs:449

↓ 2 callersMethodrelease_resources

Internal method to release all resources. Called by both `close()` and `Drop::drop()` to avoid code duplication.

src/storage/src/storage.rs:146

↓ 2 callersMethodremove_expired

Remove expired requests from the queue

src/common/runtime/message.rs:581

↓ 2 callersMethodresume

Resume: allow new requests to proceed.

src/common/runtime/storage_server.rs:70

↓ 2 callersFunctionrpc_failed_network_error

(target: &str, last_error: Option<tonic::Status>)

src/raft/src/network.rs:73

↓ 2 callersMethodrpop_internal

Internal version of rpop without locking (used by rpoplpush)

src/storage/src/redis_lists.rs:370

↓ 2 callersMethodset_array_len

(&mut self, len: i64)

src/resp/src/encode.rs:197

↓ 2 callersMethodset_bulk_string_len

(&mut self, len: i64)

src/resp/src/encode.rs:192

↓ 2 callersMethodset_count_to_value

(&mut self)

src/storage/src/format_list_meta_value.rs:218

↓ 2 callersMethodset_ctime

(&mut self, ctime: u64)

src/storage/src/format_strings_value.rs:141

↓ 2 callersMethodset_ctime

(&mut self, ctime: u64)

src/storage/src/format_base_meta_value.rs:206

↓ 2 callersMethodset_etime

(&mut self, etime: u64)

src/storage/src/format_strings_value.rs:147

↓ 2 callersMethodset_etime

(&mut self, etime: u64)

src/storage/src/format_base_meta_value.rs:201

↓ 2 callersMethodset_ignore_tasks

(&self, ignore: bool)

src/storage/src/storage.rs:278

↓ 2 callersMethodset_options_cf

(&self, cf: &ColumnFamilyRef<'_>, options: &[(&str, &str)])

src/engine/src/rocksdb_engine.rs:85

↓ 2 callersMethodset_relative_etime

(&mut self, ttl: u64)

src/storage/src/format_base_value.rs:123

↓ 2 callersMethodshould_replace

Check if buffer has grown too large and should be replaced

src/net/src/buffer.rs:106

↓ 2 callersMethodsorted_indexes

(&self, keys: I)

src/kstd/src/lock_mgr.rs:109

↓ 2 callersMethodstart_cleanup_task

Start background cleanup task

src/net/src/buffer.rs:262

↓ 2 callersMethodswap

Swap to a new Storage instance atomically. Used during snapshot installation to switch to restored data. All clones of this GlobalStorage will see the

src/common/runtime/global_storage.rs:63

↓ 2 callersMethodtouch

(&mut self)

src/net/src/pool.rs:69

↓ 2 callersMethodtry_recovery_request

Try a single recovery request to test if storage is available

src/common/runtime/message.rs:1236

↓ 2 callersMethodttl

TTL command - get time to live for a key

src/net/src/storage_client.rs:155

↓ 2 callersFunctionunpack_cf_id

(packed: u64)

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

↓ 2 callersFunctionunpacked_checkpoint_root

Directory inside `unpack_tar_to_dir` output that contains `0/`, `1/`, … and `__raft_snapshot_meta`.

src/raft/src/snapshot_archive.rs:107

↓ 2 callersMethodupdate_channel_health

Update channel health

src/common/runtime/metrics.rs:1256

↓ 2 callersMethodupdate_network_health

Update network runtime health

src/common/runtime/metrics.rs:1240

↓ 2 callersMethodupdate_storage_health

Update storage runtime health

src/common/runtime/metrics.rs:1248

↓ 2 callersMethoduser_value_len

(&self)

src/storage/src/format_strings_value.rs:47

↓ 2 callersMethodwrite

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

src/net/src/tcp.rs:89

↓ 2 callersMethodzset_store_operation

Internal helper for ZINTERSTORE and ZUNIONSTORE This function performs all operations atomically in a single batch: 1. Collects members from source z

src/storage/src/redis_zsets.rs:1091

↓ 1 callersMethodadd

( &mut self, _key: &[u8], _value: &[u8], _entry_type: DBEntryType, seq

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

↓ 1 callersMethodadd_duration

(&mut self, duration: u64)

src/storage/src/statistics.rs:63

↓ 1 callersMethodadd_modify_count

(&mut self, count: u64)

src/storage/src/statistics.rs:100

↓ 1 callersMethodappend_big_number

(&mut self, value: &str)

src/resp/src/encode.rs:493

↓ 1 callersMethodappend_boolean

(&mut self, value: bool)

src/resp/src/encode.rs:471

↓ 1 callersMethodappend_bulk_error

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

src/resp/src/encode.rs:499

↓ 1 callersFunctionappend_dir_all_skip_lock

( builder: &mut tar::Builder<W>, dst_path: &str, src_path: &Path, )

src/raft/src/snapshot_archive.rs:37

↓ 1 callersMethodappend_double

(&mut self, value: f64)

src/resp/src/encode.rs:478

↓ 1 callersMethodappend_integer

(&mut self, value: i64)

src/resp/src/encode.rs:315

↓ 1 callersMethodappend_null

RESP3 specific methods

src/resp/src/encode.rs:466

↓ 1 callersMethodappend_string

(&mut self, value: &str)

src/resp/src/encode.rs:336

↓ 1 callersMethodappend_verbatim_string

(&mut self, format: &str, data: &[u8])

src/resp/src/encode.rs:506

↓ 1 callersMethodapply_binlog

Apply binlog to storage.

src/raft/src/state_machine.rs:227

↓ 1 callersMethodapply_pressure

(&mut self)

src/common/runtime/stress_tests.rs:81

↓ 1 callersMethodapply_pressure

(&mut self)

tests/dual_runtime_stress_tests.rs:79

↓ 1 callersFunctionarb_binlog

生成随机 Binlog 的策略

src/raft/src/log_store_rocksdb.rs:619

↓ 1 callersFunctionarb_binlog_entry

生成随机 BinlogEntry 的策略

src/raft/src/log_store_rocksdb.rs:603

↓ 1 callersFunctionarb_log_id

生成随机 LogId 的策略

src/raft/src/log_store_rocksdb.rs:583

↓ 1 callersFunctionarb_operate_type

生成随机 OperateType 的策略

src/raft/src/log_store_rocksdb.rs:594

↓ 1 callersMethodarc_swap

Get the underlying Arc<ArcSwap<Storage>> for passing to Raft. Raft needs Arc<ArcSwap<Storage>> for KiwiStateMachine.

src/common/runtime/global_storage.rs:69

↓ 1 callersMethodarg

(&self, index: usize)

src/resp/src/command.rs:512

↓ 1 callersMethodat

Returns the ith byte in the referenced data. REQUIRES: n < size()

src/kstd/src/slice.rs:62

↓ 1 callersFunctionauto_compact

(client: redis.Redis)

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

↓ 1 callersMethodauto_detect_version

Auto-detect and switch protocol version based on input

src/resp/src/parse.rs:99

↓ 1 callersMethodbenchmark_dual_runtime_latency

Benchmark dual runtime latency under load

benches/dual_runtime_performance_benchmark.rs:394

↓ 1 callersMethodbenchmark_dual_runtime_throughput

Benchmark dual runtime throughput

benches/dual_runtime_performance_benchmark.rs:252

↓ 1 callersMethodbenchmark_single_runtime_latency

Benchmark single runtime latency under load

benches/dual_runtime_performance_benchmark.rs:333

← previous next →401–500 of 2,670, ranked by callers