Functions — github.com/arana-db/kiwi

CodeHub MCPcopy Create free account

hub / github.com/arana-db/kiwi / functions

Functions2,670 in github.com/arana-db/kiwi

⨍ Functions 2,670◇ Types & classes 421

Functionauth_without_requirepass_returns_error

src/cmd/src/auth.rs:190

Methodbackpressure_config

Get the backpressure configuration

src/common/runtime/message.rs:401

Methodbegin_receiving_snapshot

src/raft/src/state_machine.rs:282

Methodbg_task_worker

usage: let mut storage = Storage::new(...); let receiver = storage.open(...)?; let storage = Arc::new(storage); tokio::spawn(Storage::bg_task_worker(s

src/storage/src/storage.rs:291

Methodbig_number

src/resp/src/types.rs:245

BITCOUNT key [start end] Count the number of set bits (population counting) in a string. By default all the bytes contained in the string are examine

src/storage/src/redis_strings.rs:1630

BITOP operation destkey key [key ...] Perform bitwise operations between strings. # Arguments `operation` - The bitwise operation to perform (AND, O

src/storage/src/redis_strings.rs:1873

BITPOS key bit [start] [end] [BYTE | BIT] Return the position of the first bit set to 1 or 0 in a string. The position is returned, thinking of the s

src/storage/src/redis_strings.rs:1727

src/resp/src/types.rs:237

Methodbuffer_size

Get the buffer size of the channel

src/common/runtime/message.rs:372

Methodbuild_meta_key

build meta key from data key ## data_key format ```text | reserve1 | encoded_key | version | Data / index | reserve2 | | 8B | N B | 8

src/storage/src/data_compaction_filter.rs:92

Methodbulk_error

src/resp/src/types.rs:249

src/kstd/src/status.rs:47

Methodbyte_size

size of self in bytes

src/storage/src/coding.rs:24

Functioncalculate_benchmark_results

Calculate benchmark results from latency data

benches/performance_benchmark.rs:210

Methodcalculate_performance_results

Calculate performance results from latency data

src/net/tests/performance_tests.rs:428

Methodcalculate_storage_stats

Calculate storage statistics based on the command and result

src/common/runtime/storage_server.rs:484

Methodcan_communicate

检查两个节点是否可以通信

tests/raft_network_partition_tests.rs:62

Functioncf_name_str_to_index

Convert CF name (&str) to index

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

Create a channel communication error

src/common/runtime/error.rs:79

Methodchannel_size

(mut self, channel_size: usize)

src/executor/src/builder.rs:38

Methodchannel_tracker

Get channel metrics tracker for recording channel events

src/common/runtime/metrics.rs:436

Methodcheck_compaction_needed

Check if compaction is needed based on various metrics

src/common/runtime/storage_server.rs:1292

Methodcheck_flush_status

Check flush status for a storage instance

src/common/runtime/storage_server.rs:1317

Methodcheck_parallel_safety

Check if commands in batch can be executed in parallel

src/net/src/async_resp_parser.rs:173

Methodcircuit_breaker_open

Create a circuit breaker error

src/common/runtime/error.rs:104

Methodclassify_operation

(command: &StorageCommand)

src/common/runtime/storage_server.rs:822

Methodcleanup_old_data

Clear old error data (for memory management)

src/common/runtime/error_logging.rs:351

Functioncleanup_test_environment

(mut manager: RuntimeManager)

src/common/runtime/tests.rs:555

Functioncleanup_test_environment

(mut manager: RuntimeManager)

src/common/runtime/additional_unit_tests.rs:576

Functioncleanup_test_environment

Helper to clean up test environment

tests/dual_runtime_unit_tests.rs:520

Methodclear_all

清除所有连接缓存

src/raft/src/network.rs:117

Methodclient_capabilities

src/resp/src/negotiation.rs:52

Methodcollect_rocksdb_stats

Collect comprehensive RocksDB statistics

src/common/runtime/storage_server.rs:1326

Methodcollect_statistics

Collect storage statistics

src/common/runtime/storage_server.rs:1231

Functioncompact

(client: redis.Redis, queue_name: str)

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

Compact buffer by moving unread data to beginning

src/net/src/buffer.rs:426

Methodcompact_all

use for admin command and cron job

src/storage/src/storage.rs:337

Methodcompact_range

Compact database range

src/storage/src/redis.rs:379

Methodcompact_range

use for admin command

src/storage/src/storage.rs:356

Methodcompact_range

(&self, start: Option<&[u8]>, end: Option<&[u8]>)

src/engine/src/rocksdb_engine.rs:182

Get health check configuration

src/common/runtime/metrics.rs:1913

Get the current configuration

src/common/runtime/manager.rs:394

Methodconfiguration

Create a configuration error

src/common/runtime/error.rs:89

Methodconvert_to_resp2

Convert RESP3 data to RESP2 compatible format for fallback

src/resp/src/negotiation.rs:219

Methodcopy_data

Efficiently copy data between buffers

src/net/src/buffer.rs:228

Functioncorrect_password_authenticates_and_replies_ok

src/cmd/src/auth.rs:178

src/storage/src/batch.rs:215

src/storage/src/format_base_meta_value.rs:192

Methodcount_byte

(&self, byte: u8)

src/kstd/src/slice.rs:101

(&mut self, _context: TablePropertiesCollectorContext)

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

Methodcreate_cf_options

Helper function: create column-family options

src/storage/src/redis.rs:289

Methodcreate_checkpoint

Export all DB instances to `checkpoint_root/<i>/` and write `__raft_snapshot_meta`.

src/storage/src/storage.rs:408

Methodcreate_checkpoint

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

src/engine/src/rocksdb_engine.rs:200

Methodcreate_grpc_services

( app: Arc<RaftApp>, )

src/raft/src/node.rs:76

Methodcreate_legacy_server

Create a legacy server without dual runtime architecture (for backward compatibility)

src/net/src/lib.rs:87

Methodcreate_network_server

Create a NetworkServer with dual runtime architecture

src/net/src/lib.rs:115

Methodcreate_server

( protocol: &str, addr: Option<String>, runtime_manager: &RuntimeManager, requ

src/net/src/lib.rs:55

Methodcreate_status

(code: Code, msg: Option<&str>)

src/kstd/src/status.rs:51

Methodcreate_test_data

Create test data of specified size

tests/comprehensive_test_suite.rs:218

Functioncreate_test_environment

src/common/runtime/tests.rs:547

Functioncreate_test_environment

src/common/runtime/additional_unit_tests.rs:568

Functioncreate_test_environment

Helper to create a minimal test environment

tests/dual_runtime_unit_tests.rs:513

Functioncreate_test_message_channel

src/common/runtime/tests.rs:67

Functioncreate_test_message_channel

src/common/runtime/additional_unit_tests.rs:76

Functioncreate_test_message_channel

Helper function to create a test MessageChannel

tests/dual_runtime_unit_tests.rs:72

Methodcurrent_version

src/resp/src/negotiation.rs:48

Functioncursor_snapshot_roundtrip

src/raft/tests/snapshot_roundtrip_test.rs:38

Returns a pointer to the beginning of the referenced data.

src/kstd/src/slice.rs:46

Methoddata_type

src/storage/src/format_base_value.rs:231

src/engine/src/rocksdb_engine.rs:38

Get db_id from current Storage.

src/common/runtime/global_storage.rs:79

Methoddb_instance_num

Get db_instance_num from current Storage.

src/common/runtime/global_storage.rs:74

Methoddeactivate_isolation

Deactivates fault isolation for a component

src/common/runtime/fault_isolation.rs:65

src/storage/src/format.rs:89

(encoded_key: &[u8], key_str: &mut BytesMut)

src/storage/src/format_base_key.rs:75

src/storage/src/format_lists_data_key.rs:125

benches/performance_benchmark.rs:63

benches/dual_runtime_performance_benchmark.rs:72

src/resp/src/parse.rs:61

src/resp/src/types.rs:112

src/resp/src/negotiation.rs:35

src/resp/src/encode.rs:160

src/conf/src/config.rs:226

src/conf/src/runtime_config.rs:74

src/storage/src/statistics.rs:110

src/storage/src/slot_indexer.rs:31

src/storage/src/options.rs:80

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

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

src/kstd/src/slice.rs:26

src/cmd/src/auth.rs:37

src/executor/src/builder.rs:49

src/net/src/buffer.rs:45

src/net/src/pipeline.rs:44

src/net/src/pool.rs:39

src/net/src/optimized_handler.rs:45

src/net/tests/performance_tests.rs:50

src/raft/src/network.rs:53

src/raft/src/node.rs:127

← previous next →801–900 of 2,670, ranked by callers