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

Methoddo_initial

(&self, client: &Client)

src/cmd/src/bitop.rs:53

Methoddo_initial

(&self, _client: &Client)

src/cmd/src/hget.rs:50

Methoddo_initial

(&self, _client: &Client)

src/cmd/src/hvals.rs:50

Methoddo_initial

(&self, client: &Client)

src/cmd/src/sscan.rs:50

Methoddo_initial

GETRANGE key start end

src/cmd/src/getrange.rs:51

Methoddo_initial

(&self, client: &Client)

src/cmd/src/incrbyfloat.rs:50

Methoddo_initial

(&self, client: &Client)

src/cmd/src/list.rs:55

Methoddo_initial

EXISTS key [key ...] Returns if key exists. Since Redis 3.0.3 it is possible to specify multiple keys instead of a single one. In such a case, it ret

src/cmd/src/exists.rs:58

Methoddo_initial

SET key value

src/cmd/src/set.rs:50

Methoddo_initial

(&self, client: &Client)

src/cmd/src/scard.rs:50

Methoddo_initial

(&self, _client: &Client)

src/cmd/src/hgetall.rs:50

Methoddo_initial

(&self, client: &Client)

src/cmd/src/zcount.rs:50

Methoddo_initial

(&self, client: &Client)

src/cmd/src/get.rs:49

Methoddo_initial

(&self, client: &Client)

src/cmd/src/sunion.rs:50

Methoddouble

(value: f64)

src/resp/src/types.rs:241

Methoddrop

(&mut self)

src/resp/src/parse.rs:509

Methoddrop

(&mut self)

src/storage/src/statistics.rs:139

Methoddrop

(&mut self)

src/storage/src/redis.rs:815

Methoddrop

(&mut self)

src/storage/src/storage.rs:117

Methoddrop

(&mut self)

src/engine/src/rocksdb_engine.rs:228

Methoddrop

(&mut self)

src/kstd/src/lock_mgr.rs:143

Methoddrop

(&mut self)

src/common/runtime/manager.rs:577

Methodempty

Returns true if the length of the referenced data is zero.

src/kstd/src/slice.rs:56

Methodencode_seek_key

Encode a seek key prefix for iteration

src/storage/src/format_member_data_key.rs:71

Functionenqueue

(client: redis.Redis, queue_name: str)

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

Methodeq

(&self, other: &Self)

src/storage/src/statistics.rs:35

Methoderror_boundary

Create an error boundary error

src/common/runtime/error.rs:119

Methodevaluate_channel_health

Evaluate channel health

src/common/runtime/metrics.rs:1847

Methodevaluate_component_health

Evaluate health of individual components

src/common/runtime/metrics.rs:1727

Methodevaluate_network_health

Evaluate network runtime health

src/common/runtime/metrics.rs:1748

Methodevaluate_storage_health

Evaluate storage runtime health

src/common/runtime/metrics.rs:1795

Methodexecute_background

Execute a low-priority command (for background operations)

src/net/src/storage_client.rs:362

Methodexecute_batch

Execute a batch of commands with optimized batching

src/net/src/storage_client.rs:283

Methodexecute_critical

Execute a high-priority command (for critical operations)

src/net/src/storage_client.rs:346

Methodexecute_pipelined

Execute commands with request pipelining support

src/net/src/storage_client.rs:312

Methodexecute_storage_command

Execute a storage command and return the result

src/common/runtime/storage_server.rs:577

Methodexecute_test_with_monitoring

Execute a test with timeout and memory tracking

tests/comprehensive_test_suite.rs:162

Methodexecute_with_priority

Execute a command with custom timeout and priority

src/net/src/storage_client.rs:266

Methodexecute_with_timeout

Execute a command with custom timeout

src/net/src/storage_client.rs:252

Methodexists

Check if one or more keys exist

src/storage/src/storage_impl.rs:647

Methodexpire

Set a key's time to live in seconds

src/storage/src/redis_multi.rs:155

Methodexpire

Set a timeout on key in seconds

src/storage/src/storage_impl.rs:541

Methodextract_batch_by_timeout

Extract batch when timeout is reached

src/common/runtime/storage_server.rs:712

Functionextract_command_from_data

Extract command from RESP data

src/net/src/network_handle.rs:204

Methodextract_data_version

(key: &[u8])

src/storage/src/data_compaction_filter.rs:118

Methodextract_optimized_batch

Extract optimized batch based on configuration

src/common/runtime/storage_server.rs:729

Methodfallback_to_resp2

Gracefully fallback to RESP2 if needed

src/resp/src/negotiation.rs:212

Methodfault_isolation

Create a fault isolation error

src/common/runtime/error.rs:127

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

src/resp/src/command.rs:336

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

src/resp/src/types.rs:274

Methodfmt

(&self, f: &mut fmt::Formatter<'_>)

src/conf/src/raft_type.rs:49

Methodfmt

(&self, f: &mut Formatter<'_>)

src/conf/src/config.rs:52

Methodfmt

(&self, f: &mut fmt::Formatter)

src/kstd/src/status.rs:62

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

src/common/runtime/error_logging.rs:57

Methodfmt

(&self, f: &mut std::fmt::Formatter<'_>)

src/common/runtime/message.rs:59

Methodforce_recovery

Force a recovery attempt

src/common/runtime/message.rs:1362

Functionfresh_client_is_unauthenticated_by_default

()

src/cmd/src/auth.rs:157

Methodfrom

(v: u8)

src/storage/src/format.rs:41

Methodfrom

(value: u8)

src/storage/src/storage.rs:43

Methodfrom

(resp: VoteResponse<u64>)

src/raft/src/conversion.rs:206

Methodfrom_arc

Create from an existing Arc<Storage>.

src/common/runtime/global_storage.rs:48

Methodfrom_config

Build StorageOptions from a loaded [`conf::config::Config`].

src/storage/src/options.rs:114

Methodfrom_enum_variant

(variant: Variant)

src/common/macro/src/error_variant.rs:37

Methodfrom_io_error

Create an IO error from std::io::Error

src/common/runtime/error.rs:199

Methodfrom_prefix

(byte: u8)

src/resp/src/types.rs:50

Methodfrom_slice

(key: &[u8])

src/storage/src/format_lists_data_key.rs:121

Methodfrom_status

从 tonic::Status 创建客户端错误

src/raft/src/grpc/error.rs:126

Methodfrom_storage_error

Create a storage error from storage::error::Error

src/common/runtime/error.rs:143

Methodfrom_str

(s: &str)

src/resp/src/command.rs:181

Methodfrom_str

(s: &str)

src/conf/src/config.rs:68

Methodfrom_u32

(v: u32)

src/conf/src/raft_type.rs:117

Methodfull_sample_config

Generate a complete sample configuration with all available keys, including Raft cluster settings and authentication.

src/conf/src/config.rs:721

Methodgenerate_test_key

Generate random key for testing

tests/comprehensive_test_suite.rs:223

Methodget_batch_stats

Get current batch statistics

src/common/runtime/storage_server.rs:894

Methodget_current_task_type

(&self)

src/storage/src/storage.rs:259

Methodget_health

Gets the health status of a component

src/common/runtime/health.rs:116

Methodget_index

Get database index

src/storage/src/redis.rs:360

Methodget_last_flush_index

(&self)

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

Methodget_log_reader

(&mut self)

src/raft/src/log_store_rocksdb.rs:432

Methodget_log_state

( &mut self, )

src/raft/src/log_store_rocksdb.rs:387

Methodget_manual_flushing_cf

Get the CF currently being manually flushed (for testing/debugging)

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

Methodget_memory_usage

Get current memory usage in MB (simplified implementation)

tests/comprehensive_test_suite.rs:205

Methodget_next_batch

Get the next batch of requests to process

src/common/runtime/storage_server.rs:696

Methodget_overall_health

Gets the overall health status of all components

src/common/runtime/health.rs:122

Methodget_properties_of_all_tables_cf

( &self, cf: &ColumnFamilyRef<'_>, )

src/engine/src/rocksdb_engine.rs:211

Methodget_readable_properties

(&self)

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

Methodget_rocksdb_block_based_table_options

(&self)

src/conf/src/config.rs:821

Methodget_smallest_applied_log_index

Get smallest applied log index across all CFs

src/storage/src/storage.rs:565

Methodget_stats

Get current background task statistics

src/common/runtime/storage_server.rs:1109

Methodget_sub_cmd

(&self, _cmd_name: &str)

src/cmd/src/lib.rs:232

Methodget_sub_cmd

(&self, cmd_name: &str)

src/cmd/src/lib.rs:338

Methodget_supported_dynamic_options

()

src/storage/src/options.rs:203

Methodget_ttl_milliseconds

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

src/storage/src/expiration_manager.rs:193

Methodget_type

(&self)

src/resp/src/types.rs:118

Methodgetbit

GETBIT key offset Returns the bit value at offset in the string value stored at key. When key does not exist, or the bit at offset does not exist, th

src/storage/src/redis_strings.rs:1550

Methodgetrange

Returns a substring of the string value stored at key. This command is compatible with Redis GETRANGE. The substring is determined by the start and e

src/storage/src/redis_strings.rs:228

Methodgetset

GETSET key value Atomically sets key to value and returns the old value stored at key. Returns an error when key exists but does not hold a string va

src/storage/src/redis_strings.rs:885

Methodhandle_batch_command

Handle BATCH command (execute multiple commands atomically)

src/common/runtime/storage_server.rs:1664

Functionhandle_command

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

src/net/src/handle.rs:89

Methodhandle_command_direct

Handle command directly (without pipeline)

src/net/src/optimized_handler.rs:317

← previous next →1,101–1,200 of 2,670, ranked by callers