coprocessor

package
v0.0.0-...-ad14807 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 5, 2025 License: Apache-2.0 Imports: 10 Imported by: 704

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCoprocessor        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCoprocessor          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCoprocessor = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type BatchRequest 

type BatchRequest struct {
	Context *kvrpcpb.Context `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Tp      int64            `protobuf:"varint,2,opt,name=tp,proto3" json:"tp,omitempty"`
	Data    []byte           `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Regions []*RegionInfo    `protobuf:"bytes,4,rep,name=regions,proto3" json:"regions,omitempty"`
	StartTs uint64           `protobuf:"varint,5,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// Any schema-ful storage to validate schema correctness if necessary.
	SchemaVer int64 `protobuf:"varint,6,opt,name=schema_ver,json=schemaVer,proto3" json:"schema_ver,omitempty"`
	// Used for partition table scan
	TableRegions    []*TableRegions `protobuf:"bytes,7,rep,name=table_regions,json=tableRegions,proto3" json:"table_regions,omitempty"`
	LogId           string          `protobuf:"bytes,8,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	ConnectionId    uint64          `protobuf:"varint,9,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ConnectionAlias string          `protobuf:"bytes,10,opt,name=connection_alias,json=connectionAlias,proto3" json:"connection_alias,omitempty"`
}

func (*BatchRequest) Descriptor 

func (*BatchRequest) Descriptor() ([]byte, []int)

func (*BatchRequest) GetConnectionAlias 

func (m *BatchRequest) GetConnectionAlias() string

func (*BatchRequest) GetConnectionId 

func (m *BatchRequest) GetConnectionId() uint64

func (*BatchRequest) GetContext 

func (m *BatchRequest) GetContext() *kvrpcpb.Context

func (*BatchRequest) GetData 

func (m *BatchRequest) GetData() []byte

func (*BatchRequest) GetLogId 

func (m *BatchRequest) GetLogId() string

func (*BatchRequest) GetRegions 

func (m *BatchRequest) GetRegions() []*RegionInfo

func (*BatchRequest) GetSchemaVer 

func (m *BatchRequest) GetSchemaVer() int64

func (*BatchRequest) GetStartTs 

func (m *BatchRequest) GetStartTs() uint64

func (*BatchRequest) GetTableRegions 

func (m *BatchRequest) GetTableRegions() []*TableRegions

func (*BatchRequest) GetTp 

func (m *BatchRequest) GetTp() int64

func (*BatchRequest) Marshal 

func (m *BatchRequest) Marshal() (dAtA []byte, err error)

func (*BatchRequest) MarshalTo 

func (m *BatchRequest) MarshalTo(dAtA []byte) (int, error)

func (*BatchRequest) MarshalToSizedBuffer 

func (m *BatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) Reset 

func (m *BatchRequest) Reset()

func (*BatchRequest) Size 

func (m *BatchRequest) Size() (n int)

func (*BatchRequest) String 

func (m *BatchRequest) String() string

func (*BatchRequest) Unmarshal 

func (m *BatchRequest) Unmarshal(dAtA []byte) error

func (*BatchRequest) XXX_DiscardUnknown 

func (m *BatchRequest) XXX_DiscardUnknown()

func (*BatchRequest) XXX_Marshal 

func (m *BatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchRequest) XXX_Merge 

func (m *BatchRequest) XXX_Merge(src proto.Message)

func (*BatchRequest) XXX_Size 

func (m *BatchRequest) XXX_Size() int

func (*BatchRequest) XXX_Unmarshal 

func (m *BatchRequest) XXX_Unmarshal(b []byte) error

type BatchResponse 

type BatchResponse struct {
	Data         github_com_pingcap_kvproto_pkg_sharedbytes.SharedBytes `protobuf:"bytes,1,opt,name=data,proto3,customtype=github.com/pingcap/kvproto/pkg/sharedbytes.SharedBytes" json:"data"`
	OtherError   string                                                 `protobuf:"bytes,2,opt,name=other_error,json=otherError,proto3" json:"other_error,omitempty"`
	ExecDetails  *kvrpcpb.ExecDetails                                   `protobuf:"bytes,3,opt,name=exec_details,json=execDetails,proto3" json:"exec_details,omitempty"`
	RetryRegions []*metapb.Region                                       `protobuf:"bytes,4,rep,name=retry_regions,json=retryRegions,proto3" json:"retry_regions,omitempty"`
}

func (*BatchResponse) Descriptor 

func (*BatchResponse) Descriptor() ([]byte, []int)

func (*BatchResponse) GetExecDetails 

func (m *BatchResponse) GetExecDetails() *kvrpcpb.ExecDetails

func (*BatchResponse) GetOtherError 

func (m *BatchResponse) GetOtherError() string

func (*BatchResponse) GetRetryRegions 

func (m *BatchResponse) GetRetryRegions() []*metapb.Region

func (*BatchResponse) Marshal 

func (m *BatchResponse) Marshal() (dAtA []byte, err error)

func (*BatchResponse) MarshalTo 

func (m *BatchResponse) MarshalTo(dAtA []byte) (int, error)

func (*BatchResponse) MarshalToSizedBuffer 

func (m *BatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BatchResponse) ProtoMessage 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) Reset 

func (m *BatchResponse) Reset()

func (*BatchResponse) Size 

func (m *BatchResponse) Size() (n int)

func (*BatchResponse) String 

func (m *BatchResponse) String() string

func (*BatchResponse) Unmarshal 

func (m *BatchResponse) Unmarshal(dAtA []byte) error

func (*BatchResponse) XXX_DiscardUnknown 

func (m *BatchResponse) XXX_DiscardUnknown()

func (*BatchResponse) XXX_Marshal 

func (m *BatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchResponse) XXX_Merge 

func (m *BatchResponse) XXX_Merge(src proto.Message)

func (*BatchResponse) XXX_Size 

func (m *BatchResponse) XXX_Size() int

func (*BatchResponse) XXX_Unmarshal 

func (m *BatchResponse) XXX_Unmarshal(b []byte) error

type KeyRange 

type KeyRange struct {
	Start []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   []byte `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
}

[start, end)

func (*KeyRange) Descriptor 

func (*KeyRange) Descriptor() ([]byte, []int)

func (*KeyRange) GetEnd 

func (m *KeyRange) GetEnd() []byte

func (*KeyRange) GetStart 

func (m *KeyRange) GetStart() []byte

func (*KeyRange) Marshal 

func (m *KeyRange) Marshal() (dAtA []byte, err error)

func (*KeyRange) MarshalTo 

func (m *KeyRange) MarshalTo(dAtA []byte) (int, error)

func (*KeyRange) MarshalToSizedBuffer 

func (m *KeyRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KeyRange) ProtoMessage 

func (*KeyRange) ProtoMessage()

func (*KeyRange) Reset 

func (m *KeyRange) Reset()

func (*KeyRange) Size 

func (m *KeyRange) Size() (n int)

func (*KeyRange) String 

func (m *KeyRange) String() string

func (*KeyRange) Unmarshal 

func (m *KeyRange) Unmarshal(dAtA []byte) error

func (*KeyRange) XXX_DiscardUnknown 

func (m *KeyRange) XXX_DiscardUnknown()

func (*KeyRange) XXX_Marshal 

func (m *KeyRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyRange) XXX_Merge 

func (m *KeyRange) XXX_Merge(src proto.Message)

func (*KeyRange) XXX_Size 

func (m *KeyRange) XXX_Size() int

func (*KeyRange) XXX_Unmarshal 

func (m *KeyRange) XXX_Unmarshal(b []byte) error

type RegionInfo 

type RegionInfo struct {
	RegionId    uint64              `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,2,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	Ranges      []*KeyRange         `protobuf:"bytes,3,rep,name=ranges,proto3" json:"ranges,omitempty"`
}

func (*RegionInfo) Descriptor 

func (*RegionInfo) Descriptor() ([]byte, []int)

func (*RegionInfo) GetRanges 

func (m *RegionInfo) GetRanges() []*KeyRange

func (*RegionInfo) GetRegionEpoch 

func (m *RegionInfo) GetRegionEpoch() *metapb.RegionEpoch

func (*RegionInfo) GetRegionId 

func (m *RegionInfo) GetRegionId() uint64

func (*RegionInfo) Marshal 

func (m *RegionInfo) Marshal() (dAtA []byte, err error)

func (*RegionInfo) MarshalTo 

func (m *RegionInfo) MarshalTo(dAtA []byte) (int, error)

func (*RegionInfo) MarshalToSizedBuffer 

func (m *RegionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegionInfo) ProtoMessage 

func (*RegionInfo) ProtoMessage()

func (*RegionInfo) Reset 

func (m *RegionInfo) Reset()

func (*RegionInfo) Size 

func (m *RegionInfo) Size() (n int)

func (*RegionInfo) String 

func (m *RegionInfo) String() string

func (*RegionInfo) Unmarshal 

func (m *RegionInfo) Unmarshal(dAtA []byte) error

func (*RegionInfo) XXX_DiscardUnknown 

func (m *RegionInfo) XXX_DiscardUnknown()

func (*RegionInfo) XXX_Marshal 

func (m *RegionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionInfo) XXX_Merge 

func (m *RegionInfo) XXX_Merge(src proto.Message)

func (*RegionInfo) XXX_Size 

func (m *RegionInfo) XXX_Size() int

func (*RegionInfo) XXX_Unmarshal 

func (m *RegionInfo) XXX_Unmarshal(b []byte) error

type Request 

type Request struct {
	Context *kvrpcpb.Context `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Tp      int64            `protobuf:"varint,2,opt,name=tp,proto3" json:"tp,omitempty"`
	Data    []byte           `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	StartTs uint64           `protobuf:"varint,7,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	Ranges  []*KeyRange      `protobuf:"bytes,4,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// If cache is enabled, TiKV returns cache hit instead of data if
	// its last version matches this `cache_if_match_version`.
	IsCacheEnabled      bool   `protobuf:"varint,5,opt,name=is_cache_enabled,json=isCacheEnabled,proto3" json:"is_cache_enabled,omitempty"`
	CacheIfMatchVersion uint64 `protobuf:"varint,6,opt,name=cache_if_match_version,json=cacheIfMatchVersion,proto3" json:"cache_if_match_version,omitempty"`
	// Any schema-ful storage to validate schema correctness if necessary.
	SchemaVer      int64 `protobuf:"varint,8,opt,name=schema_ver,json=schemaVer,proto3" json:"schema_ver,omitempty"`
	IsTraceEnabled bool  `protobuf:"varint,9,opt,name=is_trace_enabled,json=isTraceEnabled,proto3" json:"is_trace_enabled,omitempty"`
	// paging_size is 0 when it's disabled, otherwise, it should be a positive number.
	PagingSize uint64 `protobuf:"varint,10,opt,name=paging_size,json=pagingSize,proto3" json:"paging_size,omitempty"`
	// tasks stores the batched coprocessor tasks sent to the same tikv store.
	Tasks           []*StoreBatchTask `protobuf:"bytes,11,rep,name=tasks,proto3" json:"tasks,omitempty"`
	ConnectionId    uint64            `protobuf:"varint,12,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ConnectionAlias string            `protobuf:"bytes,13,opt,name=connection_alias,json=connectionAlias,proto3" json:"connection_alias,omitempty"`
}

func (*Request) Descriptor 

func (*Request) Descriptor() ([]byte, []int)

func (*Request) GetCacheIfMatchVersion 

func (m *Request) GetCacheIfMatchVersion() uint64

func (*Request) GetConnectionAlias 

func (m *Request) GetConnectionAlias() string

func (*Request) GetConnectionId 

func (m *Request) GetConnectionId() uint64

func (*Request) GetContext 

func (m *Request) GetContext() *kvrpcpb.Context

func (*Request) GetData 

func (m *Request) GetData() []byte

func (*Request) GetIsCacheEnabled 

func (m *Request) GetIsCacheEnabled() bool

func (*Request) GetIsTraceEnabled 

func (m *Request) GetIsTraceEnabled() bool

func (*Request) GetPagingSize 

func (m *Request) GetPagingSize() uint64

func (*Request) GetRanges 

func (m *Request) GetRanges() []*KeyRange

func (*Request) GetSchemaVer 

func (m *Request) GetSchemaVer() int64

func (*Request) GetStartTs 

func (m *Request) GetStartTs() uint64

func (*Request) GetTasks 

func (m *Request) GetTasks() []*StoreBatchTask

func (*Request) GetTp 

func (m *Request) GetTp() int64

func (*Request) Marshal 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

func (m *Request) Size() (n int)

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge 

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

func (m *Request) XXX_Unmarshal(b []byte) error

type Response 

type Response struct {
	Data        github_com_pingcap_kvproto_pkg_sharedbytes.SharedBytes `protobuf:"bytes,1,opt,name=data,proto3,customtype=github.com/pingcap/kvproto/pkg/sharedbytes.SharedBytes" json:"data"`
	RegionError *errorpb.Error                                         `protobuf:"bytes,2,opt,name=region_error,json=regionError,proto3" json:"region_error,omitempty"`
	Locked      *kvrpcpb.LockInfo                                      `protobuf:"bytes,3,opt,name=locked,proto3" json:"locked,omitempty"`
	OtherError  string                                                 `protobuf:"bytes,4,opt,name=other_error,json=otherError,proto3" json:"other_error,omitempty"`
	Range       *KeyRange                                              `protobuf:"bytes,5,opt,name=range,proto3" json:"range,omitempty"`
	// This field is always filled for compatibility consideration. However
	// newer TiDB should respect `exec_details_v2` field instead.
	ExecDetails *kvrpcpb.ExecDetails `protobuf:"bytes,6,opt,name=exec_details,json=execDetails,proto3" json:"exec_details,omitempty"`
	// This field is provided in later versions, containing more detailed
	// information.
	ExecDetailsV2    *kvrpcpb.ExecDetailsV2 `protobuf:"bytes,11,opt,name=exec_details_v2,json=execDetailsV2,proto3" json:"exec_details_v2,omitempty"`
	IsCacheHit       bool                   `protobuf:"varint,7,opt,name=is_cache_hit,json=isCacheHit,proto3" json:"is_cache_hit,omitempty"`
	CacheLastVersion uint64                 `protobuf:"varint,8,opt,name=cache_last_version,json=cacheLastVersion,proto3" json:"cache_last_version,omitempty"`
	CanBeCached      bool                   `protobuf:"varint,9,opt,name=can_be_cached,json=canBeCached,proto3" json:"can_be_cached,omitempty"`
	// Contains the latest buckets version of the region.
	// Clients should query PD to update buckets in cache if its is stale.
	LatestBucketsVersion uint64 `protobuf:"varint,12,opt,name=latest_buckets_version,json=latestBucketsVersion,proto3" json:"latest_buckets_version,omitempty"`
	// StoreBatchTaskResponse is the collection of batch task responses.
	BatchResponses []*StoreBatchTaskResponse `protobuf:"bytes,13,rep,name=batch_responses,json=batchResponses,proto3" json:"batch_responses,omitempty"`
}

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetBatchResponses 

func (m *Response) GetBatchResponses() []*StoreBatchTaskResponse

func (*Response) GetCacheLastVersion 

func (m *Response) GetCacheLastVersion() uint64

func (*Response) GetCanBeCached 

func (m *Response) GetCanBeCached() bool

func (*Response) GetExecDetails 

func (m *Response) GetExecDetails() *kvrpcpb.ExecDetails

func (*Response) GetExecDetailsV2 

func (m *Response) GetExecDetailsV2() *kvrpcpb.ExecDetailsV2

func (*Response) GetIsCacheHit 

func (m *Response) GetIsCacheHit() bool

func (*Response) GetLatestBucketsVersion 

func (m *Response) GetLatestBucketsVersion() uint64

func (*Response) GetLocked 

func (m *Response) GetLocked() *kvrpcpb.LockInfo

func (*Response) GetOtherError 

func (m *Response) GetOtherError() string

func (*Response) GetRange 

func (m *Response) GetRange() *KeyRange

func (*Response) GetRegionError 

func (m *Response) GetRegionError() *errorpb.Error

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type StoreBatchTask 

type StoreBatchTask struct {
	RegionId    uint64              `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,2,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	Peer        *metapb.Peer        `protobuf:"bytes,3,opt,name=peer,proto3" json:"peer,omitempty"`
	Ranges      []*KeyRange         `protobuf:"bytes,4,rep,name=ranges,proto3" json:"ranges,omitempty"`
	TaskId      uint64              `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
}

func (*StoreBatchTask) Descriptor 

func (*StoreBatchTask) Descriptor() ([]byte, []int)

func (*StoreBatchTask) GetPeer 

func (m *StoreBatchTask) GetPeer() *metapb.Peer

func (*StoreBatchTask) GetRanges 

func (m *StoreBatchTask) GetRanges() []*KeyRange

func (*StoreBatchTask) GetRegionEpoch 

func (m *StoreBatchTask) GetRegionEpoch() *metapb.RegionEpoch

func (*StoreBatchTask) GetRegionId 

func (m *StoreBatchTask) GetRegionId() uint64

func (*StoreBatchTask) GetTaskId 

func (m *StoreBatchTask) GetTaskId() uint64

func (*StoreBatchTask) Marshal 

func (m *StoreBatchTask) Marshal() (dAtA []byte, err error)

func (*StoreBatchTask) MarshalTo 

func (m *StoreBatchTask) MarshalTo(dAtA []byte) (int, error)

func (*StoreBatchTask) MarshalToSizedBuffer 

func (m *StoreBatchTask) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StoreBatchTask) ProtoMessage 

func (*StoreBatchTask) ProtoMessage()

func (*StoreBatchTask) Reset 

func (m *StoreBatchTask) Reset()

func (*StoreBatchTask) Size 

func (m *StoreBatchTask) Size() (n int)

func (*StoreBatchTask) String 

func (m *StoreBatchTask) String() string

func (*StoreBatchTask) Unmarshal 

func (m *StoreBatchTask) Unmarshal(dAtA []byte) error

func (*StoreBatchTask) XXX_DiscardUnknown 

func (m *StoreBatchTask) XXX_DiscardUnknown()

func (*StoreBatchTask) XXX_Marshal 

func (m *StoreBatchTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoreBatchTask) XXX_Merge 

func (m *StoreBatchTask) XXX_Merge(src proto.Message)

func (*StoreBatchTask) XXX_Size 

func (m *StoreBatchTask) XXX_Size() int

func (*StoreBatchTask) XXX_Unmarshal 

func (m *StoreBatchTask) XXX_Unmarshal(b []byte) error

type StoreBatchTaskResponse 

type StoreBatchTaskResponse struct {
	Data          github_com_pingcap_kvproto_pkg_sharedbytes.SharedBytes `protobuf:"bytes,1,opt,name=data,proto3,customtype=github.com/pingcap/kvproto/pkg/sharedbytes.SharedBytes" json:"data"`
	RegionError   *errorpb.Error                                         `protobuf:"bytes,2,opt,name=region_error,json=regionError,proto3" json:"region_error,omitempty"`
	Locked        *kvrpcpb.LockInfo                                      `protobuf:"bytes,3,opt,name=locked,proto3" json:"locked,omitempty"`
	OtherError    string                                                 `protobuf:"bytes,4,opt,name=other_error,json=otherError,proto3" json:"other_error,omitempty"`
	TaskId        uint64                                                 `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ExecDetailsV2 *kvrpcpb.ExecDetailsV2                                 `protobuf:"bytes,6,opt,name=exec_details_v2,json=execDetailsV2,proto3" json:"exec_details_v2,omitempty"`
}

func (*StoreBatchTaskResponse) Descriptor 

func (*StoreBatchTaskResponse) Descriptor() ([]byte, []int)

func (*StoreBatchTaskResponse) GetExecDetailsV2 

func (m *StoreBatchTaskResponse) GetExecDetailsV2() *kvrpcpb.ExecDetailsV2

func (*StoreBatchTaskResponse) GetLocked 

func (m *StoreBatchTaskResponse) GetLocked() *kvrpcpb.LockInfo

func (*StoreBatchTaskResponse) GetOtherError 

func (m *StoreBatchTaskResponse) GetOtherError() string

func (*StoreBatchTaskResponse) GetRegionError 

func (m *StoreBatchTaskResponse) GetRegionError() *errorpb.Error

func (*StoreBatchTaskResponse) GetTaskId 

func (m *StoreBatchTaskResponse) GetTaskId() uint64

func (*StoreBatchTaskResponse) Marshal 

func (m *StoreBatchTaskResponse) Marshal() (dAtA []byte, err error)

func (*StoreBatchTaskResponse) MarshalTo 

func (m *StoreBatchTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*StoreBatchTaskResponse) MarshalToSizedBuffer 

func (m *StoreBatchTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StoreBatchTaskResponse) ProtoMessage 

func (*StoreBatchTaskResponse) ProtoMessage()

func (*StoreBatchTaskResponse) Reset 

func (m *StoreBatchTaskResponse) Reset()

func (*StoreBatchTaskResponse) Size 

func (m *StoreBatchTaskResponse) Size() (n int)

func (*StoreBatchTaskResponse) String 

func (m *StoreBatchTaskResponse) String() string

func (*StoreBatchTaskResponse) Unmarshal 

func (m *StoreBatchTaskResponse) Unmarshal(dAtA []byte) error

func (*StoreBatchTaskResponse) XXX_DiscardUnknown 

func (m *StoreBatchTaskResponse) XXX_DiscardUnknown()

func (*StoreBatchTaskResponse) XXX_Marshal 

func (m *StoreBatchTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StoreBatchTaskResponse) XXX_Merge 

func (m *StoreBatchTaskResponse) XXX_Merge(src proto.Message)

func (*StoreBatchTaskResponse) XXX_Size 

func (m *StoreBatchTaskResponse) XXX_Size() int

func (*StoreBatchTaskResponse) XXX_Unmarshal 

func (m *StoreBatchTaskResponse) XXX_Unmarshal(b []byte) error

type TableRegions 

type TableRegions struct {
	PhysicalTableId int64         `protobuf:"varint,1,opt,name=physical_table_id,json=physicalTableId,proto3" json:"physical_table_id,omitempty"`
	Regions         []*RegionInfo `protobuf:"bytes,2,rep,name=regions,proto3" json:"regions,omitempty"`
}

func (*TableRegions) Descriptor 

func (*TableRegions) Descriptor() ([]byte, []int)

func (*TableRegions) GetPhysicalTableId 

func (m *TableRegions) GetPhysicalTableId() int64

func (*TableRegions) GetRegions 

func (m *TableRegions) GetRegions() []*RegionInfo

func (*TableRegions) Marshal 

func (m *TableRegions) Marshal() (dAtA []byte, err error)

func (*TableRegions) MarshalTo 

func (m *TableRegions) MarshalTo(dAtA []byte) (int, error)

func (*TableRegions) MarshalToSizedBuffer 

func (m *TableRegions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TableRegions) ProtoMessage 

func (*TableRegions) ProtoMessage()

func (*TableRegions) Reset 

func (m *TableRegions) Reset()

func (*TableRegions) Size 

func (m *TableRegions) Size() (n int)

func (*TableRegions) String 

func (m *TableRegions) String() string

func (*TableRegions) Unmarshal 

func (m *TableRegions) Unmarshal(dAtA []byte) error

func (*TableRegions) XXX_DiscardUnknown 

func (m *TableRegions) XXX_DiscardUnknown()

func (*TableRegions) XXX_Marshal 

func (m *TableRegions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableRegions) XXX_Merge 

func (m *TableRegions) XXX_Merge(src proto.Message)

func (*TableRegions) XXX_Size 

func (m *TableRegions) XXX_Size() int

func (*TableRegions) XXX_Unmarshal 

func (m *TableRegions) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.