testutils

package

v2.0.0-...-5317c89 Latest Latest Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var BootstrapWithMultiRegions = mocktikv.BootstrapWithMultiRegions

BootstrapWithMultiRegions initializes a Cluster with multiple Regions and 1 Store. The number of Regions will be len(splitKeys) + 1.

View Source

var BootstrapWithMultiStores = mocktikv.BootstrapWithMultiStores

BootstrapWithMultiStores initializes a Cluster with 1 Region and n Stores.

View Source

var BootstrapWithSingleStore = mocktikv.BootstrapWithSingleStore

BootstrapWithSingleStore initializes a Cluster with 1 Region and 1 Store.

func NewMockTiKV(path string, coprHandler CoprRPCHandler) (*MockClient, *MockCluster, pd.Client, error)

NewMockTiKV creates a TiKV client and PD client from options.

type Cluster = cluster.Cluster

Cluster simulates a TiKV cluster.

type CoprRPCHandler = mocktikv.CoprRPCHandler

CoprRPCHandler is the interface to handle coprocessor RPC commands.

type ErrLocked = mocktikv.ErrLocked

ErrLocked is returned when trying to Read/Write on a locked key. Client should backoff or cleanup the lock then retry.

type MVCCPair = mocktikv.Pair

MVCCPair is a KV pair read from MvccStore or an error if any occurs.

type MVCCStore = mocktikv.MVCCStore

MVCCStore is a mvcc key-value storage.

type MockClient = mocktikv.RPCClient

MockClient sends kv RPC calls to mock cluster.

type MockCluster = mocktikv.Cluster

MockCluster simulates a TiKV cluster.

type RPCSession = mocktikv.Session

RPCSession stores session scope rpc data.