kvrpcpb

Documentation

Index

• Variables
• type APIVersion
  • func (APIVersion) EnumDescriptor() ([]byte, []int)
  • func (x APIVersion) String() string
• type Action
  • func (Action) EnumDescriptor() ([]byte, []int)
  • func (x Action) String() string
• type AlreadyExist
  • func (*AlreadyExist) Descriptor() ([]byte, []int)
  • func (m *AlreadyExist) GetKey() []byte
  • func (m *AlreadyExist) Marshal() (dAtA []byte, err error)
  • func (m *AlreadyExist) MarshalTo(dAtA []byte) (int, error)
  • func (m *AlreadyExist) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AlreadyExist) ProtoMessage()
  • func (m *AlreadyExist) Reset()
  • func (m *AlreadyExist) Size() (n int)
  • func (m *AlreadyExist) String() string
  • func (m *AlreadyExist) Unmarshal(dAtA []byte) error
  • func (m *AlreadyExist) XXX_DiscardUnknown()
  • func (m *AlreadyExist) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AlreadyExist) XXX_Merge(src proto.Message)
  • func (m *AlreadyExist) XXX_Size() int
  • func (m *AlreadyExist) XXX_Unmarshal(b []byte) error
• type Assertion
  • func (Assertion) EnumDescriptor() ([]byte, []int)
  • func (x Assertion) String() string
• type AssertionFailed
  • func (*AssertionFailed) Descriptor() ([]byte, []int)
  • func (m *AssertionFailed) GetAssertion() Assertion
  • func (m *AssertionFailed) GetExistingCommitTs() uint64
  • func (m *AssertionFailed) GetExistingStartTs() uint64
  • func (m *AssertionFailed) GetKey() []byte
  • func (m *AssertionFailed) GetStartTs() uint64
  • func (m *AssertionFailed) Marshal() (dAtA []byte, err error)
  • func (m *AssertionFailed) MarshalTo(dAtA []byte) (int, error)
  • func (m *AssertionFailed) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AssertionFailed) ProtoMessage()
  • func (m *AssertionFailed) Reset()
  • func (m *AssertionFailed) Size() (n int)
  • func (m *AssertionFailed) String() string
  • func (m *AssertionFailed) Unmarshal(dAtA []byte) error
  • func (m *AssertionFailed) XXX_DiscardUnknown()
  • func (m *AssertionFailed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AssertionFailed) XXX_Merge(src proto.Message)
  • func (m *AssertionFailed) XXX_Size() int
  • func (m *AssertionFailed) XXX_Unmarshal(b []byte) error
• type AssertionLevel
  • func (AssertionLevel) EnumDescriptor() ([]byte, []int)
  • func (x AssertionLevel) String() string
• type BatchGetRequest
  • func (*BatchGetRequest) Descriptor() ([]byte, []int)
  • func (m *BatchGetRequest) GetContext() *Context
  • func (m *BatchGetRequest) GetKeys() [][]byte
  • func (m *BatchGetRequest) GetVersion() uint64
  • func (m *BatchGetRequest) Marshal() (dAtA []byte, err error)
  • func (m *BatchGetRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *BatchGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*BatchGetRequest) ProtoMessage()
  • func (m *BatchGetRequest) Reset()
  • func (m *BatchGetRequest) Size() (n int)
  • func (m *BatchGetRequest) String() string
  • func (m *BatchGetRequest) Unmarshal(dAtA []byte) error
  • func (m *BatchGetRequest) XXX_DiscardUnknown()
  • func (m *BatchGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *BatchGetRequest) XXX_Merge(src proto.Message)
  • func (m *BatchGetRequest) XXX_Size() int
  • func (m *BatchGetRequest) XXX_Unmarshal(b []byte) error
• type BatchGetResponse
  • func (*BatchGetResponse) Descriptor() ([]byte, []int)
  • func (m *BatchGetResponse) GetError() *KeyError
  • func (m *BatchGetResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *BatchGetResponse) GetPairs() []*KvPair
  • func (m *BatchGetResponse) GetRegionError() *errorpb.Error
  • func (m *BatchGetResponse) Marshal() (dAtA []byte, err error)
  • func (m *BatchGetResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *BatchGetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*BatchGetResponse) ProtoMessage()
  • func (m *BatchGetResponse) Reset()
  • func (m *BatchGetResponse) Size() (n int)
  • func (m *BatchGetResponse) String() string
  • func (m *BatchGetResponse) Unmarshal(dAtA []byte) error
  • func (m *BatchGetResponse) XXX_DiscardUnknown()
  • func (m *BatchGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *BatchGetResponse) XXX_Merge(src proto.Message)
  • func (m *BatchGetResponse) XXX_Size() int
  • func (m *BatchGetResponse) XXX_Unmarshal(b []byte) error
• type BatchRollbackRequest
  • func (*BatchRollbackRequest) Descriptor() ([]byte, []int)
  • func (m *BatchRollbackRequest) GetContext() *Context
  • func (m *BatchRollbackRequest) GetKeys() [][]byte
  • func (m *BatchRollbackRequest) GetStartVersion() uint64
  • func (m *BatchRollbackRequest) Marshal() (dAtA []byte, err error)
  • func (m *BatchRollbackRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *BatchRollbackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*BatchRollbackRequest) ProtoMessage()
  • func (m *BatchRollbackRequest) Reset()
  • func (m *BatchRollbackRequest) Size() (n int)
  • func (m *BatchRollbackRequest) String() string
  • func (m *BatchRollbackRequest) Unmarshal(dAtA []byte) error
  • func (m *BatchRollbackRequest) XXX_DiscardUnknown()
  • func (m *BatchRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *BatchRollbackRequest) XXX_Merge(src proto.Message)
  • func (m *BatchRollbackRequest) XXX_Size() int
  • func (m *BatchRollbackRequest) XXX_Unmarshal(b []byte) error
• type BatchRollbackResponse
  • func (*BatchRollbackResponse) Descriptor() ([]byte, []int)
  • func (m *BatchRollbackResponse) GetError() *KeyError
  • func (m *BatchRollbackResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *BatchRollbackResponse) GetRegionError() *errorpb.Error
  • func (m *BatchRollbackResponse) Marshal() (dAtA []byte, err error)
  • func (m *BatchRollbackResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *BatchRollbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*BatchRollbackResponse) ProtoMessage()
  • func (m *BatchRollbackResponse) Reset()
  • func (m *BatchRollbackResponse) Size() (n int)
  • func (m *BatchRollbackResponse) String() string
  • func (m *BatchRollbackResponse) Unmarshal(dAtA []byte) error
  • func (m *BatchRollbackResponse) XXX_DiscardUnknown()
  • func (m *BatchRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *BatchRollbackResponse) XXX_Merge(src proto.Message)
  • func (m *BatchRollbackResponse) XXX_Size() int
  • func (m *BatchRollbackResponse) XXX_Unmarshal(b []byte) error
• type CheckLeaderRequest
  • func (*CheckLeaderRequest) Descriptor() ([]byte, []int)
  • func (m *CheckLeaderRequest) GetRegions() []*LeaderInfo
  • func (m *CheckLeaderRequest) GetTs() uint64
  • func (m *CheckLeaderRequest) Marshal() (dAtA []byte, err error)
  • func (m *CheckLeaderRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *CheckLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CheckLeaderRequest) ProtoMessage()
  • func (m *CheckLeaderRequest) Reset()
  • func (m *CheckLeaderRequest) Size() (n int)
  • func (m *CheckLeaderRequest) String() string
  • func (m *CheckLeaderRequest) Unmarshal(dAtA []byte) error
  • func (m *CheckLeaderRequest) XXX_DiscardUnknown()
  • func (m *CheckLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckLeaderRequest) XXX_Merge(src proto.Message)
  • func (m *CheckLeaderRequest) XXX_Size() int
  • func (m *CheckLeaderRequest) XXX_Unmarshal(b []byte) error
• type CheckLeaderResponse
  • func (*CheckLeaderResponse) Descriptor() ([]byte, []int)
  • func (m *CheckLeaderResponse) GetRegions() []uint64
  • func (m *CheckLeaderResponse) GetTs() uint64
  • func (m *CheckLeaderResponse) Marshal() (dAtA []byte, err error)
  • func (m *CheckLeaderResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *CheckLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CheckLeaderResponse) ProtoMessage()
  • func (m *CheckLeaderResponse) Reset()
  • func (m *CheckLeaderResponse) Size() (n int)
  • func (m *CheckLeaderResponse) String() string
  • func (m *CheckLeaderResponse) Unmarshal(dAtA []byte) error
  • func (m *CheckLeaderResponse) XXX_DiscardUnknown()
  • func (m *CheckLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckLeaderResponse) XXX_Merge(src proto.Message)
  • func (m *CheckLeaderResponse) XXX_Size() int
  • func (m *CheckLeaderResponse) XXX_Unmarshal(b []byte) error
• type CheckLockObserverRequest
  • func (*CheckLockObserverRequest) Descriptor() ([]byte, []int)
  • func (m *CheckLockObserverRequest) GetContext() *Context
  • func (m *CheckLockObserverRequest) GetMaxTs() uint64
  • func (m *CheckLockObserverRequest) Marshal() (dAtA []byte, err error)
  • func (m *CheckLockObserverRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *CheckLockObserverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CheckLockObserverRequest) ProtoMessage()
  • func (m *CheckLockObserverRequest) Reset()
  • func (m *CheckLockObserverRequest) Size() (n int)
  • func (m *CheckLockObserverRequest) String() string
  • func (m *CheckLockObserverRequest) Unmarshal(dAtA []byte) error
  • func (m *CheckLockObserverRequest) XXX_DiscardUnknown()
  • func (m *CheckLockObserverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckLockObserverRequest) XXX_Merge(src proto.Message)
  • func (m *CheckLockObserverRequest) XXX_Size() int
  • func (m *CheckLockObserverRequest) XXX_Unmarshal(b []byte) error
• type CheckLockObserverResponse
  • func (*CheckLockObserverResponse) Descriptor() ([]byte, []int)
  • func (m *CheckLockObserverResponse) GetError() string
  • func (m *CheckLockObserverResponse) GetIsClean() bool
  • func (m *CheckLockObserverResponse) GetLocks() []*LockInfo
  • func (m *CheckLockObserverResponse) Marshal() (dAtA []byte, err error)
  • func (m *CheckLockObserverResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *CheckLockObserverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CheckLockObserverResponse) ProtoMessage()
  • func (m *CheckLockObserverResponse) Reset()
  • func (m *CheckLockObserverResponse) Size() (n int)
  • func (m *CheckLockObserverResponse) String() string
  • func (m *CheckLockObserverResponse) Unmarshal(dAtA []byte) error
  • func (m *CheckLockObserverResponse) XXX_DiscardUnknown()
  • func (m *CheckLockObserverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckLockObserverResponse) XXX_Merge(src proto.Message)
  • func (m *CheckLockObserverResponse) XXX_Size() int
  • func (m *CheckLockObserverResponse) XXX_Unmarshal(b []byte) error
• type CheckSecondaryLocksRequest
  • func (*CheckSecondaryLocksRequest) Descriptor() ([]byte, []int)
  • func (m *CheckSecondaryLocksRequest) GetContext() *Context
  • func (m *CheckSecondaryLocksRequest) GetKeys() [][]byte
  • func (m *CheckSecondaryLocksRequest) GetStartVersion() uint64
  • func (m *CheckSecondaryLocksRequest) Marshal() (dAtA []byte, err error)
  • func (m *CheckSecondaryLocksRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *CheckSecondaryLocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CheckSecondaryLocksRequest) ProtoMessage()
  • func (m *CheckSecondaryLocksRequest) Reset()
  • func (m *CheckSecondaryLocksRequest) Size() (n int)
  • func (m *CheckSecondaryLocksRequest) String() string
  • func (m *CheckSecondaryLocksRequest) Unmarshal(dAtA []byte) error
  • func (m *CheckSecondaryLocksRequest) XXX_DiscardUnknown()
  • func (m *CheckSecondaryLocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckSecondaryLocksRequest) XXX_Merge(src proto.Message)
  • func (m *CheckSecondaryLocksRequest) XXX_Size() int
  • func (m *CheckSecondaryLocksRequest) XXX_Unmarshal(b []byte) error
• type CheckSecondaryLocksResponse
  • func (*CheckSecondaryLocksResponse) Descriptor() ([]byte, []int)
  • func (m *CheckSecondaryLocksResponse) GetCommitTs() uint64
  • func (m *CheckSecondaryLocksResponse) GetError() *KeyError
  • func (m *CheckSecondaryLocksResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *CheckSecondaryLocksResponse) GetLocks() []*LockInfo
  • func (m *CheckSecondaryLocksResponse) GetRegionError() *errorpb.Error
  • func (m *CheckSecondaryLocksResponse) Marshal() (dAtA []byte, err error)
  • func (m *CheckSecondaryLocksResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *CheckSecondaryLocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CheckSecondaryLocksResponse) ProtoMessage()
  • func (m *CheckSecondaryLocksResponse) Reset()
  • func (m *CheckSecondaryLocksResponse) Size() (n int)
  • func (m *CheckSecondaryLocksResponse) String() string
  • func (m *CheckSecondaryLocksResponse) Unmarshal(dAtA []byte) error
  • func (m *CheckSecondaryLocksResponse) XXX_DiscardUnknown()
  • func (m *CheckSecondaryLocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckSecondaryLocksResponse) XXX_Merge(src proto.Message)
  • func (m *CheckSecondaryLocksResponse) XXX_Size() int
  • func (m *CheckSecondaryLocksResponse) XXX_Unmarshal(b []byte) error
• type CheckTxnStatusRequest
  • func (*CheckTxnStatusRequest) Descriptor() ([]byte, []int)
  • func (m *CheckTxnStatusRequest) GetCallerStartTs() uint64
  • func (m *CheckTxnStatusRequest) GetContext() *Context
  • func (m *CheckTxnStatusRequest) GetCurrentTs() uint64
  • func (m *CheckTxnStatusRequest) GetForceSyncCommit() bool
  • func (m *CheckTxnStatusRequest) GetLockTs() uint64
  • func (m *CheckTxnStatusRequest) GetPrimaryKey() []byte
  • func (m *CheckTxnStatusRequest) GetResolvingPessimisticLock() bool
  • func (m *CheckTxnStatusRequest) GetRollbackIfNotExist() bool
  • func (m *CheckTxnStatusRequest) GetVerifyIsPrimary() bool
  • func (m *CheckTxnStatusRequest) Marshal() (dAtA []byte, err error)
  • func (m *CheckTxnStatusRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *CheckTxnStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CheckTxnStatusRequest) ProtoMessage()
  • func (m *CheckTxnStatusRequest) Reset()
  • func (m *CheckTxnStatusRequest) Size() (n int)
  • func (m *CheckTxnStatusRequest) String() string
  • func (m *CheckTxnStatusRequest) Unmarshal(dAtA []byte) error
  • func (m *CheckTxnStatusRequest) XXX_DiscardUnknown()
  • func (m *CheckTxnStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckTxnStatusRequest) XXX_Merge(src proto.Message)
  • func (m *CheckTxnStatusRequest) XXX_Size() int
  • func (m *CheckTxnStatusRequest) XXX_Unmarshal(b []byte) error
• type CheckTxnStatusResponse
  • func (*CheckTxnStatusResponse) Descriptor() ([]byte, []int)
  • func (m *CheckTxnStatusResponse) GetAction() Action
  • func (m *CheckTxnStatusResponse) GetCommitVersion() uint64
  • func (m *CheckTxnStatusResponse) GetError() *KeyError
  • func (m *CheckTxnStatusResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *CheckTxnStatusResponse) GetLockInfo() *LockInfo
  • func (m *CheckTxnStatusResponse) GetLockTtl() uint64
  • func (m *CheckTxnStatusResponse) GetRegionError() *errorpb.Error
  • func (m *CheckTxnStatusResponse) Marshal() (dAtA []byte, err error)
  • func (m *CheckTxnStatusResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *CheckTxnStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CheckTxnStatusResponse) ProtoMessage()
  • func (m *CheckTxnStatusResponse) Reset()
  • func (m *CheckTxnStatusResponse) Size() (n int)
  • func (m *CheckTxnStatusResponse) String() string
  • func (m *CheckTxnStatusResponse) Unmarshal(dAtA []byte) error
  • func (m *CheckTxnStatusResponse) XXX_DiscardUnknown()
  • func (m *CheckTxnStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckTxnStatusResponse) XXX_Merge(src proto.Message)
  • func (m *CheckTxnStatusResponse) XXX_Size() int
  • func (m *CheckTxnStatusResponse) XXX_Unmarshal(b []byte) error
• type ChecksumAlgorithm
  • func (ChecksumAlgorithm) EnumDescriptor() ([]byte, []int)
  • func (x ChecksumAlgorithm) String() string
• type CleanupRequest
  • func (*CleanupRequest) Descriptor() ([]byte, []int)
  • func (m *CleanupRequest) GetContext() *Context
  • func (m *CleanupRequest) GetCurrentTs() uint64
  • func (m *CleanupRequest) GetKey() []byte
  • func (m *CleanupRequest) GetStartVersion() uint64
  • func (m *CleanupRequest) Marshal() (dAtA []byte, err error)
  • func (m *CleanupRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *CleanupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CleanupRequest) ProtoMessage()
  • func (m *CleanupRequest) Reset()
  • func (m *CleanupRequest) Size() (n int)
  • func (m *CleanupRequest) String() string
  • func (m *CleanupRequest) Unmarshal(dAtA []byte) error
  • func (m *CleanupRequest) XXX_DiscardUnknown()
  • func (m *CleanupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CleanupRequest) XXX_Merge(src proto.Message)
  • func (m *CleanupRequest) XXX_Size() int
  • func (m *CleanupRequest) XXX_Unmarshal(b []byte) error
• type CleanupResponse
  • func (*CleanupResponse) Descriptor() ([]byte, []int)
  • func (m *CleanupResponse) GetCommitVersion() uint64
  • func (m *CleanupResponse) GetError() *KeyError
  • func (m *CleanupResponse) GetRegionError() *errorpb.Error
  • func (m *CleanupResponse) Marshal() (dAtA []byte, err error)
  • func (m *CleanupResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *CleanupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CleanupResponse) ProtoMessage()
  • func (m *CleanupResponse) Reset()
  • func (m *CleanupResponse) Size() (n int)
  • func (m *CleanupResponse) String() string
  • func (m *CleanupResponse) Unmarshal(dAtA []byte) error
  • func (m *CleanupResponse) XXX_DiscardUnknown()
  • func (m *CleanupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CleanupResponse) XXX_Merge(src proto.Message)
  • func (m *CleanupResponse) XXX_Size() int
  • func (m *CleanupResponse) XXX_Unmarshal(b []byte) error
• type CommandPri
  • func (CommandPri) EnumDescriptor() ([]byte, []int)
  • func (x CommandPri) String() string
• type CommitRequest
  • func (*CommitRequest) Descriptor() ([]byte, []int)
  • func (m *CommitRequest) GetCommitVersion() uint64
  • func (m *CommitRequest) GetContext() *Context
  • func (m *CommitRequest) GetKeys() [][]byte
  • func (m *CommitRequest) GetStartVersion() uint64
  • func (m *CommitRequest) Marshal() (dAtA []byte, err error)
  • func (m *CommitRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *CommitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CommitRequest) ProtoMessage()
  • func (m *CommitRequest) Reset()
  • func (m *CommitRequest) Size() (n int)
  • func (m *CommitRequest) String() string
  • func (m *CommitRequest) Unmarshal(dAtA []byte) error
  • func (m *CommitRequest) XXX_DiscardUnknown()
  • func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CommitRequest) XXX_Merge(src proto.Message)
  • func (m *CommitRequest) XXX_Size() int
  • func (m *CommitRequest) XXX_Unmarshal(b []byte) error
• type CommitResponse
  • func (*CommitResponse) Descriptor() ([]byte, []int)
  • func (m *CommitResponse) GetCommitVersion() uint64
  • func (m *CommitResponse) GetError() *KeyError
  • func (m *CommitResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *CommitResponse) GetRegionError() *errorpb.Error
  • func (m *CommitResponse) Marshal() (dAtA []byte, err error)
  • func (m *CommitResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *CommitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CommitResponse) ProtoMessage()
  • func (m *CommitResponse) Reset()
  • func (m *CommitResponse) Size() (n int)
  • func (m *CommitResponse) String() string
  • func (m *CommitResponse) Unmarshal(dAtA []byte) error
  • func (m *CommitResponse) XXX_DiscardUnknown()
  • func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CommitResponse) XXX_Merge(src proto.Message)
  • func (m *CommitResponse) XXX_Size() int
  • func (m *CommitResponse) XXX_Unmarshal(b []byte) error
• type CommitTsExpired
  • func (*CommitTsExpired) Descriptor() ([]byte, []int)
  • func (m *CommitTsExpired) GetAttemptedCommitTs() uint64
  • func (m *CommitTsExpired) GetKey() []byte
  • func (m *CommitTsExpired) GetMinCommitTs() uint64
  • func (m *CommitTsExpired) GetStartTs() uint64
  • func (m *CommitTsExpired) Marshal() (dAtA []byte, err error)
  • func (m *CommitTsExpired) MarshalTo(dAtA []byte) (int, error)
  • func (m *CommitTsExpired) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CommitTsExpired) ProtoMessage()
  • func (m *CommitTsExpired) Reset()
  • func (m *CommitTsExpired) Size() (n int)
  • func (m *CommitTsExpired) String() string
  • func (m *CommitTsExpired) Unmarshal(dAtA []byte) error
  • func (m *CommitTsExpired) XXX_DiscardUnknown()
  • func (m *CommitTsExpired) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CommitTsExpired) XXX_Merge(src proto.Message)
  • func (m *CommitTsExpired) XXX_Size() int
  • func (m *CommitTsExpired) XXX_Unmarshal(b []byte) error
• type CommitTsTooLarge
  • func (*CommitTsTooLarge) Descriptor() ([]byte, []int)
  • func (m *CommitTsTooLarge) GetCommitTs() uint64
  • func (m *CommitTsTooLarge) Marshal() (dAtA []byte, err error)
  • func (m *CommitTsTooLarge) MarshalTo(dAtA []byte) (int, error)
  • func (m *CommitTsTooLarge) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CommitTsTooLarge) ProtoMessage()
  • func (m *CommitTsTooLarge) Reset()
  • func (m *CommitTsTooLarge) Size() (n int)
  • func (m *CommitTsTooLarge) String() string
  • func (m *CommitTsTooLarge) Unmarshal(dAtA []byte) error
  • func (m *CommitTsTooLarge) XXX_DiscardUnknown()
  • func (m *CommitTsTooLarge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CommitTsTooLarge) XXX_Merge(src proto.Message)
  • func (m *CommitTsTooLarge) XXX_Size() int
  • func (m *CommitTsTooLarge) XXX_Unmarshal(b []byte) error
• type CompactError
  • func (*CompactError) Descriptor() ([]byte, []int)
  • func (m *CompactError) GetErrCompactInProgress() *CompactErrorCompactInProgress
  • func (m *CompactError) GetErrInvalidStartKey() *CompactErrorInvalidStartKey
  • func (m *CompactError) GetErrPhysicalTableNotExist() *CompactErrorPhysicalTableNotExist
  • func (m *CompactError) GetErrTooManyPendingTasks() *CompactErrorTooManyPendingTasks
  • func (m *CompactError) GetError() isCompactError_Error
  • func (m *CompactError) Marshal() (dAtA []byte, err error)
  • func (m *CompactError) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactError) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CompactError) ProtoMessage()
  • func (m *CompactError) Reset()
  • func (m *CompactError) Size() (n int)
  • func (m *CompactError) String() string
  • func (m *CompactError) Unmarshal(dAtA []byte) error
  • func (m *CompactError) XXX_DiscardUnknown()
  • func (m *CompactError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CompactError) XXX_Merge(src proto.Message)
  • func (*CompactError) XXX_OneofWrappers() []interface{}
  • func (m *CompactError) XXX_Size() int
  • func (m *CompactError) XXX_Unmarshal(b []byte) error
• type CompactErrorCompactInProgress
  • func (*CompactErrorCompactInProgress) Descriptor() ([]byte, []int)
  • func (m *CompactErrorCompactInProgress) Marshal() (dAtA []byte, err error)
  • func (m *CompactErrorCompactInProgress) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactErrorCompactInProgress) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CompactErrorCompactInProgress) ProtoMessage()
  • func (m *CompactErrorCompactInProgress) Reset()
  • func (m *CompactErrorCompactInProgress) Size() (n int)
  • func (m *CompactErrorCompactInProgress) String() string
  • func (m *CompactErrorCompactInProgress) Unmarshal(dAtA []byte) error
  • func (m *CompactErrorCompactInProgress) XXX_DiscardUnknown()
  • func (m *CompactErrorCompactInProgress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CompactErrorCompactInProgress) XXX_Merge(src proto.Message)
  • func (m *CompactErrorCompactInProgress) XXX_Size() int
  • func (m *CompactErrorCompactInProgress) XXX_Unmarshal(b []byte) error
• type CompactErrorInvalidStartKey
  • func (*CompactErrorInvalidStartKey) Descriptor() ([]byte, []int)
  • func (m *CompactErrorInvalidStartKey) Marshal() (dAtA []byte, err error)
  • func (m *CompactErrorInvalidStartKey) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactErrorInvalidStartKey) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CompactErrorInvalidStartKey) ProtoMessage()
  • func (m *CompactErrorInvalidStartKey) Reset()
  • func (m *CompactErrorInvalidStartKey) Size() (n int)
  • func (m *CompactErrorInvalidStartKey) String() string
  • func (m *CompactErrorInvalidStartKey) Unmarshal(dAtA []byte) error
  • func (m *CompactErrorInvalidStartKey) XXX_DiscardUnknown()
  • func (m *CompactErrorInvalidStartKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CompactErrorInvalidStartKey) XXX_Merge(src proto.Message)
  • func (m *CompactErrorInvalidStartKey) XXX_Size() int
  • func (m *CompactErrorInvalidStartKey) XXX_Unmarshal(b []byte) error
• type CompactErrorPhysicalTableNotExist
  • func (*CompactErrorPhysicalTableNotExist) Descriptor() ([]byte, []int)
  • func (m *CompactErrorPhysicalTableNotExist) Marshal() (dAtA []byte, err error)
  • func (m *CompactErrorPhysicalTableNotExist) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactErrorPhysicalTableNotExist) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CompactErrorPhysicalTableNotExist) ProtoMessage()
  • func (m *CompactErrorPhysicalTableNotExist) Reset()
  • func (m *CompactErrorPhysicalTableNotExist) Size() (n int)
  • func (m *CompactErrorPhysicalTableNotExist) String() string
  • func (m *CompactErrorPhysicalTableNotExist) Unmarshal(dAtA []byte) error
  • func (m *CompactErrorPhysicalTableNotExist) XXX_DiscardUnknown()
  • func (m *CompactErrorPhysicalTableNotExist) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CompactErrorPhysicalTableNotExist) XXX_Merge(src proto.Message)
  • func (m *CompactErrorPhysicalTableNotExist) XXX_Size() int
  • func (m *CompactErrorPhysicalTableNotExist) XXX_Unmarshal(b []byte) error
• type CompactErrorTooManyPendingTasks
  • func (*CompactErrorTooManyPendingTasks) Descriptor() ([]byte, []int)
  • func (m *CompactErrorTooManyPendingTasks) Marshal() (dAtA []byte, err error)
  • func (m *CompactErrorTooManyPendingTasks) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactErrorTooManyPendingTasks) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CompactErrorTooManyPendingTasks) ProtoMessage()
  • func (m *CompactErrorTooManyPendingTasks) Reset()
  • func (m *CompactErrorTooManyPendingTasks) Size() (n int)
  • func (m *CompactErrorTooManyPendingTasks) String() string
  • func (m *CompactErrorTooManyPendingTasks) Unmarshal(dAtA []byte) error
  • func (m *CompactErrorTooManyPendingTasks) XXX_DiscardUnknown()
  • func (m *CompactErrorTooManyPendingTasks) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CompactErrorTooManyPendingTasks) XXX_Merge(src proto.Message)
  • func (m *CompactErrorTooManyPendingTasks) XXX_Size() int
  • func (m *CompactErrorTooManyPendingTasks) XXX_Unmarshal(b []byte) error
• type CompactError_ErrCompactInProgress
  • func (m *CompactError_ErrCompactInProgress) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactError_ErrCompactInProgress) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *CompactError_ErrCompactInProgress) Size() (n int)
• type CompactError_ErrInvalidStartKey
  • func (m *CompactError_ErrInvalidStartKey) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactError_ErrInvalidStartKey) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *CompactError_ErrInvalidStartKey) Size() (n int)
• type CompactError_ErrPhysicalTableNotExist
  • func (m *CompactError_ErrPhysicalTableNotExist) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactError_ErrPhysicalTableNotExist) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *CompactError_ErrPhysicalTableNotExist) Size() (n int)
• type CompactError_ErrTooManyPendingTasks
  • func (m *CompactError_ErrTooManyPendingTasks) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactError_ErrTooManyPendingTasks) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *CompactError_ErrTooManyPendingTasks) Size() (n int)
• type CompactRequest
  • func (*CompactRequest) Descriptor() ([]byte, []int)
  • func (m *CompactRequest) GetApiVersion() APIVersion
  • func (m *CompactRequest) GetKeyspaceId() uint32
  • func (m *CompactRequest) GetLogicalTableId() int64
  • func (m *CompactRequest) GetPhysicalTableId() int64
  • func (m *CompactRequest) GetStartKey() []byte
  • func (m *CompactRequest) Marshal() (dAtA []byte, err error)
  • func (m *CompactRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CompactRequest) ProtoMessage()
  • func (m *CompactRequest) Reset()
  • func (m *CompactRequest) Size() (n int)
  • func (m *CompactRequest) String() string
  • func (m *CompactRequest) Unmarshal(dAtA []byte) error
  • func (m *CompactRequest) XXX_DiscardUnknown()
  • func (m *CompactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CompactRequest) XXX_Merge(src proto.Message)
  • func (m *CompactRequest) XXX_Size() int
  • func (m *CompactRequest) XXX_Unmarshal(b []byte) error
• type CompactResponse
  • func (*CompactResponse) Descriptor() ([]byte, []int)
  • func (m *CompactResponse) GetCompactedEndKey() []byte
  • func (m *CompactResponse) GetCompactedStartKey() []byte
  • func (m *CompactResponse) GetError() *CompactError
  • func (m *CompactResponse) GetHasRemaining() bool
  • func (m *CompactResponse) Marshal() (dAtA []byte, err error)
  • func (m *CompactResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *CompactResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*CompactResponse) ProtoMessage()
  • func (m *CompactResponse) Reset()
  • func (m *CompactResponse) Size() (n int)
  • func (m *CompactResponse) String() string
  • func (m *CompactResponse) Unmarshal(dAtA []byte) error
  • func (m *CompactResponse) XXX_DiscardUnknown()
  • func (m *CompactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CompactResponse) XXX_Merge(src proto.Message)
  • func (m *CompactResponse) XXX_Size() int
  • func (m *CompactResponse) XXX_Unmarshal(b []byte) error
• type Context
  • func (*Context) Descriptor() ([]byte, []int)
  • func (m *Context) GetApiVersion() APIVersion
  • func (m *Context) GetAppliedIndex() uint64
  • func (m *Context) GetBucketsVersion() uint64
  • func (m *Context) GetBusyThresholdMs() uint32
  • func (m *Context) GetCommittedLocks() []uint64
  • func (m *Context) GetDiskFullOpt() DiskFullOpt
  • func (m *Context) GetIsRetryRequest() bool
  • func (m *Context) GetIsolationLevel() IsolationLevel
  • func (m *Context) GetKeyspaceId() uint32
  • func (m *Context) GetMaxExecutionDurationMs() uint64
  • func (m *Context) GetNotFillCache() bool
  • func (m *Context) GetPeer() *metapb.Peer
  • func (m *Context) GetPriority() CommandPri
  • func (m *Context) GetRecordScanStat() bool
  • func (m *Context) GetRecordTimeStat() bool
  • func (m *Context) GetRegionEpoch() *metapb.RegionEpoch
  • func (m *Context) GetRegionId() uint64
  • func (m *Context) GetReplicaRead() bool
  • func (m *Context) GetRequestSource() string
  • func (m *Context) GetResolvedLocks() []uint64
  • func (m *Context) GetResourceControlContext() *ResourceControlContext
  • func (m *Context) GetResourceGroupTag() []byte
  • func (m *Context) GetSourceStmt() *SourceStmt
  • func (m *Context) GetStaleRead() bool
  • func (m *Context) GetSyncLog() bool
  • func (m *Context) GetTaskId() uint64
  • func (m *Context) GetTerm() uint64
  • func (m *Context) GetTraceContext() *tracepb.TraceContext
  • func (m *Context) GetTxnSource() uint64
  • func (m *Context) Marshal() (dAtA []byte, err error)
  • func (m *Context) MarshalTo(dAtA []byte) (int, error)
  • func (m *Context) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Context) ProtoMessage()
  • func (m *Context) Reset()
  • func (m *Context) Size() (n int)
  • func (m *Context) String() string
  • func (m *Context) Unmarshal(dAtA []byte) error
  • func (m *Context) XXX_DiscardUnknown()
  • func (m *Context) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Context) XXX_Merge(src proto.Message)
  • func (m *Context) XXX_Size() int
  • func (m *Context) XXX_Unmarshal(b []byte) error
• type Deadlock
  • func (*Deadlock) Descriptor() ([]byte, []int)
  • func (m *Deadlock) GetDeadlockKeyHash() uint64
  • func (m *Deadlock) GetLockKey() []byte
  • func (m *Deadlock) GetLockTs() uint64
  • func (m *Deadlock) GetWaitChain() []*deadlock.WaitForEntry
  • func (m *Deadlock) Marshal() (dAtA []byte, err error)
  • func (m *Deadlock) MarshalTo(dAtA []byte) (int, error)
  • func (m *Deadlock) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Deadlock) ProtoMessage()
  • func (m *Deadlock) Reset()
  • func (m *Deadlock) Size() (n int)
  • func (m *Deadlock) String() string
  • func (m *Deadlock) Unmarshal(dAtA []byte) error
  • func (m *Deadlock) XXX_DiscardUnknown()
  • func (m *Deadlock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Deadlock) XXX_Merge(src proto.Message)
  • func (m *Deadlock) XXX_Size() int
  • func (m *Deadlock) XXX_Unmarshal(b []byte) error
• type DeleteRangeRequest
  • func (*DeleteRangeRequest) Descriptor() ([]byte, []int)
  • func (m *DeleteRangeRequest) GetContext() *Context
  • func (m *DeleteRangeRequest) GetEndKey() []byte
  • func (m *DeleteRangeRequest) GetNotifyOnly() bool
  • func (m *DeleteRangeRequest) GetStartKey() []byte
  • func (m *DeleteRangeRequest) Marshal() (dAtA []byte, err error)
  • func (m *DeleteRangeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *DeleteRangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DeleteRangeRequest) ProtoMessage()
  • func (m *DeleteRangeRequest) Reset()
  • func (m *DeleteRangeRequest) Size() (n int)
  • func (m *DeleteRangeRequest) String() string
  • func (m *DeleteRangeRequest) Unmarshal(dAtA []byte) error
  • func (m *DeleteRangeRequest) XXX_DiscardUnknown()
  • func (m *DeleteRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DeleteRangeRequest) XXX_Merge(src proto.Message)
  • func (m *DeleteRangeRequest) XXX_Size() int
  • func (m *DeleteRangeRequest) XXX_Unmarshal(b []byte) error
• type DeleteRangeResponse
  • func (*DeleteRangeResponse) Descriptor() ([]byte, []int)
  • func (m *DeleteRangeResponse) GetError() string
  • func (m *DeleteRangeResponse) GetRegionError() *errorpb.Error
  • func (m *DeleteRangeResponse) Marshal() (dAtA []byte, err error)
  • func (m *DeleteRangeResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *DeleteRangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DeleteRangeResponse) ProtoMessage()
  • func (m *DeleteRangeResponse) Reset()
  • func (m *DeleteRangeResponse) Size() (n int)
  • func (m *DeleteRangeResponse) String() string
  • func (m *DeleteRangeResponse) Unmarshal(dAtA []byte) error
  • func (m *DeleteRangeResponse) XXX_DiscardUnknown()
  • func (m *DeleteRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DeleteRangeResponse) XXX_Merge(src proto.Message)
  • func (m *DeleteRangeResponse) XXX_Size() int
  • func (m *DeleteRangeResponse) XXX_Unmarshal(b []byte) error
• type DiskFullOpt
  • func (DiskFullOpt) EnumDescriptor() ([]byte, []int)
  • func (x DiskFullOpt) String() string
• type ExecDetails
  • func (*ExecDetails) Descriptor() ([]byte, []int)
  • func (m *ExecDetails) GetScanDetail() *ScanDetail
  • func (m *ExecDetails) GetTimeDetail() *TimeDetail
  • func (m *ExecDetails) Marshal() (dAtA []byte, err error)
  • func (m *ExecDetails) MarshalTo(dAtA []byte) (int, error)
  • func (m *ExecDetails) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ExecDetails) ProtoMessage()
  • func (m *ExecDetails) Reset()
  • func (m *ExecDetails) Size() (n int)
  • func (m *ExecDetails) String() string
  • func (m *ExecDetails) Unmarshal(dAtA []byte) error
  • func (m *ExecDetails) XXX_DiscardUnknown()
  • func (m *ExecDetails) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ExecDetails) XXX_Merge(src proto.Message)
  • func (m *ExecDetails) XXX_Size() int
  • func (m *ExecDetails) XXX_Unmarshal(b []byte) error
• type ExecDetailsV2
  • func (*ExecDetailsV2) Descriptor() ([]byte, []int)
  • func (m *ExecDetailsV2) GetScanDetailV2() *ScanDetailV2
  • func (m *ExecDetailsV2) GetTimeDetail() *TimeDetail
  • func (m *ExecDetailsV2) GetTimeDetailV2() *TimeDetailV2
  • func (m *ExecDetailsV2) GetWriteDetail() *WriteDetail
  • func (m *ExecDetailsV2) Marshal() (dAtA []byte, err error)
  • func (m *ExecDetailsV2) MarshalTo(dAtA []byte) (int, error)
  • func (m *ExecDetailsV2) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ExecDetailsV2) ProtoMessage()
  • func (m *ExecDetailsV2) Reset()
  • func (m *ExecDetailsV2) Size() (n int)
  • func (m *ExecDetailsV2) String() string
  • func (m *ExecDetailsV2) Unmarshal(dAtA []byte) error
  • func (m *ExecDetailsV2) XXX_DiscardUnknown()
  • func (m *ExecDetailsV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ExecDetailsV2) XXX_Merge(src proto.Message)
  • func (m *ExecDetailsV2) XXX_Size() int
  • func (m *ExecDetailsV2) XXX_Unmarshal(b []byte) error
• type ExtraOp
  • func (ExtraOp) EnumDescriptor() ([]byte, []int)
  • func (x ExtraOp) String() string
• type FlashbackToVersionRequest
  • func (*FlashbackToVersionRequest) Descriptor() ([]byte, []int)
  • func (m *FlashbackToVersionRequest) GetCommitTs() uint64
  • func (m *FlashbackToVersionRequest) GetContext() *Context
  • func (m *FlashbackToVersionRequest) GetEndKey() []byte
  • func (m *FlashbackToVersionRequest) GetStartKey() []byte
  • func (m *FlashbackToVersionRequest) GetStartTs() uint64
  • func (m *FlashbackToVersionRequest) GetVersion() uint64
  • func (m *FlashbackToVersionRequest) Marshal() (dAtA []byte, err error)
  • func (m *FlashbackToVersionRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *FlashbackToVersionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*FlashbackToVersionRequest) ProtoMessage()
  • func (m *FlashbackToVersionRequest) Reset()
  • func (m *FlashbackToVersionRequest) Size() (n int)
  • func (m *FlashbackToVersionRequest) String() string
  • func (m *FlashbackToVersionRequest) Unmarshal(dAtA []byte) error
  • func (m *FlashbackToVersionRequest) XXX_DiscardUnknown()
  • func (m *FlashbackToVersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *FlashbackToVersionRequest) XXX_Merge(src proto.Message)
  • func (m *FlashbackToVersionRequest) XXX_Size() int
  • func (m *FlashbackToVersionRequest) XXX_Unmarshal(b []byte) error
• type FlashbackToVersionResponse
  • func (*FlashbackToVersionResponse) Descriptor() ([]byte, []int)
  • func (m *FlashbackToVersionResponse) GetError() string
  • func (m *FlashbackToVersionResponse) GetRegionError() *errorpb.Error
  • func (m *FlashbackToVersionResponse) Marshal() (dAtA []byte, err error)
  • func (m *FlashbackToVersionResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *FlashbackToVersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*FlashbackToVersionResponse) ProtoMessage()
  • func (m *FlashbackToVersionResponse) Reset()
  • func (m *FlashbackToVersionResponse) Size() (n int)
  • func (m *FlashbackToVersionResponse) String() string
  • func (m *FlashbackToVersionResponse) Unmarshal(dAtA []byte) error
  • func (m *FlashbackToVersionResponse) XXX_DiscardUnknown()
  • func (m *FlashbackToVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *FlashbackToVersionResponse) XXX_Merge(src proto.Message)
  • func (m *FlashbackToVersionResponse) XXX_Size() int
  • func (m *FlashbackToVersionResponse) XXX_Unmarshal(b []byte) error
• type GCRequest
  • func (*GCRequest) Descriptor() ([]byte, []int)
  • func (m *GCRequest) GetContext() *Context
  • func (m *GCRequest) GetSafePoint() uint64
  • func (m *GCRequest) Marshal() (dAtA []byte, err error)
  • func (m *GCRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GCRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GCRequest) ProtoMessage()
  • func (m *GCRequest) Reset()
  • func (m *GCRequest) Size() (n int)
  • func (m *GCRequest) String() string
  • func (m *GCRequest) Unmarshal(dAtA []byte) error
  • func (m *GCRequest) XXX_DiscardUnknown()
  • func (m *GCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GCRequest) XXX_Merge(src proto.Message)
  • func (m *GCRequest) XXX_Size() int
  • func (m *GCRequest) XXX_Unmarshal(b []byte) error
• type GCResponse
  • func (*GCResponse) Descriptor() ([]byte, []int)
  • func (m *GCResponse) GetError() *KeyError
  • func (m *GCResponse) GetRegionError() *errorpb.Error
  • func (m *GCResponse) Marshal() (dAtA []byte, err error)
  • func (m *GCResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GCResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GCResponse) ProtoMessage()
  • func (m *GCResponse) Reset()
  • func (m *GCResponse) Size() (n int)
  • func (m *GCResponse) String() string
  • func (m *GCResponse) Unmarshal(dAtA []byte) error
  • func (m *GCResponse) XXX_DiscardUnknown()
  • func (m *GCResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GCResponse) XXX_Merge(src proto.Message)
  • func (m *GCResponse) XXX_Size() int
  • func (m *GCResponse) XXX_Unmarshal(b []byte) error
• type GetLockWaitHistoryRequest
  • func (*GetLockWaitHistoryRequest) Descriptor() ([]byte, []int)
  • func (m *GetLockWaitHistoryRequest) GetContext() *Context
  • func (m *GetLockWaitHistoryRequest) Marshal() (dAtA []byte, err error)
  • func (m *GetLockWaitHistoryRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetLockWaitHistoryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetLockWaitHistoryRequest) ProtoMessage()
  • func (m *GetLockWaitHistoryRequest) Reset()
  • func (m *GetLockWaitHistoryRequest) Size() (n int)
  • func (m *GetLockWaitHistoryRequest) String() string
  • func (m *GetLockWaitHistoryRequest) Unmarshal(dAtA []byte) error
  • func (m *GetLockWaitHistoryRequest) XXX_DiscardUnknown()
  • func (m *GetLockWaitHistoryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetLockWaitHistoryRequest) XXX_Merge(src proto.Message)
  • func (m *GetLockWaitHistoryRequest) XXX_Size() int
  • func (m *GetLockWaitHistoryRequest) XXX_Unmarshal(b []byte) error
• type GetLockWaitHistoryResponse
  • func (*GetLockWaitHistoryResponse) Descriptor() ([]byte, []int)
  • func (m *GetLockWaitHistoryResponse) GetEntries() []*deadlock.WaitForEntry
  • func (m *GetLockWaitHistoryResponse) GetError() string
  • func (m *GetLockWaitHistoryResponse) GetRegionError() *errorpb.Error
  • func (m *GetLockWaitHistoryResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetLockWaitHistoryResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetLockWaitHistoryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetLockWaitHistoryResponse) ProtoMessage()
  • func (m *GetLockWaitHistoryResponse) Reset()
  • func (m *GetLockWaitHistoryResponse) Size() (n int)
  • func (m *GetLockWaitHistoryResponse) String() string
  • func (m *GetLockWaitHistoryResponse) Unmarshal(dAtA []byte) error
  • func (m *GetLockWaitHistoryResponse) XXX_DiscardUnknown()
  • func (m *GetLockWaitHistoryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetLockWaitHistoryResponse) XXX_Merge(src proto.Message)
  • func (m *GetLockWaitHistoryResponse) XXX_Size() int
  • func (m *GetLockWaitHistoryResponse) XXX_Unmarshal(b []byte) error
• type GetLockWaitInfoRequest
  • func (*GetLockWaitInfoRequest) Descriptor() ([]byte, []int)
  • func (m *GetLockWaitInfoRequest) GetContext() *Context
  • func (m *GetLockWaitInfoRequest) Marshal() (dAtA []byte, err error)
  • func (m *GetLockWaitInfoRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetLockWaitInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetLockWaitInfoRequest) ProtoMessage()
  • func (m *GetLockWaitInfoRequest) Reset()
  • func (m *GetLockWaitInfoRequest) Size() (n int)
  • func (m *GetLockWaitInfoRequest) String() string
  • func (m *GetLockWaitInfoRequest) Unmarshal(dAtA []byte) error
  • func (m *GetLockWaitInfoRequest) XXX_DiscardUnknown()
  • func (m *GetLockWaitInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetLockWaitInfoRequest) XXX_Merge(src proto.Message)
  • func (m *GetLockWaitInfoRequest) XXX_Size() int
  • func (m *GetLockWaitInfoRequest) XXX_Unmarshal(b []byte) error
• type GetLockWaitInfoResponse
  • func (*GetLockWaitInfoResponse) Descriptor() ([]byte, []int)
  • func (m *GetLockWaitInfoResponse) GetEntries() []*deadlock.WaitForEntry
  • func (m *GetLockWaitInfoResponse) GetError() string
  • func (m *GetLockWaitInfoResponse) GetRegionError() *errorpb.Error
  • func (m *GetLockWaitInfoResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetLockWaitInfoResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetLockWaitInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetLockWaitInfoResponse) ProtoMessage()
  • func (m *GetLockWaitInfoResponse) Reset()
  • func (m *GetLockWaitInfoResponse) Size() (n int)
  • func (m *GetLockWaitInfoResponse) String() string
  • func (m *GetLockWaitInfoResponse) Unmarshal(dAtA []byte) error
  • func (m *GetLockWaitInfoResponse) XXX_DiscardUnknown()
  • func (m *GetLockWaitInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetLockWaitInfoResponse) XXX_Merge(src proto.Message)
  • func (m *GetLockWaitInfoResponse) XXX_Size() int
  • func (m *GetLockWaitInfoResponse) XXX_Unmarshal(b []byte) error
• type GetRequest
  • func (*GetRequest) Descriptor() ([]byte, []int)
  • func (m *GetRequest) GetContext() *Context
  • func (m *GetRequest) GetKey() []byte
  • func (m *GetRequest) GetVersion() uint64
  • func (m *GetRequest) Marshal() (dAtA []byte, err error)
  • func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetRequest) ProtoMessage()
  • func (m *GetRequest) Reset()
  • func (m *GetRequest) Size() (n int)
  • func (m *GetRequest) String() string
  • func (m *GetRequest) Unmarshal(dAtA []byte) error
  • func (m *GetRequest) XXX_DiscardUnknown()
  • func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetRequest) XXX_Merge(src proto.Message)
  • func (m *GetRequest) XXX_Size() int
  • func (m *GetRequest) XXX_Unmarshal(b []byte) error
• type GetResponse
  • func (*GetResponse) Descriptor() ([]byte, []int)
  • func (m *GetResponse) GetError() *KeyError
  • func (m *GetResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *GetResponse) GetNotFound() bool
  • func (m *GetResponse) GetRegionError() *errorpb.Error
  • func (m *GetResponse) GetValue() []byte
  • func (m *GetResponse) Marshal() (dAtA []byte, err error)
  • func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GetResponse) ProtoMessage()
  • func (m *GetResponse) Reset()
  • func (m *GetResponse) Size() (n int)
  • func (m *GetResponse) String() string
  • func (m *GetResponse) Unmarshal(dAtA []byte) error
  • func (m *GetResponse) XXX_DiscardUnknown()
  • func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GetResponse) XXX_Merge(src proto.Message)
  • func (m *GetResponse) XXX_Size() int
  • func (m *GetResponse) XXX_Unmarshal(b []byte) error
• type ImportRequest
  • func (*ImportRequest) Descriptor() ([]byte, []int)
  • func (m *ImportRequest) GetCommitVersion() uint64
  • func (m *ImportRequest) GetMutations() []*Mutation
  • func (m *ImportRequest) Marshal() (dAtA []byte, err error)
  • func (m *ImportRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ImportRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ImportRequest) ProtoMessage()
  • func (m *ImportRequest) Reset()
  • func (m *ImportRequest) Size() (n int)
  • func (m *ImportRequest) String() string
  • func (m *ImportRequest) Unmarshal(dAtA []byte) error
  • func (m *ImportRequest) XXX_DiscardUnknown()
  • func (m *ImportRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ImportRequest) XXX_Merge(src proto.Message)
  • func (m *ImportRequest) XXX_Size() int
  • func (m *ImportRequest) XXX_Unmarshal(b []byte) error
• type ImportResponse
  • func (*ImportResponse) Descriptor() ([]byte, []int)
  • func (m *ImportResponse) GetError() string
  • func (m *ImportResponse) GetRegionError() *errorpb.Error
  • func (m *ImportResponse) Marshal() (dAtA []byte, err error)
  • func (m *ImportResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ImportResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ImportResponse) ProtoMessage()
  • func (m *ImportResponse) Reset()
  • func (m *ImportResponse) Size() (n int)
  • func (m *ImportResponse) String() string
  • func (m *ImportResponse) Unmarshal(dAtA []byte) error
  • func (m *ImportResponse) XXX_DiscardUnknown()
  • func (m *ImportResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ImportResponse) XXX_Merge(src proto.Message)
  • func (m *ImportResponse) XXX_Size() int
  • func (m *ImportResponse) XXX_Unmarshal(b []byte) error
• type IsolationLevel
  • func (IsolationLevel) EnumDescriptor() ([]byte, []int)
  • func (x IsolationLevel) String() string
• type KeyError
  • func (*KeyError) Descriptor() ([]byte, []int)
  • func (m *KeyError) GetAbort() string
  • func (m *KeyError) GetAlreadyExist() *AlreadyExist
  • func (m *KeyError) GetAssertionFailed() *AssertionFailed
  • func (m *KeyError) GetCommitTsExpired() *CommitTsExpired
  • func (m *KeyError) GetCommitTsTooLarge() *CommitTsTooLarge
  • func (m *KeyError) GetConflict() *WriteConflict
  • func (m *KeyError) GetDeadlock() *Deadlock
  • func (m *KeyError) GetLocked() *LockInfo
  • func (m *KeyError) GetPrimaryMismatch() *PrimaryMismatch
  • func (m *KeyError) GetRetryable() string
  • func (m *KeyError) GetTxnNotFound() *TxnNotFound
  • func (m *KeyError) Marshal() (dAtA []byte, err error)
  • func (m *KeyError) MarshalTo(dAtA []byte) (int, error)
  • func (m *KeyError) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*KeyError) ProtoMessage()
  • func (m *KeyError) Reset()
  • func (m *KeyError) Size() (n int)
  • func (m *KeyError) String() string
  • func (m *KeyError) Unmarshal(dAtA []byte) error
  • func (m *KeyError) XXX_DiscardUnknown()
  • func (m *KeyError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *KeyError) XXX_Merge(src proto.Message)
  • func (m *KeyError) XXX_Size() int
  • func (m *KeyError) XXX_Unmarshal(b []byte) error
• type KeyRange
  • func (*KeyRange) Descriptor() ([]byte, []int)
  • func (m *KeyRange) GetEndKey() []byte
  • func (m *KeyRange) GetStartKey() []byte
  • func (m *KeyRange) Marshal() (dAtA []byte, err error)
  • func (m *KeyRange) MarshalTo(dAtA []byte) (int, error)
  • func (m *KeyRange) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*KeyRange) ProtoMessage()
  • func (m *KeyRange) Reset()
  • func (m *KeyRange) Size() (n int)
  • func (m *KeyRange) String() string
  • func (m *KeyRange) Unmarshal(dAtA []byte) error
  • func (m *KeyRange) XXX_DiscardUnknown()
  • func (m *KeyRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *KeyRange) XXX_Merge(src proto.Message)
  • func (m *KeyRange) XXX_Size() int
  • func (m *KeyRange) XXX_Unmarshal(b []byte) error
• type KvPair
  • func (*KvPair) Descriptor() ([]byte, []int)
  • func (m *KvPair) GetError() *KeyError
  • func (m *KvPair) GetKey() []byte
  • func (m *KvPair) GetValue() []byte
  • func (m *KvPair) Marshal() (dAtA []byte, err error)
  • func (m *KvPair) MarshalTo(dAtA []byte) (int, error)
  • func (m *KvPair) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*KvPair) ProtoMessage()
  • func (m *KvPair) Reset()
  • func (m *KvPair) Size() (n int)
  • func (m *KvPair) String() string
  • func (m *KvPair) Unmarshal(dAtA []byte) error
  • func (m *KvPair) XXX_DiscardUnknown()
  • func (m *KvPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *KvPair) XXX_Merge(src proto.Message)
  • func (m *KvPair) XXX_Size() int
  • func (m *KvPair) XXX_Unmarshal(b []byte) error
• type LeaderInfo
  • func (*LeaderInfo) Descriptor() ([]byte, []int)
  • func (m *LeaderInfo) GetPeerId() uint64
  • func (m *LeaderInfo) GetReadState() *ReadState
  • func (m *LeaderInfo) GetRegionEpoch() *metapb.RegionEpoch
  • func (m *LeaderInfo) GetRegionId() uint64
  • func (m *LeaderInfo) GetTerm() uint64
  • func (m *LeaderInfo) Marshal() (dAtA []byte, err error)
  • func (m *LeaderInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *LeaderInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*LeaderInfo) ProtoMessage()
  • func (m *LeaderInfo) Reset()
  • func (m *LeaderInfo) Size() (n int)
  • func (m *LeaderInfo) String() string
  • func (m *LeaderInfo) Unmarshal(dAtA []byte) error
  • func (m *LeaderInfo) XXX_DiscardUnknown()
  • func (m *LeaderInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *LeaderInfo) XXX_Merge(src proto.Message)
  • func (m *LeaderInfo) XXX_Size() int
  • func (m *LeaderInfo) XXX_Unmarshal(b []byte) error
• type LockInfo
  • func (*LockInfo) Descriptor() ([]byte, []int)
  • func (m *LockInfo) GetDurationToLastUpdateMs() uint64
  • func (m *LockInfo) GetKey() []byte
  • func (m *LockInfo) GetLockForUpdateTs() uint64
  • func (m *LockInfo) GetLockTtl() uint64
  • func (m *LockInfo) GetLockType() Op
  • func (m *LockInfo) GetLockVersion() uint64
  • func (m *LockInfo) GetMinCommitTs() uint64
  • func (m *LockInfo) GetPrimaryLock() []byte
  • func (m *LockInfo) GetSecondaries() [][]byte
  • func (m *LockInfo) GetTxnSize() uint64
  • func (m *LockInfo) GetUseAsyncCommit() bool
  • func (m *LockInfo) Marshal() (dAtA []byte, err error)
  • func (m *LockInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *LockInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*LockInfo) ProtoMessage()
  • func (m *LockInfo) Reset()
  • func (m *LockInfo) Size() (n int)
  • func (m *LockInfo) String() string
  • func (m *LockInfo) Unmarshal(dAtA []byte) error
  • func (m *LockInfo) XXX_DiscardUnknown()
  • func (m *LockInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *LockInfo) XXX_Merge(src proto.Message)
  • func (m *LockInfo) XXX_Size() int
  • func (m *LockInfo) XXX_Unmarshal(b []byte) error
• type Mutation
  • func (*Mutation) Descriptor() ([]byte, []int)
  • func (m *Mutation) GetAssertion() Assertion
  • func (m *Mutation) GetKey() []byte
  • func (m *Mutation) GetOp() Op
  • func (m *Mutation) GetValue() []byte
  • func (m *Mutation) Marshal() (dAtA []byte, err error)
  • func (m *Mutation) MarshalTo(dAtA []byte) (int, error)
  • func (m *Mutation) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Mutation) ProtoMessage()
  • func (m *Mutation) Reset()
  • func (m *Mutation) Size() (n int)
  • func (m *Mutation) String() string
  • func (m *Mutation) Unmarshal(dAtA []byte) error
  • func (m *Mutation) XXX_DiscardUnknown()
  • func (m *Mutation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Mutation) XXX_Merge(src proto.Message)
  • func (m *Mutation) XXX_Size() int
  • func (m *Mutation) XXX_Unmarshal(b []byte) error
• type MvccGetByKeyRequest
  • func (*MvccGetByKeyRequest) Descriptor() ([]byte, []int)
  • func (m *MvccGetByKeyRequest) GetContext() *Context
  • func (m *MvccGetByKeyRequest) GetKey() []byte
  • func (m *MvccGetByKeyRequest) Marshal() (dAtA []byte, err error)
  • func (m *MvccGetByKeyRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *MvccGetByKeyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MvccGetByKeyRequest) ProtoMessage()
  • func (m *MvccGetByKeyRequest) Reset()
  • func (m *MvccGetByKeyRequest) Size() (n int)
  • func (m *MvccGetByKeyRequest) String() string
  • func (m *MvccGetByKeyRequest) Unmarshal(dAtA []byte) error
  • func (m *MvccGetByKeyRequest) XXX_DiscardUnknown()
  • func (m *MvccGetByKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MvccGetByKeyRequest) XXX_Merge(src proto.Message)
  • func (m *MvccGetByKeyRequest) XXX_Size() int
  • func (m *MvccGetByKeyRequest) XXX_Unmarshal(b []byte) error
• type MvccGetByKeyResponse
  • func (*MvccGetByKeyResponse) Descriptor() ([]byte, []int)
  • func (m *MvccGetByKeyResponse) GetError() string
  • func (m *MvccGetByKeyResponse) GetInfo() *MvccInfo
  • func (m *MvccGetByKeyResponse) GetRegionError() *errorpb.Error
  • func (m *MvccGetByKeyResponse) Marshal() (dAtA []byte, err error)
  • func (m *MvccGetByKeyResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *MvccGetByKeyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MvccGetByKeyResponse) ProtoMessage()
  • func (m *MvccGetByKeyResponse) Reset()
  • func (m *MvccGetByKeyResponse) Size() (n int)
  • func (m *MvccGetByKeyResponse) String() string
  • func (m *MvccGetByKeyResponse) Unmarshal(dAtA []byte) error
  • func (m *MvccGetByKeyResponse) XXX_DiscardUnknown()
  • func (m *MvccGetByKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MvccGetByKeyResponse) XXX_Merge(src proto.Message)
  • func (m *MvccGetByKeyResponse) XXX_Size() int
  • func (m *MvccGetByKeyResponse) XXX_Unmarshal(b []byte) error
• type MvccGetByStartTsRequest
  • func (*MvccGetByStartTsRequest) Descriptor() ([]byte, []int)
  • func (m *MvccGetByStartTsRequest) GetContext() *Context
  • func (m *MvccGetByStartTsRequest) GetStartTs() uint64
  • func (m *MvccGetByStartTsRequest) Marshal() (dAtA []byte, err error)
  • func (m *MvccGetByStartTsRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *MvccGetByStartTsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MvccGetByStartTsRequest) ProtoMessage()
  • func (m *MvccGetByStartTsRequest) Reset()
  • func (m *MvccGetByStartTsRequest) Size() (n int)
  • func (m *MvccGetByStartTsRequest) String() string
  • func (m *MvccGetByStartTsRequest) Unmarshal(dAtA []byte) error
  • func (m *MvccGetByStartTsRequest) XXX_DiscardUnknown()
  • func (m *MvccGetByStartTsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MvccGetByStartTsRequest) XXX_Merge(src proto.Message)
  • func (m *MvccGetByStartTsRequest) XXX_Size() int
  • func (m *MvccGetByStartTsRequest) XXX_Unmarshal(b []byte) error
• type MvccGetByStartTsResponse
  • func (*MvccGetByStartTsResponse) Descriptor() ([]byte, []int)
  • func (m *MvccGetByStartTsResponse) GetError() string
  • func (m *MvccGetByStartTsResponse) GetInfo() *MvccInfo
  • func (m *MvccGetByStartTsResponse) GetKey() []byte
  • func (m *MvccGetByStartTsResponse) GetRegionError() *errorpb.Error
  • func (m *MvccGetByStartTsResponse) Marshal() (dAtA []byte, err error)
  • func (m *MvccGetByStartTsResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *MvccGetByStartTsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MvccGetByStartTsResponse) ProtoMessage()
  • func (m *MvccGetByStartTsResponse) Reset()
  • func (m *MvccGetByStartTsResponse) Size() (n int)
  • func (m *MvccGetByStartTsResponse) String() string
  • func (m *MvccGetByStartTsResponse) Unmarshal(dAtA []byte) error
  • func (m *MvccGetByStartTsResponse) XXX_DiscardUnknown()
  • func (m *MvccGetByStartTsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MvccGetByStartTsResponse) XXX_Merge(src proto.Message)
  • func (m *MvccGetByStartTsResponse) XXX_Size() int
  • func (m *MvccGetByStartTsResponse) XXX_Unmarshal(b []byte) error
• type MvccInfo
  • func (*MvccInfo) Descriptor() ([]byte, []int)
  • func (m *MvccInfo) GetLock() *MvccLock
  • func (m *MvccInfo) GetValues() []*MvccValue
  • func (m *MvccInfo) GetWrites() []*MvccWrite
  • func (m *MvccInfo) Marshal() (dAtA []byte, err error)
  • func (m *MvccInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *MvccInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MvccInfo) ProtoMessage()
  • func (m *MvccInfo) Reset()
  • func (m *MvccInfo) Size() (n int)
  • func (m *MvccInfo) String() string
  • func (m *MvccInfo) Unmarshal(dAtA []byte) error
  • func (m *MvccInfo) XXX_DiscardUnknown()
  • func (m *MvccInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MvccInfo) XXX_Merge(src proto.Message)
  • func (m *MvccInfo) XXX_Size() int
  • func (m *MvccInfo) XXX_Unmarshal(b []byte) error
• type MvccLock
  • func (*MvccLock) Descriptor() ([]byte, []int)
  • func (m *MvccLock) GetForUpdateTs() uint64
  • func (m *MvccLock) GetLastChangeTs() uint64
  • func (m *MvccLock) GetPrimary() []byte
  • func (m *MvccLock) GetRollbackTs() []uint64
  • func (m *MvccLock) GetSecondaries() [][]byte
  • func (m *MvccLock) GetShortValue() []byte
  • func (m *MvccLock) GetStartTs() uint64
  • func (m *MvccLock) GetTtl() uint64
  • func (m *MvccLock) GetTxnSize() uint64
  • func (m *MvccLock) GetType() Op
  • func (m *MvccLock) GetUseAsyncCommit() bool
  • func (m *MvccLock) GetVersionsToLastChange() uint64
  • func (m *MvccLock) Marshal() (dAtA []byte, err error)
  • func (m *MvccLock) MarshalTo(dAtA []byte) (int, error)
  • func (m *MvccLock) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MvccLock) ProtoMessage()
  • func (m *MvccLock) Reset()
  • func (m *MvccLock) Size() (n int)
  • func (m *MvccLock) String() string
  • func (m *MvccLock) Unmarshal(dAtA []byte) error
  • func (m *MvccLock) XXX_DiscardUnknown()
  • func (m *MvccLock) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MvccLock) XXX_Merge(src proto.Message)
  • func (m *MvccLock) XXX_Size() int
  • func (m *MvccLock) XXX_Unmarshal(b []byte) error
• type MvccValue
  • func (*MvccValue) Descriptor() ([]byte, []int)
  • func (m *MvccValue) GetStartTs() uint64
  • func (m *MvccValue) GetValue() []byte
  • func (m *MvccValue) Marshal() (dAtA []byte, err error)
  • func (m *MvccValue) MarshalTo(dAtA []byte) (int, error)
  • func (m *MvccValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MvccValue) ProtoMessage()
  • func (m *MvccValue) Reset()
  • func (m *MvccValue) Size() (n int)
  • func (m *MvccValue) String() string
  • func (m *MvccValue) Unmarshal(dAtA []byte) error
  • func (m *MvccValue) XXX_DiscardUnknown()
  • func (m *MvccValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MvccValue) XXX_Merge(src proto.Message)
  • func (m *MvccValue) XXX_Size() int
  • func (m *MvccValue) XXX_Unmarshal(b []byte) error
• type MvccWrite
  • func (*MvccWrite) Descriptor() ([]byte, []int)
  • func (m *MvccWrite) GetCommitTs() uint64
  • func (m *MvccWrite) GetGcFence() uint64
  • func (m *MvccWrite) GetHasGcFence() bool
  • func (m *MvccWrite) GetHasOverlappedRollback() bool
  • func (m *MvccWrite) GetLastChangeTs() uint64
  • func (m *MvccWrite) GetShortValue() []byte
  • func (m *MvccWrite) GetStartTs() uint64
  • func (m *MvccWrite) GetType() Op
  • func (m *MvccWrite) GetVersionsToLastChange() uint64
  • func (m *MvccWrite) Marshal() (dAtA []byte, err error)
  • func (m *MvccWrite) MarshalTo(dAtA []byte) (int, error)
  • func (m *MvccWrite) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MvccWrite) ProtoMessage()
  • func (m *MvccWrite) Reset()
  • func (m *MvccWrite) Size() (n int)
  • func (m *MvccWrite) String() string
  • func (m *MvccWrite) Unmarshal(dAtA []byte) error
  • func (m *MvccWrite) XXX_DiscardUnknown()
  • func (m *MvccWrite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MvccWrite) XXX_Merge(src proto.Message)
  • func (m *MvccWrite) XXX_Size() int
  • func (m *MvccWrite) XXX_Unmarshal(b []byte) error
• type Op
  • func (Op) EnumDescriptor() ([]byte, []int)
  • func (x Op) String() string
• type PessimisticLockKeyResult
  • func (*PessimisticLockKeyResult) Descriptor() ([]byte, []int)
  • func (m *PessimisticLockKeyResult) GetExistence() bool
  • func (m *PessimisticLockKeyResult) GetLockedWithConflictTs() uint64
  • func (m *PessimisticLockKeyResult) GetSkipResolvingLock() bool
  • func (m *PessimisticLockKeyResult) GetType() PessimisticLockKeyResultType
  • func (m *PessimisticLockKeyResult) GetValue() []byte
  • func (m *PessimisticLockKeyResult) Marshal() (dAtA []byte, err error)
  • func (m *PessimisticLockKeyResult) MarshalTo(dAtA []byte) (int, error)
  • func (m *PessimisticLockKeyResult) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PessimisticLockKeyResult) ProtoMessage()
  • func (m *PessimisticLockKeyResult) Reset()
  • func (m *PessimisticLockKeyResult) Size() (n int)
  • func (m *PessimisticLockKeyResult) String() string
  • func (m *PessimisticLockKeyResult) Unmarshal(dAtA []byte) error
  • func (m *PessimisticLockKeyResult) XXX_DiscardUnknown()
  • func (m *PessimisticLockKeyResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PessimisticLockKeyResult) XXX_Merge(src proto.Message)
  • func (m *PessimisticLockKeyResult) XXX_Size() int
  • func (m *PessimisticLockKeyResult) XXX_Unmarshal(b []byte) error
• type PessimisticLockKeyResultType
  • func (PessimisticLockKeyResultType) EnumDescriptor() ([]byte, []int)
  • func (x PessimisticLockKeyResultType) String() string
• type PessimisticLockRequest
  • func (*PessimisticLockRequest) Descriptor() ([]byte, []int)
  • func (m *PessimisticLockRequest) GetCheckExistence() bool
  • func (m *PessimisticLockRequest) GetContext() *Context
  • func (m *PessimisticLockRequest) GetForUpdateTs() uint64
  • func (m *PessimisticLockRequest) GetForce() bool
  • func (m *PessimisticLockRequest) GetIsFirstLock() bool
  • func (m *PessimisticLockRequest) GetLockOnlyIfExists() bool
  • func (m *PessimisticLockRequest) GetLockTtl() uint64
  • func (m *PessimisticLockRequest) GetMinCommitTs() uint64
  • func (m *PessimisticLockRequest) GetMutations() []*Mutation
  • func (m *PessimisticLockRequest) GetPrimaryLock() []byte
  • func (m *PessimisticLockRequest) GetReturnValues() bool
  • func (m *PessimisticLockRequest) GetStartVersion() uint64
  • func (m *PessimisticLockRequest) GetWaitTimeout() int64
  • func (m *PessimisticLockRequest) GetWakeUpMode() PessimisticLockWakeUpMode
  • func (m *PessimisticLockRequest) Marshal() (dAtA []byte, err error)
  • func (m *PessimisticLockRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *PessimisticLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PessimisticLockRequest) ProtoMessage()
  • func (m *PessimisticLockRequest) Reset()
  • func (m *PessimisticLockRequest) Size() (n int)
  • func (m *PessimisticLockRequest) String() string
  • func (m *PessimisticLockRequest) Unmarshal(dAtA []byte) error
  • func (m *PessimisticLockRequest) XXX_DiscardUnknown()
  • func (m *PessimisticLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PessimisticLockRequest) XXX_Merge(src proto.Message)
  • func (m *PessimisticLockRequest) XXX_Size() int
  • func (m *PessimisticLockRequest) XXX_Unmarshal(b []byte) error
• type PessimisticLockResponse
  • func (*PessimisticLockResponse) Descriptor() ([]byte, []int)
  • func (m *PessimisticLockResponse) GetCommitTs() uint64
  • func (m *PessimisticLockResponse) GetErrors() []*KeyError
  • func (m *PessimisticLockResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *PessimisticLockResponse) GetNotFounds() []bool
  • func (m *PessimisticLockResponse) GetRegionError() *errorpb.Error
  • func (m *PessimisticLockResponse) GetResults() []*PessimisticLockKeyResult
  • func (m *PessimisticLockResponse) GetValue() []byte
  • func (m *PessimisticLockResponse) GetValues() [][]byte
  • func (m *PessimisticLockResponse) Marshal() (dAtA []byte, err error)
  • func (m *PessimisticLockResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *PessimisticLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PessimisticLockResponse) ProtoMessage()
  • func (m *PessimisticLockResponse) Reset()
  • func (m *PessimisticLockResponse) Size() (n int)
  • func (m *PessimisticLockResponse) String() string
  • func (m *PessimisticLockResponse) Unmarshal(dAtA []byte) error
  • func (m *PessimisticLockResponse) XXX_DiscardUnknown()
  • func (m *PessimisticLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PessimisticLockResponse) XXX_Merge(src proto.Message)
  • func (m *PessimisticLockResponse) XXX_Size() int
  • func (m *PessimisticLockResponse) XXX_Unmarshal(b []byte) error
• type PessimisticLockWakeUpMode
  • func (PessimisticLockWakeUpMode) EnumDescriptor() ([]byte, []int)
  • func (x PessimisticLockWakeUpMode) String() string
• type PessimisticRollbackRequest
  • func (*PessimisticRollbackRequest) Descriptor() ([]byte, []int)
  • func (m *PessimisticRollbackRequest) GetContext() *Context
  • func (m *PessimisticRollbackRequest) GetForUpdateTs() uint64
  • func (m *PessimisticRollbackRequest) GetKeys() [][]byte
  • func (m *PessimisticRollbackRequest) GetStartVersion() uint64
  • func (m *PessimisticRollbackRequest) Marshal() (dAtA []byte, err error)
  • func (m *PessimisticRollbackRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *PessimisticRollbackRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PessimisticRollbackRequest) ProtoMessage()
  • func (m *PessimisticRollbackRequest) Reset()
  • func (m *PessimisticRollbackRequest) Size() (n int)
  • func (m *PessimisticRollbackRequest) String() string
  • func (m *PessimisticRollbackRequest) Unmarshal(dAtA []byte) error
  • func (m *PessimisticRollbackRequest) XXX_DiscardUnknown()
  • func (m *PessimisticRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PessimisticRollbackRequest) XXX_Merge(src proto.Message)
  • func (m *PessimisticRollbackRequest) XXX_Size() int
  • func (m *PessimisticRollbackRequest) XXX_Unmarshal(b []byte) error
• type PessimisticRollbackResponse
  • func (*PessimisticRollbackResponse) Descriptor() ([]byte, []int)
  • func (m *PessimisticRollbackResponse) GetErrors() []*KeyError
  • func (m *PessimisticRollbackResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *PessimisticRollbackResponse) GetRegionError() *errorpb.Error
  • func (m *PessimisticRollbackResponse) Marshal() (dAtA []byte, err error)
  • func (m *PessimisticRollbackResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *PessimisticRollbackResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PessimisticRollbackResponse) ProtoMessage()
  • func (m *PessimisticRollbackResponse) Reset()
  • func (m *PessimisticRollbackResponse) Size() (n int)
  • func (m *PessimisticRollbackResponse) String() string
  • func (m *PessimisticRollbackResponse) Unmarshal(dAtA []byte) error
  • func (m *PessimisticRollbackResponse) XXX_DiscardUnknown()
  • func (m *PessimisticRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PessimisticRollbackResponse) XXX_Merge(src proto.Message)
  • func (m *PessimisticRollbackResponse) XXX_Size() int
  • func (m *PessimisticRollbackResponse) XXX_Unmarshal(b []byte) error
• type PhysicalScanLockRequest
  • func (*PhysicalScanLockRequest) Descriptor() ([]byte, []int)
  • func (m *PhysicalScanLockRequest) GetContext() *Context
  • func (m *PhysicalScanLockRequest) GetLimit() uint32
  • func (m *PhysicalScanLockRequest) GetMaxTs() uint64
  • func (m *PhysicalScanLockRequest) GetStartKey() []byte
  • func (m *PhysicalScanLockRequest) Marshal() (dAtA []byte, err error)
  • func (m *PhysicalScanLockRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *PhysicalScanLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PhysicalScanLockRequest) ProtoMessage()
  • func (m *PhysicalScanLockRequest) Reset()
  • func (m *PhysicalScanLockRequest) Size() (n int)
  • func (m *PhysicalScanLockRequest) String() string
  • func (m *PhysicalScanLockRequest) Unmarshal(dAtA []byte) error
  • func (m *PhysicalScanLockRequest) XXX_DiscardUnknown()
  • func (m *PhysicalScanLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PhysicalScanLockRequest) XXX_Merge(src proto.Message)
  • func (m *PhysicalScanLockRequest) XXX_Size() int
  • func (m *PhysicalScanLockRequest) XXX_Unmarshal(b []byte) error
• type PhysicalScanLockResponse
  • func (*PhysicalScanLockResponse) Descriptor() ([]byte, []int)
  • func (m *PhysicalScanLockResponse) GetError() string
  • func (m *PhysicalScanLockResponse) GetLocks() []*LockInfo
  • func (m *PhysicalScanLockResponse) Marshal() (dAtA []byte, err error)
  • func (m *PhysicalScanLockResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *PhysicalScanLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PhysicalScanLockResponse) ProtoMessage()
  • func (m *PhysicalScanLockResponse) Reset()
  • func (m *PhysicalScanLockResponse) Size() (n int)
  • func (m *PhysicalScanLockResponse) String() string
  • func (m *PhysicalScanLockResponse) Unmarshal(dAtA []byte) error
  • func (m *PhysicalScanLockResponse) XXX_DiscardUnknown()
  • func (m *PhysicalScanLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PhysicalScanLockResponse) XXX_Merge(src proto.Message)
  • func (m *PhysicalScanLockResponse) XXX_Size() int
  • func (m *PhysicalScanLockResponse) XXX_Unmarshal(b []byte) error
• type PrepareFlashbackToVersionRequest
  • func (*PrepareFlashbackToVersionRequest) Descriptor() ([]byte, []int)
  • func (m *PrepareFlashbackToVersionRequest) GetContext() *Context
  • func (m *PrepareFlashbackToVersionRequest) GetEndKey() []byte
  • func (m *PrepareFlashbackToVersionRequest) GetStartKey() []byte
  • func (m *PrepareFlashbackToVersionRequest) GetStartTs() uint64
  • func (m *PrepareFlashbackToVersionRequest) GetVersion() uint64
  • func (m *PrepareFlashbackToVersionRequest) Marshal() (dAtA []byte, err error)
  • func (m *PrepareFlashbackToVersionRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *PrepareFlashbackToVersionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PrepareFlashbackToVersionRequest) ProtoMessage()
  • func (m *PrepareFlashbackToVersionRequest) Reset()
  • func (m *PrepareFlashbackToVersionRequest) Size() (n int)
  • func (m *PrepareFlashbackToVersionRequest) String() string
  • func (m *PrepareFlashbackToVersionRequest) Unmarshal(dAtA []byte) error
  • func (m *PrepareFlashbackToVersionRequest) XXX_DiscardUnknown()
  • func (m *PrepareFlashbackToVersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PrepareFlashbackToVersionRequest) XXX_Merge(src proto.Message)
  • func (m *PrepareFlashbackToVersionRequest) XXX_Size() int
  • func (m *PrepareFlashbackToVersionRequest) XXX_Unmarshal(b []byte) error
• type PrepareFlashbackToVersionResponse
  • func (*PrepareFlashbackToVersionResponse) Descriptor() ([]byte, []int)
  • func (m *PrepareFlashbackToVersionResponse) GetError() string
  • func (m *PrepareFlashbackToVersionResponse) GetRegionError() *errorpb.Error
  • func (m *PrepareFlashbackToVersionResponse) Marshal() (dAtA []byte, err error)
  • func (m *PrepareFlashbackToVersionResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *PrepareFlashbackToVersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PrepareFlashbackToVersionResponse) ProtoMessage()
  • func (m *PrepareFlashbackToVersionResponse) Reset()
  • func (m *PrepareFlashbackToVersionResponse) Size() (n int)
  • func (m *PrepareFlashbackToVersionResponse) String() string
  • func (m *PrepareFlashbackToVersionResponse) Unmarshal(dAtA []byte) error
  • func (m *PrepareFlashbackToVersionResponse) XXX_DiscardUnknown()
  • func (m *PrepareFlashbackToVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PrepareFlashbackToVersionResponse) XXX_Merge(src proto.Message)
  • func (m *PrepareFlashbackToVersionResponse) XXX_Size() int
  • func (m *PrepareFlashbackToVersionResponse) XXX_Unmarshal(b []byte) error
• type PrewriteRequest
  • func (*PrewriteRequest) Descriptor() ([]byte, []int)
  • func (m *PrewriteRequest) GetAssertionLevel() AssertionLevel
  • func (m *PrewriteRequest) GetContext() *Context
  • func (m *PrewriteRequest) GetForUpdateTs() uint64
  • func (m *PrewriteRequest) GetForUpdateTsConstraints() []*PrewriteRequest_ForUpdateTSConstraint
  • func (m *PrewriteRequest) GetLockTtl() uint64
  • func (m *PrewriteRequest) GetMaxCommitTs() uint64
  • func (m *PrewriteRequest) GetMinCommitTs() uint64
  • func (m *PrewriteRequest) GetMutations() []*Mutation
  • func (m *PrewriteRequest) GetPessimisticActions() []PrewriteRequest_PessimisticAction
  • func (m *PrewriteRequest) GetPrimaryLock() []byte
  • func (m *PrewriteRequest) GetSecondaries() [][]byte
  • func (m *PrewriteRequest) GetSkipConstraintCheck() bool
  • func (m *PrewriteRequest) GetStartVersion() uint64
  • func (m *PrewriteRequest) GetTryOnePc() bool
  • func (m *PrewriteRequest) GetTxnSize() uint64
  • func (m *PrewriteRequest) GetUseAsyncCommit() bool
  • func (m *PrewriteRequest) Marshal() (dAtA []byte, err error)
  • func (m *PrewriteRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *PrewriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PrewriteRequest) ProtoMessage()
  • func (m *PrewriteRequest) Reset()
  • func (m *PrewriteRequest) Size() (n int)
  • func (m *PrewriteRequest) String() string
  • func (m *PrewriteRequest) Unmarshal(dAtA []byte) error
  • func (m *PrewriteRequest) XXX_DiscardUnknown()
  • func (m *PrewriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PrewriteRequest) XXX_Merge(src proto.Message)
  • func (m *PrewriteRequest) XXX_Size() int
  • func (m *PrewriteRequest) XXX_Unmarshal(b []byte) error
• type PrewriteRequest_ForUpdateTSConstraint
  • func (*PrewriteRequest_ForUpdateTSConstraint) Descriptor() ([]byte, []int)
  • func (m *PrewriteRequest_ForUpdateTSConstraint) GetExpectedForUpdateTs() uint64
  • func (m *PrewriteRequest_ForUpdateTSConstraint) GetIndex() uint32
  • func (m *PrewriteRequest_ForUpdateTSConstraint) Marshal() (dAtA []byte, err error)
  • func (m *PrewriteRequest_ForUpdateTSConstraint) MarshalTo(dAtA []byte) (int, error)
  • func (m *PrewriteRequest_ForUpdateTSConstraint) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PrewriteRequest_ForUpdateTSConstraint) ProtoMessage()
  • func (m *PrewriteRequest_ForUpdateTSConstraint) Reset()
  • func (m *PrewriteRequest_ForUpdateTSConstraint) Size() (n int)
  • func (m *PrewriteRequest_ForUpdateTSConstraint) String() string
  • func (m *PrewriteRequest_ForUpdateTSConstraint) Unmarshal(dAtA []byte) error
  • func (m *PrewriteRequest_ForUpdateTSConstraint) XXX_DiscardUnknown()
  • func (m *PrewriteRequest_ForUpdateTSConstraint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PrewriteRequest_ForUpdateTSConstraint) XXX_Merge(src proto.Message)
  • func (m *PrewriteRequest_ForUpdateTSConstraint) XXX_Size() int
  • func (m *PrewriteRequest_ForUpdateTSConstraint) XXX_Unmarshal(b []byte) error
• type PrewriteRequest_PessimisticAction
  • func (PrewriteRequest_PessimisticAction) EnumDescriptor() ([]byte, []int)
  • func (x PrewriteRequest_PessimisticAction) String() string
• type PrewriteResponse
  • func (*PrewriteResponse) Descriptor() ([]byte, []int)
  • func (m *PrewriteResponse) GetErrors() []*KeyError
  • func (m *PrewriteResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *PrewriteResponse) GetMinCommitTs() uint64
  • func (m *PrewriteResponse) GetOnePcCommitTs() uint64
  • func (m *PrewriteResponse) GetRegionError() *errorpb.Error
  • func (m *PrewriteResponse) Marshal() (dAtA []byte, err error)
  • func (m *PrewriteResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *PrewriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PrewriteResponse) ProtoMessage()
  • func (m *PrewriteResponse) Reset()
  • func (m *PrewriteResponse) Size() (n int)
  • func (m *PrewriteResponse) String() string
  • func (m *PrewriteResponse) Unmarshal(dAtA []byte) error
  • func (m *PrewriteResponse) XXX_DiscardUnknown()
  • func (m *PrewriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PrewriteResponse) XXX_Merge(src proto.Message)
  • func (m *PrewriteResponse) XXX_Size() int
  • func (m *PrewriteResponse) XXX_Unmarshal(b []byte) error
• type PrimaryMismatch
  • func (*PrimaryMismatch) Descriptor() ([]byte, []int)
  • func (m *PrimaryMismatch) GetLockInfo() *LockInfo
  • func (m *PrimaryMismatch) Marshal() (dAtA []byte, err error)
  • func (m *PrimaryMismatch) MarshalTo(dAtA []byte) (int, error)
  • func (m *PrimaryMismatch) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PrimaryMismatch) ProtoMessage()
  • func (m *PrimaryMismatch) Reset()
  • func (m *PrimaryMismatch) Size() (n int)
  • func (m *PrimaryMismatch) String() string
  • func (m *PrimaryMismatch) Unmarshal(dAtA []byte) error
  • func (m *PrimaryMismatch) XXX_DiscardUnknown()
  • func (m *PrimaryMismatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PrimaryMismatch) XXX_Merge(src proto.Message)
  • func (m *PrimaryMismatch) XXX_Size() int
  • func (m *PrimaryMismatch) XXX_Unmarshal(b []byte) error
• type RawBatchDeleteRequest
  • func (*RawBatchDeleteRequest) Descriptor() ([]byte, []int)
  • func (m *RawBatchDeleteRequest) GetCf() string
  • func (m *RawBatchDeleteRequest) GetContext() *Context
  • func (m *RawBatchDeleteRequest) GetForCas() bool
  • func (m *RawBatchDeleteRequest) GetKeys() [][]byte
  • func (m *RawBatchDeleteRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawBatchDeleteRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawBatchDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawBatchDeleteRequest) ProtoMessage()
  • func (m *RawBatchDeleteRequest) Reset()
  • func (m *RawBatchDeleteRequest) Size() (n int)
  • func (m *RawBatchDeleteRequest) String() string
  • func (m *RawBatchDeleteRequest) Unmarshal(dAtA []byte) error
  • func (m *RawBatchDeleteRequest) XXX_DiscardUnknown()
  • func (m *RawBatchDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawBatchDeleteRequest) XXX_Merge(src proto.Message)
  • func (m *RawBatchDeleteRequest) XXX_Size() int
  • func (m *RawBatchDeleteRequest) XXX_Unmarshal(b []byte) error
• type RawBatchDeleteResponse
  • func (*RawBatchDeleteResponse) Descriptor() ([]byte, []int)
  • func (m *RawBatchDeleteResponse) GetError() string
  • func (m *RawBatchDeleteResponse) GetRegionError() *errorpb.Error
  • func (m *RawBatchDeleteResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawBatchDeleteResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawBatchDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawBatchDeleteResponse) ProtoMessage()
  • func (m *RawBatchDeleteResponse) Reset()
  • func (m *RawBatchDeleteResponse) Size() (n int)
  • func (m *RawBatchDeleteResponse) String() string
  • func (m *RawBatchDeleteResponse) Unmarshal(dAtA []byte) error
  • func (m *RawBatchDeleteResponse) XXX_DiscardUnknown()
  • func (m *RawBatchDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawBatchDeleteResponse) XXX_Merge(src proto.Message)
  • func (m *RawBatchDeleteResponse) XXX_Size() int
  • func (m *RawBatchDeleteResponse) XXX_Unmarshal(b []byte) error
• type RawBatchGetRequest
  • func (*RawBatchGetRequest) Descriptor() ([]byte, []int)
  • func (m *RawBatchGetRequest) GetCf() string
  • func (m *RawBatchGetRequest) GetContext() *Context
  • func (m *RawBatchGetRequest) GetKeys() [][]byte
  • func (m *RawBatchGetRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawBatchGetRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawBatchGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawBatchGetRequest) ProtoMessage()
  • func (m *RawBatchGetRequest) Reset()
  • func (m *RawBatchGetRequest) Size() (n int)
  • func (m *RawBatchGetRequest) String() string
  • func (m *RawBatchGetRequest) Unmarshal(dAtA []byte) error
  • func (m *RawBatchGetRequest) XXX_DiscardUnknown()
  • func (m *RawBatchGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawBatchGetRequest) XXX_Merge(src proto.Message)
  • func (m *RawBatchGetRequest) XXX_Size() int
  • func (m *RawBatchGetRequest) XXX_Unmarshal(b []byte) error
• type RawBatchGetResponse
  • func (*RawBatchGetResponse) Descriptor() ([]byte, []int)
  • func (m *RawBatchGetResponse) GetPairs() []*KvPair
  • func (m *RawBatchGetResponse) GetRegionError() *errorpb.Error
  • func (m *RawBatchGetResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawBatchGetResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawBatchGetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawBatchGetResponse) ProtoMessage()
  • func (m *RawBatchGetResponse) Reset()
  • func (m *RawBatchGetResponse) Size() (n int)
  • func (m *RawBatchGetResponse) String() string
  • func (m *RawBatchGetResponse) Unmarshal(dAtA []byte) error
  • func (m *RawBatchGetResponse) XXX_DiscardUnknown()
  • func (m *RawBatchGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawBatchGetResponse) XXX_Merge(src proto.Message)
  • func (m *RawBatchGetResponse) XXX_Size() int
  • func (m *RawBatchGetResponse) XXX_Unmarshal(b []byte) error
• type RawBatchPutRequest
  • func (*RawBatchPutRequest) Descriptor() ([]byte, []int)
  • func (m *RawBatchPutRequest) GetCf() string
  • func (m *RawBatchPutRequest) GetContext() *Context
  • func (m *RawBatchPutRequest) GetForCas() bool
  • func (m *RawBatchPutRequest) GetPairs() []*KvPair
  • func (m *RawBatchPutRequest) GetTtl() uint64
  • func (m *RawBatchPutRequest) GetTtls() []uint64
  • func (m *RawBatchPutRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawBatchPutRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawBatchPutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawBatchPutRequest) ProtoMessage()
  • func (m *RawBatchPutRequest) Reset()
  • func (m *RawBatchPutRequest) Size() (n int)
  • func (m *RawBatchPutRequest) String() string
  • func (m *RawBatchPutRequest) Unmarshal(dAtA []byte) error
  • func (m *RawBatchPutRequest) XXX_DiscardUnknown()
  • func (m *RawBatchPutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawBatchPutRequest) XXX_Merge(src proto.Message)
  • func (m *RawBatchPutRequest) XXX_Size() int
  • func (m *RawBatchPutRequest) XXX_Unmarshal(b []byte) error
• type RawBatchPutResponse
  • func (*RawBatchPutResponse) Descriptor() ([]byte, []int)
  • func (m *RawBatchPutResponse) GetError() string
  • func (m *RawBatchPutResponse) GetRegionError() *errorpb.Error
  • func (m *RawBatchPutResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawBatchPutResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawBatchPutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawBatchPutResponse) ProtoMessage()
  • func (m *RawBatchPutResponse) Reset()
  • func (m *RawBatchPutResponse) Size() (n int)
  • func (m *RawBatchPutResponse) String() string
  • func (m *RawBatchPutResponse) Unmarshal(dAtA []byte) error
  • func (m *RawBatchPutResponse) XXX_DiscardUnknown()
  • func (m *RawBatchPutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawBatchPutResponse) XXX_Merge(src proto.Message)
  • func (m *RawBatchPutResponse) XXX_Size() int
  • func (m *RawBatchPutResponse) XXX_Unmarshal(b []byte) error
• type RawBatchScanRequest
  • func (*RawBatchScanRequest) Descriptor() ([]byte, []int)
  • func (m *RawBatchScanRequest) GetCf() string
  • func (m *RawBatchScanRequest) GetContext() *Context
  • func (m *RawBatchScanRequest) GetEachLimit() uint32
  • func (m *RawBatchScanRequest) GetKeyOnly() bool
  • func (m *RawBatchScanRequest) GetRanges() []*KeyRange
  • func (m *RawBatchScanRequest) GetReverse() bool
  • func (m *RawBatchScanRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawBatchScanRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawBatchScanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawBatchScanRequest) ProtoMessage()
  • func (m *RawBatchScanRequest) Reset()
  • func (m *RawBatchScanRequest) Size() (n int)
  • func (m *RawBatchScanRequest) String() string
  • func (m *RawBatchScanRequest) Unmarshal(dAtA []byte) error
  • func (m *RawBatchScanRequest) XXX_DiscardUnknown()
  • func (m *RawBatchScanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawBatchScanRequest) XXX_Merge(src proto.Message)
  • func (m *RawBatchScanRequest) XXX_Size() int
  • func (m *RawBatchScanRequest) XXX_Unmarshal(b []byte) error
• type RawBatchScanResponse
  • func (*RawBatchScanResponse) Descriptor() ([]byte, []int)
  • func (m *RawBatchScanResponse) GetKvs() []*KvPair
  • func (m *RawBatchScanResponse) GetRegionError() *errorpb.Error
  • func (m *RawBatchScanResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawBatchScanResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawBatchScanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawBatchScanResponse) ProtoMessage()
  • func (m *RawBatchScanResponse) Reset()
  • func (m *RawBatchScanResponse) Size() (n int)
  • func (m *RawBatchScanResponse) String() string
  • func (m *RawBatchScanResponse) Unmarshal(dAtA []byte) error
  • func (m *RawBatchScanResponse) XXX_DiscardUnknown()
  • func (m *RawBatchScanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawBatchScanResponse) XXX_Merge(src proto.Message)
  • func (m *RawBatchScanResponse) XXX_Size() int
  • func (m *RawBatchScanResponse) XXX_Unmarshal(b []byte) error
• type RawCASRequest
  • func (*RawCASRequest) Descriptor() ([]byte, []int)
  • func (m *RawCASRequest) GetCf() string
  • func (m *RawCASRequest) GetContext() *Context
  • func (m *RawCASRequest) GetKey() []byte
  • func (m *RawCASRequest) GetPreviousNotExist() bool
  • func (m *RawCASRequest) GetPreviousValue() []byte
  • func (m *RawCASRequest) GetTtl() uint64
  • func (m *RawCASRequest) GetValue() []byte
  • func (m *RawCASRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawCASRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawCASRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawCASRequest) ProtoMessage()
  • func (m *RawCASRequest) Reset()
  • func (m *RawCASRequest) Size() (n int)
  • func (m *RawCASRequest) String() string
  • func (m *RawCASRequest) Unmarshal(dAtA []byte) error
  • func (m *RawCASRequest) XXX_DiscardUnknown()
  • func (m *RawCASRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawCASRequest) XXX_Merge(src proto.Message)
  • func (m *RawCASRequest) XXX_Size() int
  • func (m *RawCASRequest) XXX_Unmarshal(b []byte) error
• type RawCASResponse
  • func (*RawCASResponse) Descriptor() ([]byte, []int)
  • func (m *RawCASResponse) GetError() string
  • func (m *RawCASResponse) GetPreviousNotExist() bool
  • func (m *RawCASResponse) GetPreviousValue() []byte
  • func (m *RawCASResponse) GetRegionError() *errorpb.Error
  • func (m *RawCASResponse) GetSucceed() bool
  • func (m *RawCASResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawCASResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawCASResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawCASResponse) ProtoMessage()
  • func (m *RawCASResponse) Reset()
  • func (m *RawCASResponse) Size() (n int)
  • func (m *RawCASResponse) String() string
  • func (m *RawCASResponse) Unmarshal(dAtA []byte) error
  • func (m *RawCASResponse) XXX_DiscardUnknown()
  • func (m *RawCASResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawCASResponse) XXX_Merge(src proto.Message)
  • func (m *RawCASResponse) XXX_Size() int
  • func (m *RawCASResponse) XXX_Unmarshal(b []byte) error
• type RawChecksumRequest
  • func (*RawChecksumRequest) Descriptor() ([]byte, []int)
  • func (m *RawChecksumRequest) GetAlgorithm() ChecksumAlgorithm
  • func (m *RawChecksumRequest) GetContext() *Context
  • func (m *RawChecksumRequest) GetRanges() []*KeyRange
  • func (m *RawChecksumRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawChecksumRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawChecksumRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawChecksumRequest) ProtoMessage()
  • func (m *RawChecksumRequest) Reset()
  • func (m *RawChecksumRequest) Size() (n int)
  • func (m *RawChecksumRequest) String() string
  • func (m *RawChecksumRequest) Unmarshal(dAtA []byte) error
  • func (m *RawChecksumRequest) XXX_DiscardUnknown()
  • func (m *RawChecksumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawChecksumRequest) XXX_Merge(src proto.Message)
  • func (m *RawChecksumRequest) XXX_Size() int
  • func (m *RawChecksumRequest) XXX_Unmarshal(b []byte) error
• type RawChecksumResponse
  • func (*RawChecksumResponse) Descriptor() ([]byte, []int)
  • func (m *RawChecksumResponse) GetChecksum() uint64
  • func (m *RawChecksumResponse) GetError() string
  • func (m *RawChecksumResponse) GetRegionError() *errorpb.Error
  • func (m *RawChecksumResponse) GetTotalBytes() uint64
  • func (m *RawChecksumResponse) GetTotalKvs() uint64
  • func (m *RawChecksumResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawChecksumResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawChecksumResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawChecksumResponse) ProtoMessage()
  • func (m *RawChecksumResponse) Reset()
  • func (m *RawChecksumResponse) Size() (n int)
  • func (m *RawChecksumResponse) String() string
  • func (m *RawChecksumResponse) Unmarshal(dAtA []byte) error
  • func (m *RawChecksumResponse) XXX_DiscardUnknown()
  • func (m *RawChecksumResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawChecksumResponse) XXX_Merge(src proto.Message)
  • func (m *RawChecksumResponse) XXX_Size() int
  • func (m *RawChecksumResponse) XXX_Unmarshal(b []byte) error
• type RawCoprocessorRequest
  • func (*RawCoprocessorRequest) Descriptor() ([]byte, []int)
  • func (m *RawCoprocessorRequest) GetContext() *Context
  • func (m *RawCoprocessorRequest) GetCoprName() string
  • func (m *RawCoprocessorRequest) GetCoprVersionReq() string
  • func (m *RawCoprocessorRequest) GetData() []byte
  • func (m *RawCoprocessorRequest) GetRanges() []*KeyRange
  • func (m *RawCoprocessorRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawCoprocessorRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawCoprocessorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawCoprocessorRequest) ProtoMessage()
  • func (m *RawCoprocessorRequest) Reset()
  • func (m *RawCoprocessorRequest) Size() (n int)
  • func (m *RawCoprocessorRequest) String() string
  • func (m *RawCoprocessorRequest) Unmarshal(dAtA []byte) error
  • func (m *RawCoprocessorRequest) XXX_DiscardUnknown()
  • func (m *RawCoprocessorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawCoprocessorRequest) XXX_Merge(src proto.Message)
  • func (m *RawCoprocessorRequest) XXX_Size() int
  • func (m *RawCoprocessorRequest) XXX_Unmarshal(b []byte) error
• type RawCoprocessorResponse
  • func (*RawCoprocessorResponse) Descriptor() ([]byte, []int)
  • func (m *RawCoprocessorResponse) GetData() []byte
  • func (m *RawCoprocessorResponse) GetError() string
  • func (m *RawCoprocessorResponse) GetRegionError() *errorpb.Error
  • func (m *RawCoprocessorResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawCoprocessorResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawCoprocessorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawCoprocessorResponse) ProtoMessage()
  • func (m *RawCoprocessorResponse) Reset()
  • func (m *RawCoprocessorResponse) Size() (n int)
  • func (m *RawCoprocessorResponse) String() string
  • func (m *RawCoprocessorResponse) Unmarshal(dAtA []byte) error
  • func (m *RawCoprocessorResponse) XXX_DiscardUnknown()
  • func (m *RawCoprocessorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawCoprocessorResponse) XXX_Merge(src proto.Message)
  • func (m *RawCoprocessorResponse) XXX_Size() int
  • func (m *RawCoprocessorResponse) XXX_Unmarshal(b []byte) error
• type RawDeleteRangeRequest
  • func (*RawDeleteRangeRequest) Descriptor() ([]byte, []int)
  • func (m *RawDeleteRangeRequest) GetCf() string
  • func (m *RawDeleteRangeRequest) GetContext() *Context
  • func (m *RawDeleteRangeRequest) GetEndKey() []byte
  • func (m *RawDeleteRangeRequest) GetStartKey() []byte
  • func (m *RawDeleteRangeRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawDeleteRangeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawDeleteRangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawDeleteRangeRequest) ProtoMessage()
  • func (m *RawDeleteRangeRequest) Reset()
  • func (m *RawDeleteRangeRequest) Size() (n int)
  • func (m *RawDeleteRangeRequest) String() string
  • func (m *RawDeleteRangeRequest) Unmarshal(dAtA []byte) error
  • func (m *RawDeleteRangeRequest) XXX_DiscardUnknown()
  • func (m *RawDeleteRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawDeleteRangeRequest) XXX_Merge(src proto.Message)
  • func (m *RawDeleteRangeRequest) XXX_Size() int
  • func (m *RawDeleteRangeRequest) XXX_Unmarshal(b []byte) error
• type RawDeleteRangeResponse
  • func (*RawDeleteRangeResponse) Descriptor() ([]byte, []int)
  • func (m *RawDeleteRangeResponse) GetError() string
  • func (m *RawDeleteRangeResponse) GetRegionError() *errorpb.Error
  • func (m *RawDeleteRangeResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawDeleteRangeResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawDeleteRangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawDeleteRangeResponse) ProtoMessage()
  • func (m *RawDeleteRangeResponse) Reset()
  • func (m *RawDeleteRangeResponse) Size() (n int)
  • func (m *RawDeleteRangeResponse) String() string
  • func (m *RawDeleteRangeResponse) Unmarshal(dAtA []byte) error
  • func (m *RawDeleteRangeResponse) XXX_DiscardUnknown()
  • func (m *RawDeleteRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawDeleteRangeResponse) XXX_Merge(src proto.Message)
  • func (m *RawDeleteRangeResponse) XXX_Size() int
  • func (m *RawDeleteRangeResponse) XXX_Unmarshal(b []byte) error
• type RawDeleteRequest
  • func (*RawDeleteRequest) Descriptor() ([]byte, []int)
  • func (m *RawDeleteRequest) GetCf() string
  • func (m *RawDeleteRequest) GetContext() *Context
  • func (m *RawDeleteRequest) GetForCas() bool
  • func (m *RawDeleteRequest) GetKey() []byte
  • func (m *RawDeleteRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawDeleteRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawDeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawDeleteRequest) ProtoMessage()
  • func (m *RawDeleteRequest) Reset()
  • func (m *RawDeleteRequest) Size() (n int)
  • func (m *RawDeleteRequest) String() string
  • func (m *RawDeleteRequest) Unmarshal(dAtA []byte) error
  • func (m *RawDeleteRequest) XXX_DiscardUnknown()
  • func (m *RawDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawDeleteRequest) XXX_Merge(src proto.Message)
  • func (m *RawDeleteRequest) XXX_Size() int
  • func (m *RawDeleteRequest) XXX_Unmarshal(b []byte) error
• type RawDeleteResponse
  • func (*RawDeleteResponse) Descriptor() ([]byte, []int)
  • func (m *RawDeleteResponse) GetError() string
  • func (m *RawDeleteResponse) GetRegionError() *errorpb.Error
  • func (m *RawDeleteResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawDeleteResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawDeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawDeleteResponse) ProtoMessage()
  • func (m *RawDeleteResponse) Reset()
  • func (m *RawDeleteResponse) Size() (n int)
  • func (m *RawDeleteResponse) String() string
  • func (m *RawDeleteResponse) Unmarshal(dAtA []byte) error
  • func (m *RawDeleteResponse) XXX_DiscardUnknown()
  • func (m *RawDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawDeleteResponse) XXX_Merge(src proto.Message)
  • func (m *RawDeleteResponse) XXX_Size() int
  • func (m *RawDeleteResponse) XXX_Unmarshal(b []byte) error
• type RawGetKeyTTLRequest
  • func (*RawGetKeyTTLRequest) Descriptor() ([]byte, []int)
  • func (m *RawGetKeyTTLRequest) GetCf() string
  • func (m *RawGetKeyTTLRequest) GetContext() *Context
  • func (m *RawGetKeyTTLRequest) GetKey() []byte
  • func (m *RawGetKeyTTLRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawGetKeyTTLRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawGetKeyTTLRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawGetKeyTTLRequest) ProtoMessage()
  • func (m *RawGetKeyTTLRequest) Reset()
  • func (m *RawGetKeyTTLRequest) Size() (n int)
  • func (m *RawGetKeyTTLRequest) String() string
  • func (m *RawGetKeyTTLRequest) Unmarshal(dAtA []byte) error
  • func (m *RawGetKeyTTLRequest) XXX_DiscardUnknown()
  • func (m *RawGetKeyTTLRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawGetKeyTTLRequest) XXX_Merge(src proto.Message)
  • func (m *RawGetKeyTTLRequest) XXX_Size() int
  • func (m *RawGetKeyTTLRequest) XXX_Unmarshal(b []byte) error
• type RawGetKeyTTLResponse
  • func (*RawGetKeyTTLResponse) Descriptor() ([]byte, []int)
  • func (m *RawGetKeyTTLResponse) GetError() string
  • func (m *RawGetKeyTTLResponse) GetNotFound() bool
  • func (m *RawGetKeyTTLResponse) GetRegionError() *errorpb.Error
  • func (m *RawGetKeyTTLResponse) GetTtl() uint64
  • func (m *RawGetKeyTTLResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawGetKeyTTLResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawGetKeyTTLResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawGetKeyTTLResponse) ProtoMessage()
  • func (m *RawGetKeyTTLResponse) Reset()
  • func (m *RawGetKeyTTLResponse) Size() (n int)
  • func (m *RawGetKeyTTLResponse) String() string
  • func (m *RawGetKeyTTLResponse) Unmarshal(dAtA []byte) error
  • func (m *RawGetKeyTTLResponse) XXX_DiscardUnknown()
  • func (m *RawGetKeyTTLResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawGetKeyTTLResponse) XXX_Merge(src proto.Message)
  • func (m *RawGetKeyTTLResponse) XXX_Size() int
  • func (m *RawGetKeyTTLResponse) XXX_Unmarshal(b []byte) error
• type RawGetRequest
  • func (*RawGetRequest) Descriptor() ([]byte, []int)
  • func (m *RawGetRequest) GetCf() string
  • func (m *RawGetRequest) GetContext() *Context
  • func (m *RawGetRequest) GetKey() []byte
  • func (m *RawGetRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawGetRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawGetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawGetRequest) ProtoMessage()
  • func (m *RawGetRequest) Reset()
  • func (m *RawGetRequest) Size() (n int)
  • func (m *RawGetRequest) String() string
  • func (m *RawGetRequest) Unmarshal(dAtA []byte) error
  • func (m *RawGetRequest) XXX_DiscardUnknown()
  • func (m *RawGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawGetRequest) XXX_Merge(src proto.Message)
  • func (m *RawGetRequest) XXX_Size() int
  • func (m *RawGetRequest) XXX_Unmarshal(b []byte) error
• type RawGetResponse
  • func (*RawGetResponse) Descriptor() ([]byte, []int)
  • func (m *RawGetResponse) GetError() string
  • func (m *RawGetResponse) GetNotFound() bool
  • func (m *RawGetResponse) GetRegionError() *errorpb.Error
  • func (m *RawGetResponse) GetValue() []byte
  • func (m *RawGetResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawGetResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawGetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawGetResponse) ProtoMessage()
  • func (m *RawGetResponse) Reset()
  • func (m *RawGetResponse) Size() (n int)
  • func (m *RawGetResponse) String() string
  • func (m *RawGetResponse) Unmarshal(dAtA []byte) error
  • func (m *RawGetResponse) XXX_DiscardUnknown()
  • func (m *RawGetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawGetResponse) XXX_Merge(src proto.Message)
  • func (m *RawGetResponse) XXX_Size() int
  • func (m *RawGetResponse) XXX_Unmarshal(b []byte) error
• type RawPutRequest
  • func (*RawPutRequest) Descriptor() ([]byte, []int)
  • func (m *RawPutRequest) GetCf() string
  • func (m *RawPutRequest) GetContext() *Context
  • func (m *RawPutRequest) GetForCas() bool
  • func (m *RawPutRequest) GetKey() []byte
  • func (m *RawPutRequest) GetTtl() uint64
  • func (m *RawPutRequest) GetValue() []byte
  • func (m *RawPutRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawPutRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawPutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawPutRequest) ProtoMessage()
  • func (m *RawPutRequest) Reset()
  • func (m *RawPutRequest) Size() (n int)
  • func (m *RawPutRequest) String() string
  • func (m *RawPutRequest) Unmarshal(dAtA []byte) error
  • func (m *RawPutRequest) XXX_DiscardUnknown()
  • func (m *RawPutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawPutRequest) XXX_Merge(src proto.Message)
  • func (m *RawPutRequest) XXX_Size() int
  • func (m *RawPutRequest) XXX_Unmarshal(b []byte) error
• type RawPutResponse
  • func (*RawPutResponse) Descriptor() ([]byte, []int)
  • func (m *RawPutResponse) GetError() string
  • func (m *RawPutResponse) GetRegionError() *errorpb.Error
  • func (m *RawPutResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawPutResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawPutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawPutResponse) ProtoMessage()
  • func (m *RawPutResponse) Reset()
  • func (m *RawPutResponse) Size() (n int)
  • func (m *RawPutResponse) String() string
  • func (m *RawPutResponse) Unmarshal(dAtA []byte) error
  • func (m *RawPutResponse) XXX_DiscardUnknown()
  • func (m *RawPutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawPutResponse) XXX_Merge(src proto.Message)
  • func (m *RawPutResponse) XXX_Size() int
  • func (m *RawPutResponse) XXX_Unmarshal(b []byte) error
• type RawScanRequest
  • func (*RawScanRequest) Descriptor() ([]byte, []int)
  • func (m *RawScanRequest) GetCf() string
  • func (m *RawScanRequest) GetContext() *Context
  • func (m *RawScanRequest) GetEndKey() []byte
  • func (m *RawScanRequest) GetKeyOnly() bool
  • func (m *RawScanRequest) GetLimit() uint32
  • func (m *RawScanRequest) GetReverse() bool
  • func (m *RawScanRequest) GetStartKey() []byte
  • func (m *RawScanRequest) Marshal() (dAtA []byte, err error)
  • func (m *RawScanRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawScanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawScanRequest) ProtoMessage()
  • func (m *RawScanRequest) Reset()
  • func (m *RawScanRequest) Size() (n int)
  • func (m *RawScanRequest) String() string
  • func (m *RawScanRequest) Unmarshal(dAtA []byte) error
  • func (m *RawScanRequest) XXX_DiscardUnknown()
  • func (m *RawScanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawScanRequest) XXX_Merge(src proto.Message)
  • func (m *RawScanRequest) XXX_Size() int
  • func (m *RawScanRequest) XXX_Unmarshal(b []byte) error
• type RawScanResponse
  • func (*RawScanResponse) Descriptor() ([]byte, []int)
  • func (m *RawScanResponse) GetKvs() []*KvPair
  • func (m *RawScanResponse) GetRegionError() *errorpb.Error
  • func (m *RawScanResponse) Marshal() (dAtA []byte, err error)
  • func (m *RawScanResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RawScanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RawScanResponse) ProtoMessage()
  • func (m *RawScanResponse) Reset()
  • func (m *RawScanResponse) Size() (n int)
  • func (m *RawScanResponse) String() string
  • func (m *RawScanResponse) Unmarshal(dAtA []byte) error
  • func (m *RawScanResponse) XXX_DiscardUnknown()
  • func (m *RawScanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RawScanResponse) XXX_Merge(src proto.Message)
  • func (m *RawScanResponse) XXX_Size() int
  • func (m *RawScanResponse) XXX_Unmarshal(b []byte) error
• type ReadIndexRequest
  • func (*ReadIndexRequest) Descriptor() ([]byte, []int)
  • func (m *ReadIndexRequest) GetContext() *Context
  • func (m *ReadIndexRequest) GetRanges() []*KeyRange
  • func (m *ReadIndexRequest) GetStartTs() uint64
  • func (m *ReadIndexRequest) Marshal() (dAtA []byte, err error)
  • func (m *ReadIndexRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ReadIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ReadIndexRequest) ProtoMessage()
  • func (m *ReadIndexRequest) Reset()
  • func (m *ReadIndexRequest) Size() (n int)
  • func (m *ReadIndexRequest) String() string
  • func (m *ReadIndexRequest) Unmarshal(dAtA []byte) error
  • func (m *ReadIndexRequest) XXX_DiscardUnknown()
  • func (m *ReadIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ReadIndexRequest) XXX_Merge(src proto.Message)
  • func (m *ReadIndexRequest) XXX_Size() int
  • func (m *ReadIndexRequest) XXX_Unmarshal(b []byte) error
• type ReadIndexResponse
  • func (*ReadIndexResponse) Descriptor() ([]byte, []int)
  • func (m *ReadIndexResponse) GetLocked() *LockInfo
  • func (m *ReadIndexResponse) GetReadIndex() uint64
  • func (m *ReadIndexResponse) GetRegionError() *errorpb.Error
  • func (m *ReadIndexResponse) Marshal() (dAtA []byte, err error)
  • func (m *ReadIndexResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ReadIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ReadIndexResponse) ProtoMessage()
  • func (m *ReadIndexResponse) Reset()
  • func (m *ReadIndexResponse) Size() (n int)
  • func (m *ReadIndexResponse) String() string
  • func (m *ReadIndexResponse) Unmarshal(dAtA []byte) error
  • func (m *ReadIndexResponse) XXX_DiscardUnknown()
  • func (m *ReadIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ReadIndexResponse) XXX_Merge(src proto.Message)
  • func (m *ReadIndexResponse) XXX_Size() int
  • func (m *ReadIndexResponse) XXX_Unmarshal(b []byte) error
• type ReadState
  • func (*ReadState) Descriptor() ([]byte, []int)
  • func (m *ReadState) GetAppliedIndex() uint64
  • func (m *ReadState) GetSafeTs() uint64
  • func (m *ReadState) Marshal() (dAtA []byte, err error)
  • func (m *ReadState) MarshalTo(dAtA []byte) (int, error)
  • func (m *ReadState) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ReadState) ProtoMessage()
  • func (m *ReadState) Reset()
  • func (m *ReadState) Size() (n int)
  • func (m *ReadState) String() string
  • func (m *ReadState) Unmarshal(dAtA []byte) error
  • func (m *ReadState) XXX_DiscardUnknown()
  • func (m *ReadState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ReadState) XXX_Merge(src proto.Message)
  • func (m *ReadState) XXX_Size() int
  • func (m *ReadState) XXX_Unmarshal(b []byte) error
• type RegisterLockObserverRequest
  • func (*RegisterLockObserverRequest) Descriptor() ([]byte, []int)
  • func (m *RegisterLockObserverRequest) GetContext() *Context
  • func (m *RegisterLockObserverRequest) GetMaxTs() uint64
  • func (m *RegisterLockObserverRequest) Marshal() (dAtA []byte, err error)
  • func (m *RegisterLockObserverRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RegisterLockObserverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RegisterLockObserverRequest) ProtoMessage()
  • func (m *RegisterLockObserverRequest) Reset()
  • func (m *RegisterLockObserverRequest) Size() (n int)
  • func (m *RegisterLockObserverRequest) String() string
  • func (m *RegisterLockObserverRequest) Unmarshal(dAtA []byte) error
  • func (m *RegisterLockObserverRequest) XXX_DiscardUnknown()
  • func (m *RegisterLockObserverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RegisterLockObserverRequest) XXX_Merge(src proto.Message)
  • func (m *RegisterLockObserverRequest) XXX_Size() int
  • func (m *RegisterLockObserverRequest) XXX_Unmarshal(b []byte) error
• type RegisterLockObserverResponse
  • func (*RegisterLockObserverResponse) Descriptor() ([]byte, []int)
  • func (m *RegisterLockObserverResponse) GetError() string
  • func (m *RegisterLockObserverResponse) Marshal() (dAtA []byte, err error)
  • func (m *RegisterLockObserverResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RegisterLockObserverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RegisterLockObserverResponse) ProtoMessage()
  • func (m *RegisterLockObserverResponse) Reset()
  • func (m *RegisterLockObserverResponse) Size() (n int)
  • func (m *RegisterLockObserverResponse) String() string
  • func (m *RegisterLockObserverResponse) Unmarshal(dAtA []byte) error
  • func (m *RegisterLockObserverResponse) XXX_DiscardUnknown()
  • func (m *RegisterLockObserverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RegisterLockObserverResponse) XXX_Merge(src proto.Message)
  • func (m *RegisterLockObserverResponse) XXX_Size() int
  • func (m *RegisterLockObserverResponse) XXX_Unmarshal(b []byte) error
• type RemoveLockObserverRequest
  • func (*RemoveLockObserverRequest) Descriptor() ([]byte, []int)
  • func (m *RemoveLockObserverRequest) GetContext() *Context
  • func (m *RemoveLockObserverRequest) GetMaxTs() uint64
  • func (m *RemoveLockObserverRequest) Marshal() (dAtA []byte, err error)
  • func (m *RemoveLockObserverRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *RemoveLockObserverRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RemoveLockObserverRequest) ProtoMessage()
  • func (m *RemoveLockObserverRequest) Reset()
  • func (m *RemoveLockObserverRequest) Size() (n int)
  • func (m *RemoveLockObserverRequest) String() string
  • func (m *RemoveLockObserverRequest) Unmarshal(dAtA []byte) error
  • func (m *RemoveLockObserverRequest) XXX_DiscardUnknown()
  • func (m *RemoveLockObserverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RemoveLockObserverRequest) XXX_Merge(src proto.Message)
  • func (m *RemoveLockObserverRequest) XXX_Size() int
  • func (m *RemoveLockObserverRequest) XXX_Unmarshal(b []byte) error
• type RemoveLockObserverResponse
  • func (*RemoveLockObserverResponse) Descriptor() ([]byte, []int)
  • func (m *RemoveLockObserverResponse) GetError() string
  • func (m *RemoveLockObserverResponse) Marshal() (dAtA []byte, err error)
  • func (m *RemoveLockObserverResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *RemoveLockObserverResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*RemoveLockObserverResponse) ProtoMessage()
  • func (m *RemoveLockObserverResponse) Reset()
  • func (m *RemoveLockObserverResponse) Size() (n int)
  • func (m *RemoveLockObserverResponse) String() string
  • func (m *RemoveLockObserverResponse) Unmarshal(dAtA []byte) error
  • func (m *RemoveLockObserverResponse) XXX_DiscardUnknown()
  • func (m *RemoveLockObserverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *RemoveLockObserverResponse) XXX_Merge(src proto.Message)
  • func (m *RemoveLockObserverResponse) XXX_Size() int
  • func (m *RemoveLockObserverResponse) XXX_Unmarshal(b []byte) error
• type ResolveLockRequest
  • func (*ResolveLockRequest) Descriptor() ([]byte, []int)
  • func (m *ResolveLockRequest) GetCommitVersion() uint64
  • func (m *ResolveLockRequest) GetContext() *Context
  • func (m *ResolveLockRequest) GetKeys() [][]byte
  • func (m *ResolveLockRequest) GetStartVersion() uint64
  • func (m *ResolveLockRequest) GetTxnInfos() []*TxnInfo
  • func (m *ResolveLockRequest) Marshal() (dAtA []byte, err error)
  • func (m *ResolveLockRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ResolveLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ResolveLockRequest) ProtoMessage()
  • func (m *ResolveLockRequest) Reset()
  • func (m *ResolveLockRequest) Size() (n int)
  • func (m *ResolveLockRequest) String() string
  • func (m *ResolveLockRequest) Unmarshal(dAtA []byte) error
  • func (m *ResolveLockRequest) XXX_DiscardUnknown()
  • func (m *ResolveLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ResolveLockRequest) XXX_Merge(src proto.Message)
  • func (m *ResolveLockRequest) XXX_Size() int
  • func (m *ResolveLockRequest) XXX_Unmarshal(b []byte) error
• type ResolveLockResponse
  • func (*ResolveLockResponse) Descriptor() ([]byte, []int)
  • func (m *ResolveLockResponse) GetError() *KeyError
  • func (m *ResolveLockResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *ResolveLockResponse) GetRegionError() *errorpb.Error
  • func (m *ResolveLockResponse) Marshal() (dAtA []byte, err error)
  • func (m *ResolveLockResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ResolveLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ResolveLockResponse) ProtoMessage()
  • func (m *ResolveLockResponse) Reset()
  • func (m *ResolveLockResponse) Size() (n int)
  • func (m *ResolveLockResponse) String() string
  • func (m *ResolveLockResponse) Unmarshal(dAtA []byte) error
  • func (m *ResolveLockResponse) XXX_DiscardUnknown()
  • func (m *ResolveLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ResolveLockResponse) XXX_Merge(src proto.Message)
  • func (m *ResolveLockResponse) XXX_Size() int
  • func (m *ResolveLockResponse) XXX_Unmarshal(b []byte) error
• type ResourceControlContext
  • func (*ResourceControlContext) Descriptor() ([]byte, []int)
  • func (m *ResourceControlContext) GetOverridePriority() uint64
  • func (m *ResourceControlContext) GetPenalty() *resource_manager.Consumption
  • func (m *ResourceControlContext) GetResourceGroupName() string
  • func (m *ResourceControlContext) Marshal() (dAtA []byte, err error)
  • func (m *ResourceControlContext) MarshalTo(dAtA []byte) (int, error)
  • func (m *ResourceControlContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ResourceControlContext) ProtoMessage()
  • func (m *ResourceControlContext) Reset()
  • func (m *ResourceControlContext) Size() (n int)
  • func (m *ResourceControlContext) String() string
  • func (m *ResourceControlContext) Unmarshal(dAtA []byte) error
  • func (m *ResourceControlContext) XXX_DiscardUnknown()
  • func (m *ResourceControlContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ResourceControlContext) XXX_Merge(src proto.Message)
  • func (m *ResourceControlContext) XXX_Size() int
  • func (m *ResourceControlContext) XXX_Unmarshal(b []byte) error
• type ScanDetail
  • func (*ScanDetail) Descriptor() ([]byte, []int)
  • func (m *ScanDetail) GetData() *ScanInfo
  • func (m *ScanDetail) GetLock() *ScanInfo
  • func (m *ScanDetail) GetWrite() *ScanInfo
  • func (m *ScanDetail) Marshal() (dAtA []byte, err error)
  • func (m *ScanDetail) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScanDetail) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScanDetail) ProtoMessage()
  • func (m *ScanDetail) Reset()
  • func (m *ScanDetail) Size() (n int)
  • func (m *ScanDetail) String() string
  • func (m *ScanDetail) Unmarshal(dAtA []byte) error
  • func (m *ScanDetail) XXX_DiscardUnknown()
  • func (m *ScanDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScanDetail) XXX_Merge(src proto.Message)
  • func (m *ScanDetail) XXX_Size() int
  • func (m *ScanDetail) XXX_Unmarshal(b []byte) error
• type ScanDetailV2
  • func (*ScanDetailV2) Descriptor() ([]byte, []int)
  • func (m *ScanDetailV2) GetGetSnapshotNanos() uint64
  • func (m *ScanDetailV2) GetProcessedVersions() uint64
  • func (m *ScanDetailV2) GetProcessedVersionsSize() uint64
  • func (m *ScanDetailV2) GetReadIndexConfirmWaitNanos() uint64
  • func (m *ScanDetailV2) GetReadIndexProposeWaitNanos() uint64
  • func (m *ScanDetailV2) GetReadPoolScheduleWaitNanos() uint64
  • func (m *ScanDetailV2) GetRocksdbBlockCacheHitCount() uint64
  • func (m *ScanDetailV2) GetRocksdbBlockReadByte() uint64
  • func (m *ScanDetailV2) GetRocksdbBlockReadCount() uint64
  • func (m *ScanDetailV2) GetRocksdbBlockReadNanos() uint64
  • func (m *ScanDetailV2) GetRocksdbDeleteSkippedCount() uint64
  • func (m *ScanDetailV2) GetRocksdbKeySkippedCount() uint64
  • func (m *ScanDetailV2) GetTotalVersions() uint64
  • func (m *ScanDetailV2) Marshal() (dAtA []byte, err error)
  • func (m *ScanDetailV2) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScanDetailV2) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScanDetailV2) ProtoMessage()
  • func (m *ScanDetailV2) Reset()
  • func (m *ScanDetailV2) Size() (n int)
  • func (m *ScanDetailV2) String() string
  • func (m *ScanDetailV2) Unmarshal(dAtA []byte) error
  • func (m *ScanDetailV2) XXX_DiscardUnknown()
  • func (m *ScanDetailV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScanDetailV2) XXX_Merge(src proto.Message)
  • func (m *ScanDetailV2) XXX_Size() int
  • func (m *ScanDetailV2) XXX_Unmarshal(b []byte) error
• type ScanInfo
  • func (*ScanInfo) Descriptor() ([]byte, []int)
  • func (m *ScanInfo) GetProcessed() int64
  • func (m *ScanInfo) GetReadBytes() int64
  • func (m *ScanInfo) GetTotal() int64
  • func (m *ScanInfo) Marshal() (dAtA []byte, err error)
  • func (m *ScanInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScanInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScanInfo) ProtoMessage()
  • func (m *ScanInfo) Reset()
  • func (m *ScanInfo) Size() (n int)
  • func (m *ScanInfo) String() string
  • func (m *ScanInfo) Unmarshal(dAtA []byte) error
  • func (m *ScanInfo) XXX_DiscardUnknown()
  • func (m *ScanInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScanInfo) XXX_Merge(src proto.Message)
  • func (m *ScanInfo) XXX_Size() int
  • func (m *ScanInfo) XXX_Unmarshal(b []byte) error
• type ScanLockRequest
  • func (*ScanLockRequest) Descriptor() ([]byte, []int)
  • func (m *ScanLockRequest) GetContext() *Context
  • func (m *ScanLockRequest) GetEndKey() []byte
  • func (m *ScanLockRequest) GetLimit() uint32
  • func (m *ScanLockRequest) GetMaxVersion() uint64
  • func (m *ScanLockRequest) GetStartKey() []byte
  • func (m *ScanLockRequest) Marshal() (dAtA []byte, err error)
  • func (m *ScanLockRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScanLockRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScanLockRequest) ProtoMessage()
  • func (m *ScanLockRequest) Reset()
  • func (m *ScanLockRequest) Size() (n int)
  • func (m *ScanLockRequest) String() string
  • func (m *ScanLockRequest) Unmarshal(dAtA []byte) error
  • func (m *ScanLockRequest) XXX_DiscardUnknown()
  • func (m *ScanLockRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScanLockRequest) XXX_Merge(src proto.Message)
  • func (m *ScanLockRequest) XXX_Size() int
  • func (m *ScanLockRequest) XXX_Unmarshal(b []byte) error
• type ScanLockResponse
  • func (*ScanLockResponse) Descriptor() ([]byte, []int)
  • func (m *ScanLockResponse) GetError() *KeyError
  • func (m *ScanLockResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *ScanLockResponse) GetLocks() []*LockInfo
  • func (m *ScanLockResponse) GetRegionError() *errorpb.Error
  • func (m *ScanLockResponse) Marshal() (dAtA []byte, err error)
  • func (m *ScanLockResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScanLockResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScanLockResponse) ProtoMessage()
  • func (m *ScanLockResponse) Reset()
  • func (m *ScanLockResponse) Size() (n int)
  • func (m *ScanLockResponse) String() string
  • func (m *ScanLockResponse) Unmarshal(dAtA []byte) error
  • func (m *ScanLockResponse) XXX_DiscardUnknown()
  • func (m *ScanLockResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScanLockResponse) XXX_Merge(src proto.Message)
  • func (m *ScanLockResponse) XXX_Size() int
  • func (m *ScanLockResponse) XXX_Unmarshal(b []byte) error
• type ScanRequest
  • func (*ScanRequest) Descriptor() ([]byte, []int)
  • func (m *ScanRequest) GetContext() *Context
  • func (m *ScanRequest) GetEndKey() []byte
  • func (m *ScanRequest) GetKeyOnly() bool
  • func (m *ScanRequest) GetLimit() uint32
  • func (m *ScanRequest) GetReverse() bool
  • func (m *ScanRequest) GetSampleStep() uint32
  • func (m *ScanRequest) GetStartKey() []byte
  • func (m *ScanRequest) GetVersion() uint64
  • func (m *ScanRequest) Marshal() (dAtA []byte, err error)
  • func (m *ScanRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScanRequest) ProtoMessage()
  • func (m *ScanRequest) Reset()
  • func (m *ScanRequest) Size() (n int)
  • func (m *ScanRequest) String() string
  • func (m *ScanRequest) Unmarshal(dAtA []byte) error
  • func (m *ScanRequest) XXX_DiscardUnknown()
  • func (m *ScanRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScanRequest) XXX_Merge(src proto.Message)
  • func (m *ScanRequest) XXX_Size() int
  • func (m *ScanRequest) XXX_Unmarshal(b []byte) error
• type ScanResponse
  • func (*ScanResponse) Descriptor() ([]byte, []int)
  • func (m *ScanResponse) GetError() *KeyError
  • func (m *ScanResponse) GetPairs() []*KvPair
  • func (m *ScanResponse) GetRegionError() *errorpb.Error
  • func (m *ScanResponse) Marshal() (dAtA []byte, err error)
  • func (m *ScanResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScanResponse) ProtoMessage()
  • func (m *ScanResponse) Reset()
  • func (m *ScanResponse) Size() (n int)
  • func (m *ScanResponse) String() string
  • func (m *ScanResponse) Unmarshal(dAtA []byte) error
  • func (m *ScanResponse) XXX_DiscardUnknown()
  • func (m *ScanResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScanResponse) XXX_Merge(src proto.Message)
  • func (m *ScanResponse) XXX_Size() int
  • func (m *ScanResponse) XXX_Unmarshal(b []byte) error
• type SourceStmt
  • func (*SourceStmt) Descriptor() ([]byte, []int)
  • func (m *SourceStmt) GetConnectionId() uint64
  • func (m *SourceStmt) GetSessionAlias() string
  • func (m *SourceStmt) GetStartTs() uint64
  • func (m *SourceStmt) GetStmtId() uint64
  • func (m *SourceStmt) Marshal() (dAtA []byte, err error)
  • func (m *SourceStmt) MarshalTo(dAtA []byte) (int, error)
  • func (m *SourceStmt) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SourceStmt) ProtoMessage()
  • func (m *SourceStmt) Reset()
  • func (m *SourceStmt) Size() (n int)
  • func (m *SourceStmt) String() string
  • func (m *SourceStmt) Unmarshal(dAtA []byte) error
  • func (m *SourceStmt) XXX_DiscardUnknown()
  • func (m *SourceStmt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SourceStmt) XXX_Merge(src proto.Message)
  • func (m *SourceStmt) XXX_Size() int
  • func (m *SourceStmt) XXX_Unmarshal(b []byte) error
• type SplitRegionRequest
  • func (*SplitRegionRequest) Descriptor() ([]byte, []int)
  • func (m *SplitRegionRequest) GetContext() *Context
  • func (m *SplitRegionRequest) GetIsRawKv() bool
  • func (m *SplitRegionRequest) GetSplitKey() []byte
  • func (m *SplitRegionRequest) GetSplitKeys() [][]byte
  • func (m *SplitRegionRequest) Marshal() (dAtA []byte, err error)
  • func (m *SplitRegionRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *SplitRegionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SplitRegionRequest) ProtoMessage()
  • func (m *SplitRegionRequest) Reset()
  • func (m *SplitRegionRequest) Size() (n int)
  • func (m *SplitRegionRequest) String() string
  • func (m *SplitRegionRequest) Unmarshal(dAtA []byte) error
  • func (m *SplitRegionRequest) XXX_DiscardUnknown()
  • func (m *SplitRegionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SplitRegionRequest) XXX_Merge(src proto.Message)
  • func (m *SplitRegionRequest) XXX_Size() int
  • func (m *SplitRegionRequest) XXX_Unmarshal(b []byte) error
• type SplitRegionResponse
  • func (*SplitRegionResponse) Descriptor() ([]byte, []int)
  • func (m *SplitRegionResponse) GetLeft() *metapb.Region
  • func (m *SplitRegionResponse) GetRegionError() *errorpb.Error
  • func (m *SplitRegionResponse) GetRegions() []*metapb.Region
  • func (m *SplitRegionResponse) GetRight() *metapb.Region
  • func (m *SplitRegionResponse) Marshal() (dAtA []byte, err error)
  • func (m *SplitRegionResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *SplitRegionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*SplitRegionResponse) ProtoMessage()
  • func (m *SplitRegionResponse) Reset()
  • func (m *SplitRegionResponse) Size() (n int)
  • func (m *SplitRegionResponse) String() string
  • func (m *SplitRegionResponse) Unmarshal(dAtA []byte) error
  • func (m *SplitRegionResponse) XXX_DiscardUnknown()
  • func (m *SplitRegionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SplitRegionResponse) XXX_Merge(src proto.Message)
  • func (m *SplitRegionResponse) XXX_Size() int
  • func (m *SplitRegionResponse) XXX_Unmarshal(b []byte) error
• type StoreSafeTSRequest
  • func (*StoreSafeTSRequest) Descriptor() ([]byte, []int)
  • func (m *StoreSafeTSRequest) GetKeyRange() *KeyRange
  • func (m *StoreSafeTSRequest) Marshal() (dAtA []byte, err error)
  • func (m *StoreSafeTSRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *StoreSafeTSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*StoreSafeTSRequest) ProtoMessage()
  • func (m *StoreSafeTSRequest) Reset()
  • func (m *StoreSafeTSRequest) Size() (n int)
  • func (m *StoreSafeTSRequest) String() string
  • func (m *StoreSafeTSRequest) Unmarshal(dAtA []byte) error
  • func (m *StoreSafeTSRequest) XXX_DiscardUnknown()
  • func (m *StoreSafeTSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StoreSafeTSRequest) XXX_Merge(src proto.Message)
  • func (m *StoreSafeTSRequest) XXX_Size() int
  • func (m *StoreSafeTSRequest) XXX_Unmarshal(b []byte) error
• type StoreSafeTSResponse
  • func (*StoreSafeTSResponse) Descriptor() ([]byte, []int)
  • func (m *StoreSafeTSResponse) GetSafeTs() uint64
  • func (m *StoreSafeTSResponse) Marshal() (dAtA []byte, err error)
  • func (m *StoreSafeTSResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *StoreSafeTSResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*StoreSafeTSResponse) ProtoMessage()
  • func (m *StoreSafeTSResponse) Reset()
  • func (m *StoreSafeTSResponse) Size() (n int)
  • func (m *StoreSafeTSResponse) String() string
  • func (m *StoreSafeTSResponse) Unmarshal(dAtA []byte) error
  • func (m *StoreSafeTSResponse) XXX_DiscardUnknown()
  • func (m *StoreSafeTSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *StoreSafeTSResponse) XXX_Merge(src proto.Message)
  • func (m *StoreSafeTSResponse) XXX_Size() int
  • func (m *StoreSafeTSResponse) XXX_Unmarshal(b []byte) error
• type TiFlashSystemTableRequest
  • func (*TiFlashSystemTableRequest) Descriptor() ([]byte, []int)
  • func (m *TiFlashSystemTableRequest) GetSql() string
  • func (m *TiFlashSystemTableRequest) Marshal() (dAtA []byte, err error)
  • func (m *TiFlashSystemTableRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *TiFlashSystemTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TiFlashSystemTableRequest) ProtoMessage()
  • func (m *TiFlashSystemTableRequest) Reset()
  • func (m *TiFlashSystemTableRequest) Size() (n int)
  • func (m *TiFlashSystemTableRequest) String() string
  • func (m *TiFlashSystemTableRequest) Unmarshal(dAtA []byte) error
  • func (m *TiFlashSystemTableRequest) XXX_DiscardUnknown()
  • func (m *TiFlashSystemTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TiFlashSystemTableRequest) XXX_Merge(src proto.Message)
  • func (m *TiFlashSystemTableRequest) XXX_Size() int
  • func (m *TiFlashSystemTableRequest) XXX_Unmarshal(b []byte) error
• type TiFlashSystemTableResponse
  • func (*TiFlashSystemTableResponse) Descriptor() ([]byte, []int)
  • func (m *TiFlashSystemTableResponse) Marshal() (dAtA []byte, err error)
  • func (m *TiFlashSystemTableResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *TiFlashSystemTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TiFlashSystemTableResponse) ProtoMessage()
  • func (m *TiFlashSystemTableResponse) Reset()
  • func (m *TiFlashSystemTableResponse) Size() (n int)
  • func (m *TiFlashSystemTableResponse) String() string
  • func (m *TiFlashSystemTableResponse) Unmarshal(dAtA []byte) error
  • func (m *TiFlashSystemTableResponse) XXX_DiscardUnknown()
  • func (m *TiFlashSystemTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TiFlashSystemTableResponse) XXX_Merge(src proto.Message)
  • func (m *TiFlashSystemTableResponse) XXX_Size() int
  • func (m *TiFlashSystemTableResponse) XXX_Unmarshal(b []byte) error
• type TimeDetail
  • func (*TimeDetail) Descriptor() ([]byte, []int)
  • func (m *TimeDetail) GetKvReadWallTimeMs() uint64
  • func (m *TimeDetail) GetProcessWallTimeMs() uint64
  • func (m *TimeDetail) GetTotalRpcWallTimeNs() uint64
  • func (m *TimeDetail) GetWaitWallTimeMs() uint64
  • func (m *TimeDetail) Marshal() (dAtA []byte, err error)
  • func (m *TimeDetail) MarshalTo(dAtA []byte) (int, error)
  • func (m *TimeDetail) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TimeDetail) ProtoMessage()
  • func (m *TimeDetail) Reset()
  • func (m *TimeDetail) Size() (n int)
  • func (m *TimeDetail) String() string
  • func (m *TimeDetail) Unmarshal(dAtA []byte) error
  • func (m *TimeDetail) XXX_DiscardUnknown()
  • func (m *TimeDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TimeDetail) XXX_Merge(src proto.Message)
  • func (m *TimeDetail) XXX_Size() int
  • func (m *TimeDetail) XXX_Unmarshal(b []byte) error
• type TimeDetailV2
  • func (*TimeDetailV2) Descriptor() ([]byte, []int)
  • func (m *TimeDetailV2) GetKvReadWallTimeNs() uint64
  • func (m *TimeDetailV2) GetProcessSuspendWallTimeNs() uint64
  • func (m *TimeDetailV2) GetProcessWallTimeNs() uint64
  • func (m *TimeDetailV2) GetTotalRpcWallTimeNs() uint64
  • func (m *TimeDetailV2) GetWaitWallTimeNs() uint64
  • func (m *TimeDetailV2) Marshal() (dAtA []byte, err error)
  • func (m *TimeDetailV2) MarshalTo(dAtA []byte) (int, error)
  • func (m *TimeDetailV2) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TimeDetailV2) ProtoMessage()
  • func (m *TimeDetailV2) Reset()
  • func (m *TimeDetailV2) Size() (n int)
  • func (m *TimeDetailV2) String() string
  • func (m *TimeDetailV2) Unmarshal(dAtA []byte) error
  • func (m *TimeDetailV2) XXX_DiscardUnknown()
  • func (m *TimeDetailV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TimeDetailV2) XXX_Merge(src proto.Message)
  • func (m *TimeDetailV2) XXX_Size() int
  • func (m *TimeDetailV2) XXX_Unmarshal(b []byte) error
• type TxnHeartBeatRequest
  • func (*TxnHeartBeatRequest) Descriptor() ([]byte, []int)
  • func (m *TxnHeartBeatRequest) GetAdviseLockTtl() uint64
  • func (m *TxnHeartBeatRequest) GetContext() *Context
  • func (m *TxnHeartBeatRequest) GetPrimaryLock() []byte
  • func (m *TxnHeartBeatRequest) GetStartVersion() uint64
  • func (m *TxnHeartBeatRequest) Marshal() (dAtA []byte, err error)
  • func (m *TxnHeartBeatRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *TxnHeartBeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TxnHeartBeatRequest) ProtoMessage()
  • func (m *TxnHeartBeatRequest) Reset()
  • func (m *TxnHeartBeatRequest) Size() (n int)
  • func (m *TxnHeartBeatRequest) String() string
  • func (m *TxnHeartBeatRequest) Unmarshal(dAtA []byte) error
  • func (m *TxnHeartBeatRequest) XXX_DiscardUnknown()
  • func (m *TxnHeartBeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TxnHeartBeatRequest) XXX_Merge(src proto.Message)
  • func (m *TxnHeartBeatRequest) XXX_Size() int
  • func (m *TxnHeartBeatRequest) XXX_Unmarshal(b []byte) error
• type TxnHeartBeatResponse
  • func (*TxnHeartBeatResponse) Descriptor() ([]byte, []int)
  • func (m *TxnHeartBeatResponse) GetError() *KeyError
  • func (m *TxnHeartBeatResponse) GetExecDetailsV2() *ExecDetailsV2
  • func (m *TxnHeartBeatResponse) GetLockTtl() uint64
  • func (m *TxnHeartBeatResponse) GetRegionError() *errorpb.Error
  • func (m *TxnHeartBeatResponse) Marshal() (dAtA []byte, err error)
  • func (m *TxnHeartBeatResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *TxnHeartBeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TxnHeartBeatResponse) ProtoMessage()
  • func (m *TxnHeartBeatResponse) Reset()
  • func (m *TxnHeartBeatResponse) Size() (n int)
  • func (m *TxnHeartBeatResponse) String() string
  • func (m *TxnHeartBeatResponse) Unmarshal(dAtA []byte) error
  • func (m *TxnHeartBeatResponse) XXX_DiscardUnknown()
  • func (m *TxnHeartBeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TxnHeartBeatResponse) XXX_Merge(src proto.Message)
  • func (m *TxnHeartBeatResponse) XXX_Size() int
  • func (m *TxnHeartBeatResponse) XXX_Unmarshal(b []byte) error
• type TxnInfo
  • func (*TxnInfo) Descriptor() ([]byte, []int)
  • func (m *TxnInfo) GetStatus() uint64
  • func (m *TxnInfo) GetTxn() uint64
  • func (m *TxnInfo) Marshal() (dAtA []byte, err error)
  • func (m *TxnInfo) MarshalTo(dAtA []byte) (int, error)
  • func (m *TxnInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TxnInfo) ProtoMessage()
  • func (m *TxnInfo) Reset()
  • func (m *TxnInfo) Size() (n int)
  • func (m *TxnInfo) String() string
  • func (m *TxnInfo) Unmarshal(dAtA []byte) error
  • func (m *TxnInfo) XXX_DiscardUnknown()
  • func (m *TxnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TxnInfo) XXX_Merge(src proto.Message)
  • func (m *TxnInfo) XXX_Size() int
  • func (m *TxnInfo) XXX_Unmarshal(b []byte) error
• type TxnNotFound
  • func (*TxnNotFound) Descriptor() ([]byte, []int)
  • func (m *TxnNotFound) GetPrimaryKey() []byte
  • func (m *TxnNotFound) GetStartTs() uint64
  • func (m *TxnNotFound) Marshal() (dAtA []byte, err error)
  • func (m *TxnNotFound) MarshalTo(dAtA []byte) (int, error)
  • func (m *TxnNotFound) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*TxnNotFound) ProtoMessage()
  • func (m *TxnNotFound) Reset()
  • func (m *TxnNotFound) Size() (n int)
  • func (m *TxnNotFound) String() string
  • func (m *TxnNotFound) Unmarshal(dAtA []byte) error
  • func (m *TxnNotFound) XXX_DiscardUnknown()
  • func (m *TxnNotFound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *TxnNotFound) XXX_Merge(src proto.Message)
  • func (m *TxnNotFound) XXX_Size() int
  • func (m *TxnNotFound) XXX_Unmarshal(b []byte) error
• type UnsafeDestroyRangeRequest
  • func (*UnsafeDestroyRangeRequest) Descriptor() ([]byte, []int)
  • func (m *UnsafeDestroyRangeRequest) GetContext() *Context
  • func (m *UnsafeDestroyRangeRequest) GetEndKey() []byte
  • func (m *UnsafeDestroyRangeRequest) GetStartKey() []byte
  • func (m *UnsafeDestroyRangeRequest) Marshal() (dAtA []byte, err error)
  • func (m *UnsafeDestroyRangeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnsafeDestroyRangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnsafeDestroyRangeRequest) ProtoMessage()
  • func (m *UnsafeDestroyRangeRequest) Reset()
  • func (m *UnsafeDestroyRangeRequest) Size() (n int)
  • func (m *UnsafeDestroyRangeRequest) String() string
  • func (m *UnsafeDestroyRangeRequest) Unmarshal(dAtA []byte) error
  • func (m *UnsafeDestroyRangeRequest) XXX_DiscardUnknown()