Categorygithub.com/coderushing/tidbstoretikvtikvrpc
package
2.1.0-rc.2+incompatible
Repository: https://github.com/coderushing/tidb.git
Documentation: pkg.go.dev
Overview
Versions
2
Dependencies
10
Dependents
0
Files
508 SLOC

# Functions

CallRPC launches a rpc call.
CheckStreamTimeoutLoop runs periodically to check is there any stream request timeouted.
GenRegionErrorResp returns corresponding Response with specified RegionError according to the given req.
SetContext set the Context field for the given req to the specified ctx.

# Constants

CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.
CmdType values.

# Structs

CopStreamResponse combinates tikvpb.Tikv_CoprocessorStreamClient and the first Recv() result together.
Lease is used to implement grpc stream timeout.
Request wraps all kv/coprocessor requests.
Response wraps all kv/coprocessor responses.

# Type aliases

CmdType represents the concrete request type in Request or response type in Response.