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 callersMethodbenchmark_single_runtime_throughput

Benchmark single runtime throughput (baseline)

benches/dual_runtime_performance_benchmark.rs:196

↓ 1 callersMethodbitop

(&self, operation: &str, dest_key: &[u8], src_keys: &[&[u8]])

src/storage/src/storage_impl.rs:267

↓ 1 callersMethodbitpos

( &self, key: &[u8], bit: i64, start: Option<i64>, end: Option<i64>,

src/storage/src/storage_impl.rs:254

↓ 1 callersMethodbuffered_bytes

Get the number of buffered bytes

src/net/src/async_resp_parser.rs:125

↓ 1 callersFunctionbuild_debug_fmt_impl

(enum_name: Ident, variants: Vec<ErrorVariant>)

src/common/macro/src/macro_stack_trace_debug.rs:55

↓ 1 callersFunctionbuild_debug_impl

(enum_name: Ident)

src/common/macro/src/macro_stack_trace_debug.rs:71

↓ 1 callersFunctionbuild_empty_set_meta_bytes

Build a valid Set meta bytes: layout: type(1) + count(8) + version(8) + reserve(16) + ctime(8) + etime(8)

src/storage/tests/redis_set_test.rs:33

↓ 1 callersFunctionbuild_raft_config

(config: &RaftConfig)

src/raft/src/node.rs:147

↓ 1 callersMethodbuild_resp3_hello_response

(&self)

src/resp/src/negotiation.rs:157

↓ 1 callersMethodcalculate_error_rates

Calculate error rates over different time windows

src/common/runtime/error_logging.rs:496

↓ 1 callersMethodcalculate_overall_health

Calculate overall system health based on component health

src/common/runtime/metrics.rs:1304

↓ 1 callersMethodcapture_stack_trace

Capture stack trace for debugging

src/common/runtime/error_logging.rs:398

↓ 1 callersMethodcategorize_error

Categorize an error based on its type

src/common/runtime/error_logging.rs:378

↓ 1 callersFunctioncf_index_to_usize

(cf_idx: ColumnFamilyIndex)

src/storage/src/batch.rs:153

↓ 1 callersFunctioncf_name_to_index

Convert CF name (bytes) to index

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

↓ 1 callersFunctioncf_not_found_write

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

src/raft/src/log_store_rocksdb.rs:456

↓ 1 callersMethodchange_membership

修改集群成员

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

↓ 1 callersMethodchannel_stats

Get channel statistics

src/common/runtime/message.rs:1111

↓ 1 callersMethodcheck_network_health

Check network runtime health

src/common/runtime/manager.rs:483

↓ 1 callersMethodcheck_set_count

(&self, count: usize)

src/storage/src/format_base_meta_value.rs:188

↓ 1 callersMethodcheck_storage_health

Check storage runtime health

src/common/runtime/manager.rs:500

↓ 1 callersFunctioncleanup

清理测试数据

tests/python/test_mset.py:364

↓ 1 callersMethodclone

(&self)

src/net/src/storage_client.rs:379

↓ 1 callersMethodclose

(&mut self)

src/executor/src/executor.rs:115

↓ 1 callersMethodcommit_batch_and_track_logindex

Commit a batch and record `(raft_log_index, seqno)` in the LogIndex collector. The seqno is captured via `latest_sequence_number()` *after* `commit()

src/storage/src/redis.rs:498

↓ 1 callersMethodcompact_range_cf

( &'a self, cf: &ColumnFamilyRef<'a>, start: Option<&[u8]>, end: Option<&[u8]>

src/engine/src/rocksdb_engine.rs:186

↓ 1 callersFunctionconvert_proto_entry

转换 Proto Entry 到 OpenRaft Entry

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

↓ 1 callersFunctioncopy_dir_all

(src: &Path, dst: &Path)

src/storage/src/checkpoint.rs:157

↓ 1 callersMethodcreate

( &mut self, _context: rocksdb::compaction_filter_factory::CompactionFilterContext, )

src/storage/src/meta_compaction_filter.rs:116

↓ 1 callersFunctioncreate_admin_service

创建 RaftAdminService 服务器

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

↓ 1 callersFunctioncreate_client_service

(app: Arc<RaftApp>)

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

↓ 1 callersFunctioncreate_core_service

创建 RaftCoreService 服务器

src/raft/src/grpc/core.rs:50

↓ 1 callersFunctioncreate_metrics_service

( app: Arc<RaftApp>, )

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

↓ 1 callersMethodcreate_network_runtime

Create the network runtime with optimized settings for I/O operations

src/common/runtime/manager.rs:451

↓ 1 callersFunctioncreate_raft_node

( config: RaftConfig, storage_swap: Arc<ArcSwap<Storage>>, pause_controller: Option<Arc<dyn PauseC

src/raft/src/node.rs:177

↓ 1 callersMethodcreate_storage_runtime

Create the storage runtime with optimized settings for CPU-intensive operations

src/common/runtime/manager.rs:467

↓ 1 callersFunctioncreate_test_components

()

src/net/src/network_handle.rs:498

↓ 1 callersFunctioncreate_test_runtime_config

Helper function to create a test RuntimeConfig

src/common/runtime/tests.rs:53

↓ 1 callersFunctioncreate_test_runtime_config

Helper function to create a test RuntimeConfig

src/common/runtime/additional_unit_tests.rs:62

↓ 1 callersFunctioncreate_test_runtime_config

Helper function to create a test RuntimeConfig

tests/dual_runtime_unit_tests.rs:62

↓ 1 callersFunctiondata_type_to_string

(data_type: DataType)

src/storage/src/format_base_value.rs:78

↓ 1 callersFunctiondata_type_to_tag

(data_type: DataType)

src/storage/src/format_base_value.rs:82

↓ 1 callersMethoddecr

DECR command - decrement a numeric value

src/net/src/storage_client.rs:195

↓ 1 callersMethoddecr_by

DECRBY command - decrement by a specific amount

src/net/src/storage_client.rs:207

↓ 1 callersFunctiondefault_network_pool_config

Default pool configuration for network server connection pooling

src/net/src/network_server.rs:36

↓ 1 callersFunctiondefault_pool_config

Default pool configuration for connection pooling

src/net/src/tcp.rs:39

↓ 1 callersMethoddequeue

Remove and return the next request from the queue

src/common/runtime/message.rs:565

↓ 1 callersMethoddo_append

追加日志条目到存储

src/raft/src/log_store_rocksdb.rs:107

↓ 1 callersMethoddo_cmd

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

src/cmd/src/lib.rs:316

↓ 1 callersMethoddo_compact_specific_key

(&self, _dtype: DataType, _key: &str)

src/storage/src/storage.rs:386

↓ 1 callersMethoddo_initial

DEL key [key ...] Removes the specified keys. A key is ignored if it does not exist. # Returns Integer reply: the number of keys that were removed

src/cmd/src/del.rs:56

↓ 1 callersMethoddo_initial

(&self, _client: &Client)

src/cmd/src/lib.rs:312

↓ 1 callersMethodencode

(&self)

src/storage/src/format_base_key.rs:50

↓ 1 callersMethodencode_hash_data_key

Helper method to encode hash data key

src/storage/src/redis_multi.rs:493

↓ 1 callersMethodencode_list_data_key

Helper method to encode list data key

src/storage/src/redis_multi.rs:520

↓ 1 callersMethodenqueue

Add a request to the queue

src/common/runtime/message.rs:540

↓ 1 callersMethodensure_meta_state

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

src/storage/src/data_compaction_filter.rs:151

↓ 1 callersMethoderror

(msg: impl Into<String>)

src/conf/src/raft_type.rs:96

↓ 1 callersMethodexecute

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

src/cmd/src/lib.rs:190

↓ 1 callersFunctionexecute_auth_command

Execute AUTH command asynchronously (doesn't require storage)

src/net/src/executor_ext.rs:446

↓ 1 callersMethodexecute_command

Execute a single command

src/net/src/pipeline.rs:314

↓ 1 callersFunctionexecute_decr_command

Execute DECR command asynchronously

src/net/src/executor_ext.rs:326

↓ 1 callersFunctionexecute_decrby_command

Execute DECRBY command asynchronously

src/net/src/executor_ext.rs:344

↓ 1 callersFunctionexecute_del_command

Execute DEL command asynchronously

src/net/src/executor_ext.rs:185

↓ 1 callersFunctionexecute_exists_command

Execute EXISTS command asynchronously

src/net/src/executor_ext.rs:203

↓ 1 callersFunctionexecute_expire_command

Execute EXPIRE command asynchronously

src/net/src/executor_ext.rs:221

↓ 1 callersFunctionexecute_get_command

Execute GET command asynchronously

src/net/src/executor_ext.rs:145

↓ 1 callersFunctionexecute_incr_command

Execute INCR command asynchronously

src/net/src/executor_ext.rs:274

↓ 1 callersFunctionexecute_incrby_command

Execute INCRBY command asynchronously

src/net/src/executor_ext.rs:292

↓ 1 callersFunctionexecute_mget_command

Execute MGET command asynchronously

src/net/src/executor_ext.rs:378

↓ 1 callersFunctionexecute_mset_command

Execute MSET command asynchronously

src/net/src/executor_ext.rs:396

↓ 1 callersMethodexecute_network

( &self, exec: NetworkCmdExecution, )

src/net/src/executor_ext.rs:46

↓ 1 callersFunctionexecute_ping_command

Execute PING command asynchronously (doesn't require storage)

src/net/src/executor_ext.rs:428

↓ 1 callersFunctionexecute_set_command

Execute SET command asynchronously

src/net/src/executor_ext.rs:163

↓ 1 callersFunctionexecute_ttl_command

Execute TTL command asynchronously

src/net/src/executor_ext.rs:256

↓ 1 callersMethodexpireat

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

src/storage/src/storage_impl.rs:587

↓ 1 callersMethodexport_metrics

Export error data for external monitoring systems

src/common/runtime/error_logging.rs:372

↓ 1 callersMethodextract_grouped_batch

Extract batch grouping compatible operations

src/common/runtime/storage_server.rs:772

↓ 1 callersMethodextract_priority_batch

Extract batch prioritizing high-priority requests

src/common/runtime/storage_server.rs:752

↓ 1 callersFunctionflatten_table

(table: &toml::Table, prefix: &str, lines: &mut Vec<(String, String)>)

src/conf/src/config.rs:757

↓ 1 callersMethodflush_all

Flush all keys from all databases (same as flush_db for single database)

src/storage/src/redis_strings.rs:2333

↓ 1 callersMethodge_seqno

Compare seqno with another pair

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

↓ 1 callersFunctiongenerate_performance_report

Generate performance report with recommendations

benches/performance_benchmark.rs:151

↓ 1 callersFunctiongenerate_storage_error_response

Enhanced error response generation for storage failures

src/net/src/network_handle.rs:403

↓ 1 callersMethodget_binary

Get the value of a key as bytes, preserving binary data

src/storage/src/redis_strings.rs:527

↓ 1 callersMethodget_fallback_response

Get a fallback response for certain commands when storage is unavailable

src/common/runtime/message.rs:1320

↓ 1 callersMethodget_pooled_resources

Get resources from pool or create new ones

src/net/src/optimized_handler.rs:113

↓ 1 callersMethodget_properties_of_all_tables_cf

( &self, cf_id: usize, )

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

↓ 1 callersMethodget_properties_of_all_tables_cf

( &self, cf_id: usize, )

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

↓ 1 callersMethodget_rocksdb_options

TODO: Due to API issues, the rocksdb_ttl_second parameter is temporarily missing

src/conf/src/config.rs:783

↓ 1 callersMethodget_ttl_seconds

Get remaining time to live for a key in seconds Returns: - Some(positive) if key exists and hasn't expired (TTL in seconds) - Some(-1) if key exists b

src/storage/src/expiration_manager.rs:173

↓ 1 callersMethodgetset

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

src/storage/src/storage_impl.rs:285

↓ 1 callersFunctionglob_match

Simple glob pattern matching for ZSCAN

src/storage/src/redis_zsets.rs:2044

↓ 1 callersMethodhandle_degraded_storage

Handle requests when storage is in degraded state

src/common/runtime/message.rs:1152

↓ 1 callersFunctionhandle_network_command

Handle a command using network-aware execution with StorageClient This function processes Redis commands by routing them through the StorageClient in

src/net/src/network_handle.rs:153

↓ 1 callersMethodhandle_storage_unavailable

Handle requests when storage is unavailable

src/common/runtime/message.rs:1116

↓ 1 callersMethodhas_efficient_batch_composition

Check if current batch has efficient composition for processing

src/common/runtime/storage_server.rs:875

↓ 1 callersMethodhas_high_priority_requests

Check if there are high priority requests that should be processed quickly

src/common/runtime/storage_server.rs:886

↓ 1 callersMethodhdel

Delete one or more hash fields

src/storage/src/redis_hashes.rs:37

↓ 1 callersMethodhealth_check

Perform health checks on both runtimes

src/common/runtime/manager.rs:330

← previous next →501–600 of 2,670, ranked by callers