Versions in this module Expand all Collapse all v1 v1.0.0 May 30, 2020 Changes in this version + func CheckStreamTimeoutLoop(ch <-chan *Lease) + func SetContext(req *Request, region *metapb.Region, peer *metapb.Peer) error + type CmdType uint16 + const CmdBatchGet + const CmdBatchRollback + const CmdCleanup + const CmdCommit + const CmdCop + const CmdCopStream + const CmdDeleteRange + const CmdGC + const CmdGet + const CmdMvccGetByKey + const CmdMvccGetByStartTs + const CmdPrewrite + const CmdRawBatchDelete + const CmdRawBatchGet + const CmdRawBatchPut + const CmdRawDelete + const CmdRawDeleteRange + const CmdRawGet + const CmdRawPut + const CmdRawScan + const CmdResolveLock + const CmdScan + const CmdScanLock + const CmdSplitRegion + const CmdUnsafeDestroyRange + func (t CmdType) String() string + type CopStreamResponse struct + Timeout time.Duration + func (resp *CopStreamResponse) Close() + func (resp *CopStreamResponse) Recv() (*coprocessor.Response, error) + type Lease struct + Cancel context.CancelFunc + type Request struct + BatchGet *kvrpcpb.BatchGetRequest + BatchRollback *kvrpcpb.BatchRollbackRequest + Cleanup *kvrpcpb.CleanupRequest + Commit *kvrpcpb.CommitRequest + Cop *coprocessor.Request + DeleteRange *kvrpcpb.DeleteRangeRequest + GC *kvrpcpb.GCRequest + Get *kvrpcpb.GetRequest + MvccGetByKey *kvrpcpb.MvccGetByKeyRequest + MvccGetByStartTs *kvrpcpb.MvccGetByStartTsRequest + Prewrite *kvrpcpb.PrewriteRequest + RawBatchDelete *kvrpcpb.RawBatchDeleteRequest + RawBatchGet *kvrpcpb.RawBatchGetRequest + RawBatchPut *kvrpcpb.RawBatchPutRequest + RawDelete *kvrpcpb.RawDeleteRequest + RawDeleteRange *kvrpcpb.RawDeleteRangeRequest + RawGet *kvrpcpb.RawGetRequest + RawPut *kvrpcpb.RawPutRequest + RawScan *kvrpcpb.RawScanRequest + ResolveLock *kvrpcpb.ResolveLockRequest + Scan *kvrpcpb.ScanRequest + ScanLock *kvrpcpb.ScanLockRequest + SplitRegion *kvrpcpb.SplitRegionRequest + Type CmdType + UnsafeDestroyRange *kvrpcpb.UnsafeDestroyRangeRequest + type Response struct + BatchGet *kvrpcpb.BatchGetResponse + BatchRollback *kvrpcpb.BatchRollbackResponse + Cleanup *kvrpcpb.CleanupResponse + Commit *kvrpcpb.CommitResponse + Cop *coprocessor.Response + CopStream *CopStreamResponse + DeleteRange *kvrpcpb.DeleteRangeResponse + GC *kvrpcpb.GCResponse + Get *kvrpcpb.GetResponse + MvccGetByKey *kvrpcpb.MvccGetByKeyResponse + MvccGetByStartTS *kvrpcpb.MvccGetByStartTsResponse + Prewrite *kvrpcpb.PrewriteResponse + RawBatchDelete *kvrpcpb.RawBatchDeleteResponse + RawBatchGet *kvrpcpb.RawBatchGetResponse + RawBatchPut *kvrpcpb.RawBatchPutResponse + RawDelete *kvrpcpb.RawDeleteResponse + RawDeleteRange *kvrpcpb.RawDeleteRangeResponse + RawGet *kvrpcpb.RawGetResponse + RawPut *kvrpcpb.RawPutResponse + RawScan *kvrpcpb.RawScanResponse + ResolveLock *kvrpcpb.ResolveLockResponse + Scan *kvrpcpb.ScanResponse + ScanLock *kvrpcpb.ScanLockResponse + SplitRegion *kvrpcpb.SplitRegionResponse + Type CmdType + UnsafeDestroyRange *kvrpcpb.UnsafeDestroyRangeResponse + func CallRPC(ctx context.Context, client tikvpb.TikvClient, req *Request) (*Response, error) + func GenRegionErrorResp(req *Request, e *errorpb.Error) (*Response, error) + func (resp *Response) GetRegionError() (*errorpb.Error, error)
Go to main page