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

src/cmd/src/hmget.rs:33

src/cmd/src/decrby.rs:34

src/cmd/src/zincrby.rs:33

src/cmd/src/hlen.rs:32

src/cmd/src/zrevrange.rs:32

src/cmd/src/ttl.rs:33

src/cmd/src/sadd.rs:33

src/cmd/src/sdiffstore.rs:33

src/cmd/src/zrevrank.rs:32

src/cmd/src/sismember.rs:33

src/cmd/src/zscore.rs:33

src/cmd/src/zrank.rs:32

src/cmd/src/zunionstore.rs:32

src/cmd/src/pexpire.rs:33

src/cmd/src/mget.rs:33

src/cmd/src/strlen.rs:33

src/cmd/src/zinterstore.rs:32

src/cmd/src/sdiff.rs:33

src/cmd/src/zcard.rs:33

src/cmd/src/flushall.rs:33

(provider: RequirepassProvider)

src/cmd/src/auth.rs:52

src/cmd/src/expire.rs:33

src/cmd/src/incr.rs:34

src/cmd/src/hdel.rs:32

src/cmd/src/hmset.rs:32

src/cmd/src/keys.rs:33

src/cmd/src/hincrby.rs:32

src/cmd/src/hsetnx.rs:32

src/cmd/src/pexpireat.rs:33

src/cmd/src/hstrlen.rs:32

src/cmd/src/sinter.rs:33

src/cmd/src/sunionstore.rs:33

src/cmd/src/type_cmd.rs:33

src/cmd/src/smembers.rs:33

src/cmd/src/psetex.rs:33

src/cmd/src/flushdb.rs:33

src/cmd/src/decr.rs:34

src/cmd/src/hkeys.rs:33

src/cmd/src/zlexcount.rs:33

src/cmd/src/persist.rs:33

src/cmd/src/getbit.rs:33

src/cmd/src/bitop.rs:36

src/cmd/src/hget.rs:33

src/cmd/src/hvals.rs:33

src/cmd/src/sscan.rs:33

src/cmd/src/getrange.rs:33

src/cmd/src/incrbyfloat.rs:34

src/cmd/src/list.rs:38

src/cmd/src/exists.rs:33

src/cmd/src/set.rs:33

src/cmd/src/scard.rs:33

src/cmd/src/hgetall.rs:33

src/cmd/src/zcount.rs:33

src/cmd/src/get.rs:33

src/cmd/src/sunion.rs:33

Creates a new `CmdExecutor` with a specified number of worker tasks

src/executor/src/executor.rs:61

src/executor/src/builder.rs:26

Create a new async RESP parser

src/net/src/async_resp_parser.rs:45

(capacity: usize, id: u64)

src/net/src/buffer.rs:71

(batch_id: u64)

src/net/src/pipeline.rs:74

(connection: T, id: u64)

src/net/src/pool.rs:61

Create a new NetworkServer with the given configuration Defaults to single-node mode.

src/net/src/network_server.rs:80

( config: OptimizedHandlerConfig, _storage: Arc<Storage>, _cmd_table: Arc<CmdTable>,

src/net/src/optimized_handler.rs:72

(stream: TcpStream)

src/net/src/tcp.rs:79

Create a new StorageClient wrapping the runtime client

src/net/src/storage_client.rs:43

(path: Option<String>, db_dir: Option<&str>)

src/net/src/unix.rs:36

创建新的内存日志存储

src/raft/src/log_store.rs:61

从已有的 RocksDB 引擎创建日志存储实例

src/raft/src/log_store_rocksdb.rs:344

Create a new state machine. Per-instance LogIndex collectors and cf_trackers are owned by the underlying Storage; snapshot build/install paths look t

src/raft/src/state_machine.rs:196

创建新的网络工厂

src/raft/src/network.rs:98

(app: Arc<RaftApp>)

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

(app: Arc<RaftApp>)

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

(raft: Raft<KiwiTypeConfig>)

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

Create a new pause controller with default state (not paused)

src/common/runtime/storage_server.rs:49

Creates a new health monitor

src/common/runtime/health.rs:68

Create a new GlobalStorage with the initial Storage instance.

src/common/runtime/global_storage.rs:41

Create a new correlation ID

src/common/runtime/error_logging.rs:46

Create a new metrics collector

src/common/runtime/metrics.rs:340

Create a new RuntimeManager with the given configuration

src/common/runtime/manager.rs:80

Creates a new fault isolation manager

src/common/runtime/fault_isolation.rs:46

Create a new unique request ID

src/common/runtime/message.rs:42

(target_mb: usize)

src/common/runtime/stress_tests.rs:74

(target_mb: usize)

tests/dual_runtime_stress_tests.rs:72

tests/raft_network_partition_tests.rs:41

Methodnew_client

(&mut self, target: NodeId, node: &Node)

src/raft/src/network.rs:132

Functionnew_client_group_cmd

src/cmd/src/group_client.rs:27

Methodnew_with_init

Create a new BufferManager and wait for initial population

src/net/src/buffer.rs:145

Methodnew_with_str

Creates a slice referring to the contents of a string.

src/kstd/src/slice.rs:38

Convenience constructors for RESP3 types

src/resp/src/types.rs:233

Methodon_flush_completed

(&self, info: &FlushJobInfo)

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

Functionopenraft_higher_vote_preserves_proto_discriminator

src/raft/src/conversion.rs:434

Functionopenraft_success_preserves_proto_success

src/raft/src/conversion.rs:444

Methodoverwrite_operation

每个线程尝试覆盖相同的键

tests/python/test_mset_concurrent.py:327

Functionpack_unpack_roundtrip

src/raft/src/snapshot_archive.rs:117

Methodparse_and_check

( value: &[u8], parse_fn: impl Fn(&[u8]) -> Result<T, crate::error::Error>,

src/storage/src/meta_compaction_filter.rs:68

Methodparse_array

src/resp/src/parse.rs:198

Methodparse_big_number

src/resp/src/parse.rs:265

Methodparse_boolean

src/resp/src/parse.rs:233

Methodparse_bulk_error

src/resp/src/parse.rs:272

Methodparse_bulk_string

src/resp/src/parse.rs:174

← previous next →1,401–1,500 of 2,670, ranked by callers