tikvrpc

package

Go to main page

Versions in this module

v2

v2.0.7

Apr 14, 2023

Changes in this version

+ const EngineRoleLabelKey

+ const EngineRoleWrite

type CmdType

+ const CmdGetTiFlashSystemTable

type Request

+ func (req *Request) GetStartTS() uint64

+ func (req *Request) GetTiFlashSystemTable() *kvrpcpb.TiFlashSystemTableRequest

v2.0.6

Mar 2, 2023

Changes in this version

+ func AttachContext(req *Request, ctx *kvrpcpb.Context) error

type Request

+ ReplicaNumber int64

v2.0.5

Feb 2, 2023

Changes in this version

type Request

+ func (req *Request) IsRawWriteRequest() bool

v2.0.4

Jan 6, 2023

v2.0.3

Dec 8, 2022

v2.0.2

Nov 2, 2022

Changes in this version

+ const EngineLabelKey

+ const EngineLabelTiFlash

+ const EngineLabelTiFlashCompute

type CmdType

+ const CmdCompact

+ const CmdFlashbackToVersion

+ const CmdPrepareFlashbackToVersion

+ const CmdRawChecksum

type EndpointType

+ const TiFlashCompute

+ func (t EndpointType) IsTiFlashRelatedType() bool

type Request

+ func (req *Request) Compact() *kvrpcpb.CompactRequest

+ func (req *Request) FlashbackToVersion() *kvrpcpb.FlashbackToVersionRequest

+ func (req *Request) PrepareFlashbackToVersion() *kvrpcpb.PrepareFlashbackToVersionRequest

+ func (req *Request) RawChecksum() *kvrpcpb.RawChecksumRequest

type Response

+ func (resp *Response) GetExecDetailsV2() *kvrpcpb.ExecDetailsV2

v2.0.1

Apr 7, 2022

v2.0.0

Feb 24, 2022

Changes in this version

+ func CheckStreamTimeoutLoop(ch <-chan *Lease, done <-chan struct{})

+ func SetContext(req *Request, region *metapb.Region, peer *metapb.Peer) error

+ type BatchCopStreamResponse struct

+ Timeout time.Duration

+ func (resp *BatchCopStreamResponse) Close()

+ func (resp *BatchCopStreamResponse) Recv() (*coprocessor.BatchResponse, error)

+ type CmdType uint16

+ const CmdBatchCop

+ const CmdBatchGet

+ const CmdBatchRollback

+ const CmdCheckLockObserver

+ const CmdCheckSecondaryLocks

+ const CmdCheckTxnStatus

+ const CmdCleanup

+ const CmdCommit

+ const CmdCop

+ const CmdCopStream

+ const CmdDebugGetRegionProperties

+ const CmdDeleteRange

+ const CmdEmpty

+ const CmdGC

+ const CmdGet

+ const CmdGetKeyTTL

+ const CmdLockWaitInfo

+ const CmdMPPAlive

+ const CmdMPPCancel

+ const CmdMPPConn

+ const CmdMPPTask

+ const CmdMvccGetByKey

+ const CmdMvccGetByStartTs

+ const CmdPessimisticLock

+ const CmdPessimisticRollback

+ const CmdPhysicalScanLock

+ const CmdPrewrite

+ const CmdRawBatchDelete

+ const CmdRawBatchGet

+ const CmdRawBatchPut

+ const CmdRawCompareAndSwap

+ const CmdRawDelete

+ const CmdRawDeleteRange

+ const CmdRawGet

+ const CmdRawPut

+ const CmdRawScan

+ const CmdRegisterLockObserver

+ const CmdRemoveLockObserver

+ const CmdResolveLock

+ const CmdScan

+ const CmdScanLock

+ const CmdSplitRegion

+ const CmdStoreSafeTS

+ const CmdTxnHeartBeat

+ 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 EndpointType uint8

+ const TiDB

+ const TiFlash

+ const TiKV

+ func GetStoreTypeByMeta(store *metapb.Store) EndpointType

+ func (t EndpointType) Name() string

+ type Lease struct

+ Cancel context.CancelFunc

+ type MPPStreamResponse struct

+ Timeout time.Duration

+ func (resp *MPPStreamResponse) Close()

+ func (resp *MPPStreamResponse) Recv() (*mpp.MPPDataPacket, error)

+ type Request struct

+ ForwardedHost string

+ ReadReplicaScope string

+ ReplicaReadSeed *uint32

+ ReplicaReadType kv.ReplicaReadType

+ Req interface{}

+ StoreTp EndpointType

+ TxnScope string

+ Type CmdType

+ func NewReplicaReadRequest(typ CmdType, pointer interface{}, replicaReadType kv.ReplicaReadType, ...) *Request

+ func NewRequest(typ CmdType, pointer interface{}, ctxs ...kvrpcpb.Context) *Request

+ func (req *Request) BatchCop() *coprocessor.BatchRequest

+ func (req *Request) BatchGet() *kvrpcpb.BatchGetRequest

+ func (req *Request) BatchRollback() *kvrpcpb.BatchRollbackRequest

+ func (req *Request) CancelMPPTask() *mpp.CancelTaskRequest

+ func (req *Request) CheckLockObserver() *kvrpcpb.CheckLockObserverRequest

+ func (req *Request) CheckSecondaryLocks() *kvrpcpb.CheckSecondaryLocksRequest

+ func (req *Request) CheckTxnStatus() *kvrpcpb.CheckTxnStatusRequest

+ func (req *Request) Cleanup() *kvrpcpb.CleanupRequest

+ func (req *Request) Commit() *kvrpcpb.CommitRequest

+ func (req *Request) Cop() *coprocessor.Request

+ func (req *Request) DebugGetRegionProperties() *debugpb.GetRegionPropertiesRequest

+ func (req *Request) DeleteRange() *kvrpcpb.DeleteRangeRequest

+ func (req *Request) DispatchMPPTask() *mpp.DispatchTaskRequest

+ func (req *Request) Empty() *tikvpb.BatchCommandsEmptyRequest

+ func (req *Request) EnableStaleRead()

+ func (req *Request) EstablishMPPConn() *mpp.EstablishMPPConnectionRequest

+ func (req *Request) GC() *kvrpcpb.GCRequest

+ func (req *Request) Get() *kvrpcpb.GetRequest

+ func (req *Request) GetReplicaReadSeed() *uint32

+ func (req *Request) IsDebugReq() bool

+ func (req *Request) IsGlobalStaleRead() bool

+ func (req *Request) IsGreenGCRequest() bool

+ func (req *Request) IsMPPAlive() *mpp.IsAliveRequest

+ func (req *Request) IsTxnWriteRequest() bool

+ func (req *Request) LockWaitInfo() *kvrpcpb.GetLockWaitInfoRequest

+ func (req *Request) MvccGetByKey() *kvrpcpb.MvccGetByKeyRequest

+ func (req *Request) MvccGetByStartTs() *kvrpcpb.MvccGetByStartTsRequest

+ func (req *Request) PessimisticLock() *kvrpcpb.PessimisticLockRequest

+ func (req *Request) PessimisticRollback() *kvrpcpb.PessimisticRollbackRequest

+ func (req *Request) PhysicalScanLock() *kvrpcpb.PhysicalScanLockRequest

+ func (req *Request) Prewrite() *kvrpcpb.PrewriteRequest

+ func (req *Request) RawBatchDelete() *kvrpcpb.RawBatchDeleteRequest

+ func (req *Request) RawBatchGet() *kvrpcpb.RawBatchGetRequest

+ func (req *Request) RawBatchPut() *kvrpcpb.RawBatchPutRequest

+ func (req *Request) RawCompareAndSwap() *kvrpcpb.RawCASRequest

+ func (req *Request) RawDelete() *kvrpcpb.RawDeleteRequest

+ func (req *Request) RawDeleteRange() *kvrpcpb.RawDeleteRangeRequest

+ func (req *Request) RawGet() *kvrpcpb.RawGetRequest

+ func (req *Request) RawGetKeyTTL() *kvrpcpb.RawGetKeyTTLRequest

+ func (req *Request) RawPut() *kvrpcpb.RawPutRequest

+ func (req *Request) RawScan() *kvrpcpb.RawScanRequest

+ func (req *Request) RegisterLockObserver() *kvrpcpb.RegisterLockObserverRequest

+ func (req *Request) RemoveLockObserver() *kvrpcpb.RemoveLockObserverRequest

+ func (req *Request) ResolveLock() *kvrpcpb.ResolveLockRequest

+ func (req *Request) Scan() *kvrpcpb.ScanRequest

+ func (req *Request) ScanLock() *kvrpcpb.ScanLockRequest

+ func (req *Request) SplitRegion() *kvrpcpb.SplitRegionRequest

+ func (req *Request) StoreSafeTS() *kvrpcpb.StoreSafeTSRequest

+ func (req *Request) ToBatchCommandsRequest() *tikvpb.BatchCommandsRequest_Request

+ func (req *Request) TxnHeartBeat() *kvrpcpb.TxnHeartBeatRequest

+ func (req *Request) UnsafeDestroyRange() *kvrpcpb.UnsafeDestroyRangeRequest

+ type ResourceGroupTagger func(req *Request)

+ type Response struct

+ Resp interface{}

+ func CallDebugRPC(ctx context.Context, client debugpb.DebugClient, req *Request) (*Response, error)

+ func CallRPC(ctx context.Context, client tikvpb.TikvClient, req *Request) (*Response, error)

+ func FromBatchCommandsResponse(res *tikvpb.BatchCommandsResponse_Response) (*Response, error)

+ func GenRegionErrorResp(req *Request, e *errorpb.Error) (*Response, error)

+ func (resp *Response) GetRegionError() (*errorpb.Error, error)

v2.0.0-rc

Dec 6, 2021

v2.0.0-alpha

Jun 23, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL