# Functions
IsShardUnavailableErr is ShardUnavailableErr error.
NewLogReader creates and returns a new LogReader instance.
NewShardUnavailableErr returns a wrapped error that the shard is unavailable.
NewResourceAdapterWithShard create a prophet resource use shard.
NewSingleTestClusterStore create test cluster with 1 node.
NewStore returns a raft store.
NewTestClusterStore create test cluster using options.
NewTestDataBuilder create and return TestDataBuilder.
WithAppendTestClusterAdjustConfigFunc adjust config.
WithDataStorageOption set options to create data storage.
WithEnableTestParallel enable parallel testing.
WithTestClusterDataPath set data data storage directory.
WithTestClusterDisableSchedule disable pd schedule.
WithTestClusterEnableAdvertiseAddr set data data storage directory.
WithTestClusterLogLevel set raftstore log level.
WithTestClusterNodeCount set node count of test cluster.
WithTestClusterNodeStartFunc custom node start func.
WithTestClusterRecreate if true, the test cluster will clean and recreate the data dir.
WithTestClusterStoreFactory custom create raftstore factory.
WithTestClusterUseDisk use disk storage for testing.
WithTestClusterUseInitProphetCluster set using init prophet cluster config.
# Variables
DisableScheduleTestCluster disable prophet schedulers test raft store.
DiskTestCluster using pebble storage test raft store.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
ErrTimeout timeout error.
ErrUnknownReplica indicates that the replica is unknown.
NewTestCluster clean data before test cluster start.
NoCleanTestCluster using exists data before test cluster start.
SingleTestCluster single test raft cluster.
# Structs
ErrTryAgain indicates that an operation should retry later.
LogReader is the struct used to manage logs that have already been persisted into LogDB.
ShardUnavailableErr is a error that the shard is unavailable.
TestDataBuilder build test data.
# Interfaces
RetryController retry controller.
Router route the request to the corresponding shard.
ShardsPool is a shards pool, it will always create shards until the number of available shards reaches the value specified by `capacity`, we called these `Idle Shards`.
ShardsProxy Shards proxy, distribute the appropriate request to the corresponding backend, retry the request for the error.
Store manage a set of raft group.
TestKVClient is a kv client that uses `TestRaftCluster` as Backend's KV storage engine.
TestRaftCluster is the test cluster is used to test starting N nodes in a process, and to provide the start and stop capabilities of a single node, which is used to test `raftstore` more easily.
# Type aliases
No description provided by the author
FailureCallback request failure callback.
No description provided by the author
alias are provided for two most commonly used types.
SuccessCallback request success callback.
TestClusterOption is the option for create TestCluster.