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

↓ 1 callersMethodhgetall

Get all fields and values in a hash

src/storage/src/redis_hashes.rs:421

↓ 1 callersMethodhincrby

Increment the integer value of a hash field

src/storage/src/redis_hashes.rs:890

↓ 1 callersMethodhincrbyfloat

Increment the float value of a hash field

src/storage/src/redis_hashes.rs:1046

↓ 1 callersMethodhkeys

Get all the fields in a hash

src/storage/src/redis_hashes.rs:188

↓ 1 callersMethodhll_hash

Hash function for HyperLogLog

src/storage/src/redis_hyperloglog.rs:385

↓ 1 callersMethodhmget

Get multiple hash field values

src/storage/src/redis_hashes.rs:547

↓ 1 callersMethodhmset

Set multiple hash fields

src/storage/src/redis_hashes.rs:617

↓ 1 callersMethodhsetnx

Set field only if it doesn't exist

src/storage/src/redis_hashes.rs:765

↓ 1 callersMethodhstrlen

Get the length of a hash field value

src/storage/src/redis_hashes.rs:1205

↓ 1 callersMethodhvals

Get all values in a hash

src/storage/src/redis_hashes.rs:486

↓ 1 callersMethodid

Get the connection ID

src/net/src/pool.rs:106

↓ 1 callersMethodincr_by

INCRBY command - increment by a specific amount

src/net/src/storage_client.rs:179

↓ 1 callersMethodincr_decr_float

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

src/storage/src/storage_impl.rs:291

↓ 1 callersMethodinit_cf_tracker

Initialize cf_tracker from restored SST properties after snapshot install or from existing DB on startup

src/raft/src/state_machine.rs:216

↓ 1 callersMethodinit_cf_trackers

Initialize cf_tracker from SST properties for all instances This should be called after restoring a snapshot to reinitialize the cf_tracker with the

src/storage/src/storage.rs:600

↓ 1 callersFunctioninitialize_storage

(config: &Config)

src/server/src/main.rs:198

↓ 1 callersMethodinitialize_storage_components

Initialize storage components by extracting the receiver and creating the storage client This must be called before the storage server is started and

src/common/runtime/manager.rs:411

↓ 1 callersFunctioninitialize_storage_server

( request_receiver: tokio::sync::mpsc::Receiver<runtime::StorageRequest>, global_storage: GlobalStorag

src/server/src/main.rs:223

↓ 1 callersMethodis_available

Check if storage is available for requests

src/common/runtime/message.rs:709

↓ 1 callersFunctionis_blocking_command

Check if a command is blocking and should be processed immediately

src/net/src/network_handle.rs:262

↓ 1 callersMethodis_empty

Check if the batch is empty

src/net/src/async_resp_parser.rs:214

↓ 1 callersMethodis_empty

(&self)

src/net/src/pipeline.rs:98

↓ 1 callersMethodis_flush_pending

Whether manual flush is needed (queue length >= max_gap)

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

↓ 1 callersMethodis_idle

(&self, max_idle_time: Duration)

src/net/src/buffer.rs:84

↓ 1 callersMethodis_locked

Returns `true` if the guard currently owns a lock.

src/kstd/src/lock_mgr.rs:131

↓ 1 callersMethodis_partitioned

(&self)

src/common/runtime/stress_tests.rs:115

↓ 1 callersMethodis_partitioned

(&self)

tests/dual_runtime_stress_tests.rs:113

↓ 1 callersMethodis_running

Check if the RuntimeManager is running

src/common/runtime/manager.rs:282

↓ 1 callersMethodis_stale

(&self)

src/storage/src/format_base_value.rs:219

↓ 1 callersMethoditerator

Iterator operations

src/engine/src/rocksdb_engine.rs:148

↓ 1 callersMethodkey_etime

(&self, key: &[u8])

src/storage/src/redis_strings.rs:35

↓ 1 callersMethodkey_type

Get the data type of a key

src/storage/src/storage_impl.rs:671

↓ 1 callersFunctionleader_id_to_proto

(lid: &LeaderId<u64>)

src/raft/src/conversion.rs:37

↓ 1 callersMethodleader_resp_addr

(&self)

src/raft/src/node.rs:98

↓ 1 callersFunctionlists_data_key_comparator_name

()

src/storage/src/custom_comparator.rs:25

↓ 1 callersFunctionlog_id_to_proto

(lid: &LogId<u64>)

src/raft/src/conversion.rs:58

↓ 1 callersMethodlog_structured

Perform structured JSON logging

src/common/runtime/error_logging.rs:439

↓ 1 callersMethodlog_traditional

Perform traditional text-based logging

src/common/runtime/error_logging.rs:456

↓ 1 callersFunctionmain

()

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

↓ 1 callersFunctionmatch_recursive

(pattern: &[char], text: &[char], p_idx: usize, t_idx: usize)

src/storage/src/redis_sets.rs:2420

↓ 1 callersMethodmaterialize

(&mut self)

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

↓ 1 callersMethodmin_meta_raw_len

(self)

src/storage/src/format_base_value.rs:42

↓ 1 callersMethodmodify_count

(&mut self, delta: u64)

src/storage/src/format_list_meta_value.rs:253

↓ 1 callersMethodmodify_count

(&mut self, delta: u64)

src/storage/src/format_base_meta_value.rs:215

↓ 1 callersMethodmset

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

src/storage/src/storage_impl.rs:98

↓ 1 callersMethodmsetnx

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

src/storage/src/storage_impl.rs:131

↓ 1 callersFunctionparse_config_line

Parse a single configuration line Supports both "key value" and "key=value" formats

src/conf/src/de_func.rs:135

↓ 1 callersMethodparse_meta_value

(&self, value: &[u8])

src/storage/src/data_compaction_filter.rs:129

↓ 1 callersMethodpause_notify_arc

Get the pause notify Arc (for StorageServer initialization)

src/common/runtime/storage_server.rs:87

↓ 1 callersMethodpaused_arc

Get the paused flag Arc (for StorageServer initialization)

src/common/runtime/storage_server.rs:77

↓ 1 callersMethodpending_count_arc

Get the pending count Arc (for StorageServer initialization)

src/common/runtime/storage_server.rs:82

↓ 1 callersMethodpending_requests

Get the current number of pending requests in the channel

src/common/runtime/message.rs:387

↓ 1 callersMethodpersist

Remove the expiration from a key

src/storage/src/storage_impl.rs:625

↓ 1 callersMethodpexpire

Set a timeout on key in milliseconds

src/storage/src/storage_impl.rs:563

↓ 1 callersMethodpexpireat

Set the expiration for a key as a UNIX timestamp in milliseconds

src/storage/src/storage_impl.rs:605

↓ 1 callersMethodpool_stats

Get connection pool statistics

src/net/src/network_server.rs:156

↓ 1 callersFunctionprint_comprehensive_results

Print comprehensive benchmark results

benches/performance_benchmark.rs:111

↓ 1 callersMethodprocess_buffer

(&mut self)

src/resp/src/parse.rs:449

↓ 1 callersFunctionprocess_connection_with_storage_client

Process connection using StorageClient for dual runtime architecture This function provides an updated version of process_connection that works with

src/net/src/handle.rs:127

↓ 1 callersFunctionprocess_network_connection

Process a network connection using StorageClient for storage operations This function replaces the original process_connection to work with the dual

src/net/src/network_handle.rs:47

↓ 1 callersMethodprocess_queued_requests

Process queued requests when storage becomes available

src/common/runtime/message.rs:1249

↓ 1 callersMethodprocess_with_pipeline

Process connection with pipeline optimization

src/net/src/optimized_handler.rs:144

↓ 1 callersMethodprocess_without_pipeline

Process connection without pipeline (fallback)

src/net/src/optimized_handler.rs:233

↓ 1 callersMethodproperty_int_value

(&self, property: &str)

src/engine/src/rocksdb_engine.rs:89

↓ 1 callersFunctionproto_to_committed_leader_id

(lid: &Option<&proto::LeaderId>)

src/raft/src/conversion.rs:44

↓ 1 callersMethodrandom_key

Get a random key from the database

src/storage/src/redis_strings.rs:2338

↓ 1 callersMethodread

( &self, request: Request<ReadRequest>, )

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

↓ 1 callersMethodrebuild_grouped_requests

Rebuild grouped requests after priority sorting

src/common/runtime/storage_server.rs:814

↓ 1 callersMethodrecord_backpressure_event

Record backpressure event

src/common/runtime/metrics.rs:901

↓ 1 callersMethodrecord_batch_processed

Record batch processing

src/common/runtime/metrics.rs:893

↓ 1 callersMethodrecord_bytes_received

Record bytes received

src/common/runtime/metrics.rs:700

↓ 1 callersMethodrecord_bytes_sent

Record bytes sent

src/common/runtime/metrics.rs:706

↓ 1 callersMethodrecord_correlation

Record request/response correlation

src/common/runtime/metrics.rs:1073

↓ 1 callersMethodrecord_message_received

Record a message received

src/common/runtime/metrics.rs:1046

↓ 1 callersMethodrecord_message_sent

Record a message sent

src/common/runtime/metrics.rs:1039

↓ 1 callersMethodrecord_operation_failure

Record a failed storage operation

src/common/runtime/metrics.rs:827

↓ 1 callersMethodrecord_operation_started

Record a storage operation started

src/common/runtime/metrics.rs:811

↓ 1 callersMethodrecord_operation_success

Record a successful storage operation

src/common/runtime/metrics.rs:816

↓ 1 callersMethodrecord_request_failure

Record a failed request

src/common/runtime/metrics.rs:690

↓ 1 callersMethodrecord_request_success

Record a successful request

src/common/runtime/metrics.rs:681

↓ 1 callersMethodrecord_timeout

Update statistics when a request times out

src/common/runtime/message.rs:442

↓ 1 callersMethodrelease_pressure

(&mut self)

src/common/runtime/stress_tests.rs:89

↓ 1 callersMethodrelease_pressure

(&mut self)

tests/dual_runtime_stress_tests.rs:87

↓ 1 callersMethodremove_expiration

Remove expiration for a key (make it persistent)

src/storage/src/expiration_manager.rs:151

↓ 1 callersMethodrequest_pause

Request pause: wait for all pending requests to complete.

src/common/runtime/storage_server.rs:58

↓ 1 callersFunctionrun_standalone_tests

独立运行所有测试（不使用 pytest）

tests/python/test_mset.py:194

↓ 1 callersMethodrun_with_batching

Run the server with batching enabled

src/common/runtime/storage_server.rs:276

↓ 1 callersMethodrun_without_batching

Run the server without batching (process requests individually)

src/common/runtime/storage_server.rs:322

↓ 1 callersMethodsave_committed

( &mut self, committed: Option<LogId<u64>>, )

src/raft/src/log_store.rs:97

↓ 1 callersMethodsave_vote

(&mut self, vote: &Vote<u64>)

src/raft/src/log_store.rs:109

↓ 1 callersMethodscan_keys

Scan for keys matching a pattern

src/storage/src/redis_strings.rs:2215

↓ 1 callersMethodsdiffstore

Store the difference between the first set and all the successive sets into a destination key

src/storage/src/redis_sets.rs:2145

↓ 1 callersMethodset

Set key to hold the string value

src/storage/src/redis_strings.rs:667

↓ 1 callersMethodset

SET command - set a key-value pair with optional TTL

src/net/src/storage_client.rs:84

↓ 1 callersMethodset_append_log_fn

Inject the Raft append-log callback, switching this instance to cluster mode. Idempotent: subsequent calls are ignored (OnceLock semantics).

src/storage/src/redis.rs:426

↓ 1 callersMethodset_applied_log_index

Set applied_index for a specific CF (used during snapshot restore)

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

↓ 1 callersMethodset_count

(&mut self, count: u64)

src/storage/src/format_base_meta_value.rs:196

↓ 1 callersMethodset_count_to_value

(&mut self)

src/storage/src/format_base_meta_value.rs:177

↓ 1 callersMethodset_ctime

(&mut self, ctime: u64)

src/storage/src/format_list_meta_value.rs:263

↓ 1 callersMethodset_ctime_to_value

(&mut self)

src/storage/src/format_strings_value.rs:153

← previous next →601–700 of 2,670, ranked by callers