Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowCoprocessor = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthCoprocessor = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupCoprocessor = fmt.Errorf("proto: unexpected end of group") + type BatchRequest struct + Context *kvrpcpb.Context + Data []byte + LogId string + Regions []*RegionInfo + SchemaVer int64 + StartTs uint64 + TableRegions []*TableRegions + Tp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchRequest) Descriptor() ([]byte, []int) + func (*BatchRequest) ProtoMessage() + func (m *BatchRequest) GetContext() *kvrpcpb.Context + func (m *BatchRequest) GetData() []byte + func (m *BatchRequest) GetLogId() string + func (m *BatchRequest) GetRegions() []*RegionInfo + func (m *BatchRequest) GetSchemaVer() int64 + func (m *BatchRequest) GetStartTs() uint64 + func (m *BatchRequest) GetTableRegions() []*TableRegions + func (m *BatchRequest) GetTp() int64 + func (m *BatchRequest) Marshal() (dAtA []byte, err error) + func (m *BatchRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchRequest) Reset() + func (m *BatchRequest) Size() (n int) + func (m *BatchRequest) String() string + func (m *BatchRequest) Unmarshal(dAtA []byte) error + func (m *BatchRequest) XXX_DiscardUnknown() + func (m *BatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchRequest) XXX_Merge(src proto.Message) + func (m *BatchRequest) XXX_Size() int + func (m *BatchRequest) XXX_Unmarshal(b []byte) error + type BatchResponse struct + Data github_com_gottingen_kvproto_pkg_sharedbytes.SharedBytes + ExecDetails *kvrpcpb.ExecDetails + OtherError string + RetryRegions []*metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchResponse) Descriptor() ([]byte, []int) + func (*BatchResponse) ProtoMessage() + func (m *BatchResponse) GetExecDetails() *kvrpcpb.ExecDetails + func (m *BatchResponse) GetOtherError() string + func (m *BatchResponse) GetRetryRegions() []*metapb.Region + func (m *BatchResponse) Marshal() (dAtA []byte, err error) + func (m *BatchResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchResponse) Reset() + func (m *BatchResponse) Size() (n int) + func (m *BatchResponse) String() string + func (m *BatchResponse) Unmarshal(dAtA []byte) error + func (m *BatchResponse) XXX_DiscardUnknown() + func (m *BatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchResponse) XXX_Merge(src proto.Message) + func (m *BatchResponse) XXX_Size() int + func (m *BatchResponse) XXX_Unmarshal(b []byte) error + type KeyRange struct + End []byte + Start []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyRange) Descriptor() ([]byte, []int) + func (*KeyRange) ProtoMessage() + func (m *KeyRange) GetEnd() []byte + func (m *KeyRange) GetStart() []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 (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 RegionInfo struct + Ranges []*KeyRange + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionInfo) Descriptor() ([]byte, []int) + func (*RegionInfo) ProtoMessage() + func (m *RegionInfo) GetRanges() []*KeyRange + func (m *RegionInfo) GetRegionEpoch() *metapb.RegionEpoch + func (m *RegionInfo) GetRegionId() uint64 + func (m *RegionInfo) Marshal() (dAtA []byte, err error) + func (m *RegionInfo) MarshalTo(dAtA []byte) (int, error) + func (m *RegionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionInfo) Reset() + func (m *RegionInfo) Size() (n int) + func (m *RegionInfo) String() string + func (m *RegionInfo) Unmarshal(dAtA []byte) error + func (m *RegionInfo) XXX_DiscardUnknown() + func (m *RegionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionInfo) XXX_Merge(src proto.Message) + func (m *RegionInfo) XXX_Size() int + func (m *RegionInfo) XXX_Unmarshal(b []byte) error + type Request struct + CacheIfMatchVersion uint64 + Context *kvrpcpb.Context + Data []byte + IsCacheEnabled bool + IsTraceEnabled bool + PagingSize uint64 + Ranges []*KeyRange + SchemaVer int64 + StartTs uint64 + Tasks []*StoreBatchTask + Tp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetCacheIfMatchVersion() uint64 + func (m *Request) GetContext() *kvrpcpb.Context + func (m *Request) GetData() []byte + func (m *Request) GetIsCacheEnabled() bool + func (m *Request) GetIsTraceEnabled() bool + func (m *Request) GetPagingSize() uint64 + func (m *Request) GetRanges() []*KeyRange + func (m *Request) GetSchemaVer() int64 + func (m *Request) GetStartTs() uint64 + func (m *Request) GetTasks() []*StoreBatchTask + func (m *Request) GetTp() int64 + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type Response struct + BatchResponses []*StoreBatchTaskResponse + CacheLastVersion uint64 + CanBeCached bool + Data github_com_gottingen_kvproto_pkg_sharedbytes.SharedBytes + ExecDetails *kvrpcpb.ExecDetails + ExecDetailsV2 *kvrpcpb.ExecDetailsV2 + IsCacheHit bool + LatestBucketsVersion uint64 + Locked *kvrpcpb.LockInfo + OtherError string + Range *KeyRange + RegionError *errorpb.Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetBatchResponses() []*StoreBatchTaskResponse + func (m *Response) GetCacheLastVersion() uint64 + func (m *Response) GetCanBeCached() bool + func (m *Response) GetExecDetails() *kvrpcpb.ExecDetails + func (m *Response) GetExecDetailsV2() *kvrpcpb.ExecDetailsV2 + func (m *Response) GetIsCacheHit() bool + func (m *Response) GetLatestBucketsVersion() uint64 + func (m *Response) GetLocked() *kvrpcpb.LockInfo + func (m *Response) GetOtherError() string + func (m *Response) GetRange() *KeyRange + func (m *Response) GetRegionError() *errorpb.Error + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type StoreBatchTask struct + Peer *metapb.Peer + Ranges []*KeyRange + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + TaskId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreBatchTask) Descriptor() ([]byte, []int) + func (*StoreBatchTask) ProtoMessage() + func (m *StoreBatchTask) GetPeer() *metapb.Peer + func (m *StoreBatchTask) GetRanges() []*KeyRange + func (m *StoreBatchTask) GetRegionEpoch() *metapb.RegionEpoch + func (m *StoreBatchTask) GetRegionId() uint64 + func (m *StoreBatchTask) GetTaskId() uint64 + func (m *StoreBatchTask) Marshal() (dAtA []byte, err error) + func (m *StoreBatchTask) MarshalTo(dAtA []byte) (int, error) + func (m *StoreBatchTask) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StoreBatchTask) Reset() + func (m *StoreBatchTask) Size() (n int) + func (m *StoreBatchTask) String() string + func (m *StoreBatchTask) Unmarshal(dAtA []byte) error + func (m *StoreBatchTask) XXX_DiscardUnknown() + func (m *StoreBatchTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StoreBatchTask) XXX_Merge(src proto.Message) + func (m *StoreBatchTask) XXX_Size() int + func (m *StoreBatchTask) XXX_Unmarshal(b []byte) error + type StoreBatchTaskResponse struct + Data github_com_gottingen_kvproto_pkg_sharedbytes.SharedBytes + ExecDetailsV2 *kvrpcpb.ExecDetailsV2 + Locked *kvrpcpb.LockInfo + OtherError string + RegionError *errorpb.Error + TaskId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreBatchTaskResponse) Descriptor() ([]byte, []int) + func (*StoreBatchTaskResponse) ProtoMessage() + func (m *StoreBatchTaskResponse) GetExecDetailsV2() *kvrpcpb.ExecDetailsV2 + func (m *StoreBatchTaskResponse) GetLocked() *kvrpcpb.LockInfo + func (m *StoreBatchTaskResponse) GetOtherError() string + func (m *StoreBatchTaskResponse) GetRegionError() *errorpb.Error + func (m *StoreBatchTaskResponse) GetTaskId() uint64 + func (m *StoreBatchTaskResponse) Marshal() (dAtA []byte, err error) + func (m *StoreBatchTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StoreBatchTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StoreBatchTaskResponse) Reset() + func (m *StoreBatchTaskResponse) Size() (n int) + func (m *StoreBatchTaskResponse) String() string + func (m *StoreBatchTaskResponse) Unmarshal(dAtA []byte) error + func (m *StoreBatchTaskResponse) XXX_DiscardUnknown() + func (m *StoreBatchTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StoreBatchTaskResponse) XXX_Merge(src proto.Message) + func (m *StoreBatchTaskResponse) XXX_Size() int + func (m *StoreBatchTaskResponse) XXX_Unmarshal(b []byte) error + type TableRegions struct + PhysicalTableId int64 + Regions []*RegionInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TableRegions) Descriptor() ([]byte, []int) + func (*TableRegions) ProtoMessage() + func (m *TableRegions) GetPhysicalTableId() int64 + func (m *TableRegions) GetRegions() []*RegionInfo + func (m *TableRegions) Marshal() (dAtA []byte, err error) + func (m *TableRegions) MarshalTo(dAtA []byte) (int, error) + func (m *TableRegions) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TableRegions) Reset() + func (m *TableRegions) Size() (n int) + func (m *TableRegions) String() string + func (m *TableRegions) Unmarshal(dAtA []byte) error + func (m *TableRegions) XXX_DiscardUnknown() + func (m *TableRegions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TableRegions) XXX_Merge(src proto.Message) + func (m *TableRegions) XXX_Size() int + func (m *TableRegions) XXX_Unmarshal(b []byte) error