coprocessor

package
Version: v0.0.0-...-ca78592 Latest Latest
Warning

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

Go to latest
Published: Nov 30, 2022 License: Apache-2.0 Imports: 10 Imported by: 535

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*BatchRequest) Descriptor

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

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"`
	XXX_NoUnkeyedLiteral struct{}                                               `json:"-"`
	XXX_unrecognized     []byte                                                 `json:"-"`
	XXX_sizecache        int32                                                  `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

[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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Request) Descriptor

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

func (*Request) GetCacheIfMatchVersion

func (m *Request) GetCacheIfMatchVersion() 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"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}                                               `json:"-"`
	XXX_unrecognized     []byte                                                 `json:"-"`
	XXX_sizecache        int32                                                  `json:"-"`
}

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

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

Jump to

Keyboard shortcuts

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