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

Methodhandle_decr_command

Handle DECR command

src/common/runtime/storage_server.rs:1593

Methodhandle_decrby_command

Handle DECRBY command

src/common/runtime/storage_server.rs:1601

Methodhandle_del_command

Handle DEL command

src/common/runtime/storage_server.rs:1429

Methodhandle_exists_command

Handle EXISTS command

src/common/runtime/storage_server.rs:1452

Methodhandle_expire_command

Handle EXPIRE command

src/common/runtime/storage_server.rs:1476

Methodhandle_get_command

Handle GET command

src/common/runtime/storage_server.rs:1377

Methodhandle_health_check

Handle /health endpoint

src/common/runtime/metrics.rs:1643

Methodhandle_incr_command

Handle INCR command

src/common/runtime/storage_server.rs:1539

Methodhandle_incrby_command

Handle INCRBY command

src/common/runtime/storage_server.rs:1547

Methodhandle_liveness_check

Handle /live endpoint (liveness probe)

src/common/runtime/metrics.rs:1702

Methodhandle_mget_command

Handle MGET command

src/common/runtime/storage_server.rs:1634

Methodhandle_mset_command

Handle MSET command

src/common/runtime/storage_server.rs:1611

Methodhandle_readiness_check

Handle /ready endpoint (readiness probe)

src/common/runtime/metrics.rs:1678

Methodhandle_set_command

Handle SET command

src/common/runtime/storage_server.rs:1400

Methodhandle_ttl_command

Handle TTL command

src/common/runtime/storage_server.rs:1509

Methodhas_expiration

Check if a key has expiration set

src/storage/src/expiration_manager.rs:209

Methodhas_sub_command

(&self)

src/cmd/src/lib.rs:228

Methodhas_sub_command

(&self)

src/cmd/src/lib.rs:334

Methodhdel

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

src/storage/src/storage_impl.rs:311

Methodhealth_monitor

Get health monitor for health status updates

src/common/runtime/metrics.rs:441

Methodhexists

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

src/storage/src/storage_impl.rs:317

Methodhget

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

src/storage/src/storage_impl.rs:305

Methodhgetall

(&self, key: &[u8])

src/storage/src/storage_impl.rs:335

Methodhigh_throughput

Create a configuration optimized for high throughput

src/conf/src/runtime_config.rs:434

Methodhincrby

(&self, key: &[u8], field: &[u8], increment: i64)

src/storage/src/storage_impl.rs:365

Methodhincrbyfloat

(&self, key: &[u8], field: &[u8], increment: f64)

src/storage/src/storage_impl.rs:371

Methodhkeys

(&self, key: &[u8])

src/storage/src/storage_impl.rs:329

Methodhlen

(&self, key: &[u8])

src/storage/src/storage_impl.rs:323

Methodhmget

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

src/storage/src/storage_impl.rs:347

Methodhmset

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

src/storage/src/storage_impl.rs:353

Methodhscan

( &self, key: &[u8], cursor: u64, pattern: Option<&str>, count: Option

src/storage/src/storage_impl.rs:383

Methodhset

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

src/storage/src/storage_impl.rs:299

Methodhsetnx

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

src/storage/src/storage_impl.rs:359

Methodhstrlen

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

src/storage/src/storage_impl.rs:377

Methodhvals

(&self, key: &[u8])

src/storage/src/storage_impl.rs:341

Methodincr_decr

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

src/storage/src/redis_strings.rs:1251

Methodincr_decr_float

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

src/storage/src/redis_strings.rs:1318

Methodindex

(&self)

src/storage/src/format_lists_data_key.rs:213

Functioninit_global_error_logger

Initialize the global error logger

src/common/runtime/error_logging.rs:532

Methodinitial_meta_value

(&mut self)

src/storage/src/format_base_meta_value.rs:149

Methodinitialize

初始化集群

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

Methodinner

Get the underlying runtime client

src/net/src/storage_client.rs:50

Methodinner

Get the inner UUID

src/common/runtime/error_logging.rs:51

Methodinner

Get the inner UUID value

src/common/runtime/message.rs:47

Methodinner_mut

Get a mutable reference to the inner connection

src/net/src/pool.rs:101

Methodinstall_snapshot

( &mut self, meta: &SnapshotMeta<u64, KiwiNode>, snapshot: Box<std::io::Cursor<Vec<u8>

src/raft/src/state_machine.rs:288

Methodinstall_snapshot

安装快照 RPC # 当前状态 - 临时 workaround 此 RPC 尚未实现。当前实现消费整个流然后返回 `failed_precondition` 错误。 ## 已知问题 - 客户端会接收到 `failed_precondition` 错误，看起来像服务端不支持此 RPC - 但实际上

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

Functioninstall_snapshot_with_existing_data

()

src/raft/tests/snapshot_roundtrip_test.rs:121

Methodinvalidate

清除指定节点的连接缓存

src/raft/src/network.rs:111

Functionio_read_err

将任意错误包装为读操作的 StorageError::IO

src/raft/src/log_store_rocksdb.rs:448

Functionio_write_err

将任意错误包装为写操作的 StorageError::IO

src/raft/src/log_store_rocksdb.rs:440

Methodis_applied

Whether cur_log_index has been applied (less than applied)

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

Methodis_degraded

Check if the system is in a degraded state

src/common/runtime/message.rs:701

Functionis_dir

(path: P)

src/kstd/src/env.rs:25

Methodis_dynamic_cf_option

(key: &str)

src/storage/src/options.rs:199

Methodis_dynamic_db_option

(key: &str)

src/storage/src/options.rs:195

Methodis_empty

(&self)

src/kstd/src/lock_mgr.rs:160

Methodis_full

(&self, max_size: usize)

src/net/src/pipeline.rs:86

Methodis_healthy

Check if the server is healthy

src/net/src/network_server.rs:161

Methodis_healthy

Check if the storage client is healthy

src/net/src/storage_client.rs:55

Methodis_healthy

Check if the channel is healthy (not closed and within capacity)

src/common/runtime/message.rs:382

Methodis_isolated

Checks if a component is isolated

src/common/runtime/fault_isolation.rs:72

Methodis_leader

(&self)

src/raft/src/leader_gate.rs:37

Methodis_pending_flush

Whether there is a CF that needs flush (gap > 0)

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

Methodis_permanent_survival

(&self)

src/storage/src/format_base_value.rs:215

Methodis_pipelining

Check if parser is in pipelining mode

src/net/src/async_resp_parser.rs:107

Functionis_read_command

Check if a command is a read operation

src/net/src/network_handle.rs:270

Methodis_recoverable

Check if this error indicates a recoverable condition Storage errors are evaluated based on their content to distinguish between: - Recoverable: tran

src/common/runtime/error.rs:212

Methodis_resp3

(&self)

src/resp/src/encode.rs:183

Methodis_storage_available

Check if storage is currently available

src/common/runtime/message.rs:1356

Methodis_storage_error_recoverable

Check if a storage error is recoverable based on its type This provides a more accurate assessment than string matching

src/common/runtime/error.rs:149

Methodis_valid

(&self)

src/storage/src/format_list_meta_value.rs:240

Methodis_valid

(&self)

src/storage/src/format_base_meta_value.rs:184

Methodis_valid_cf_id

(cf_id: usize)

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

Functionis_write_command

Check if a command is a write operation

src/net/src/network_handle.rs:302

Methoditerator_opt

( &self, mode: IteratorMode, readopts: ReadOptions, )

src/engine/src/rocksdb_engine.rs:152

Methodkey

(&self)

src/storage/src/format_lists_data_key.rs:205

Methodkey

(&self)

src/storage/src/format_zset_score_key.rs:200

Methodkey

(&self)

src/storage/src/format_member_data_key.rs:136

Functionl1_checkpoint_roundtrip

()

src/storage/tests/checkpoint_test.rs:28

Methodleader

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

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

Methodleader_resp_addr

(&self)

src/raft/src/leader_gate.rs:40

Methodlifecycle

Create a lifecycle error

src/common/runtime/error.rs:94

Methodlindex

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

src/storage/src/storage_impl.rs:439

Methodlinsert

( &self, key: &[u8], before_or_after: BeforeOrAfter, pivot: &[u8], val

src/storage/src/storage_impl.rs:469

Functionlists_compare_prefix_then_version_then_index

()

src/storage/src/custom_comparator.rs:208

Functionlists_data_key_compare

(a: &[u8], b: &[u8])

src/storage/src/custom_comparator.rs:46

Methodllen

(&self, key: &[u8])

src/storage/src/storage_impl.rs:433

Methodlog_correlated_error

Log a correlated error (part of an error chain)

src/common/runtime/error_logging.rs:317

Methodlog_request_error

Log an error associated with a specific request

src/common/runtime/error_logging.rs:296

Methodlow_latency

Create a configuration optimized for low latency

src/conf/src/runtime_config.rs:468

Methodlpop

(&self, key: &[u8], count: Option<usize>)

src/storage/src/storage_impl.rs:421

Methodlpush

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

src/storage/src/storage_impl.rs:397

Methodlpushx

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

src/storage/src/storage_impl.rs:403

Methodlrange

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

src/storage/src/storage_impl.rs:445

Methodlrem

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

src/storage/src/storage_impl.rs:463

Methodlset

(&self, key: &[u8], index: i64, value: Vec<u8>)

src/storage/src/storage_impl.rs:451

Methodltrim

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

src/storage/src/storage_impl.rs:457

Functionmain

()

benches/performance_benchmark.rs:75

Functionmain

()

src/net/benches/network_benchmark.rs:27

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