Versions in this module Expand all Collapse all v1 v1.0.0 Oct 16, 2017 Changes in this version + 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 CmdDeleteRange + const CmdGC + const CmdGet + const CmdMvccGetByKey + const CmdMvccGetByStartTs + const CmdPrewrite + const CmdRawDelete + const CmdRawGet + const CmdRawPut + const CmdRawScan + const CmdResolveLock + const CmdScan + const CmdScanLock + const CmdSplitRegion + 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 + RawDelete *kvrpcpb.RawDeleteRequest + RawGet *kvrpcpb.RawGetRequest + RawPut *kvrpcpb.RawPutRequest + RawScan *kvrpcpb.RawScanRequest + ResolveLock *kvrpcpb.ResolveLockRequest + Scan *kvrpcpb.ScanRequest + ScanLock *kvrpcpb.ScanLockRequest + SplitRegion *kvrpcpb.SplitRegionRequest + Type CmdType + type Response struct + BatchGet *kvrpcpb.BatchGetResponse + BatchRollback *kvrpcpb.BatchRollbackResponse + Cleanup *kvrpcpb.CleanupResponse + Commit *kvrpcpb.CommitResponse + Cop *coprocessor.Response + DeleteRange *kvrpcpb.DeleteRangeResponse + GC *kvrpcpb.GCResponse + Get *kvrpcpb.GetResponse + MvccGetByKey *kvrpcpb.MvccGetByKeyResponse + MvccGetByStartTS *kvrpcpb.MvccGetByStartTsResponse + Prewrite *kvrpcpb.PrewriteResponse + RawDelete *kvrpcpb.RawDeleteResponse + RawGet *kvrpcpb.RawGetResponse + RawPut *kvrpcpb.RawPutResponse + RawScan *kvrpcpb.RawScanResponse + ResolveLock *kvrpcpb.ResolveLockResponse + Scan *kvrpcpb.ScanResponse + ScanLock *kvrpcpb.ScanLockResponse + SplitRegion *kvrpcpb.SplitRegionResponse + Type CmdType + func GenRegionErrorResp(req *Request, e *errorpb.Error) (*Response, error) + func (resp *Response) GetRegionError() (*errorpb.Error, error)
Go to main page