Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowMpp = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMpp = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupMpp = fmt.Errorf("proto: unexpected end of group") + type CancelTaskRequest struct + Error *Error + Meta *TaskMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CancelTaskRequest) Descriptor() ([]byte, []int) + func (*CancelTaskRequest) ProtoMessage() + func (m *CancelTaskRequest) GetError() *Error + func (m *CancelTaskRequest) GetMeta() *TaskMeta + func (m *CancelTaskRequest) Marshal() (dAtA []byte, err error) + func (m *CancelTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CancelTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CancelTaskRequest) Reset() + func (m *CancelTaskRequest) Size() (n int) + func (m *CancelTaskRequest) String() string + func (m *CancelTaskRequest) Unmarshal(dAtA []byte) error + func (m *CancelTaskRequest) XXX_DiscardUnknown() + func (m *CancelTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CancelTaskRequest) XXX_Merge(src proto.Message) + func (m *CancelTaskRequest) XXX_Size() int + func (m *CancelTaskRequest) XXX_Unmarshal(b []byte) error + type CancelTaskResponse struct + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CancelTaskResponse) Descriptor() ([]byte, []int) + func (*CancelTaskResponse) ProtoMessage() + func (m *CancelTaskResponse) GetError() *Error + func (m *CancelTaskResponse) Marshal() (dAtA []byte, err error) + func (m *CancelTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CancelTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CancelTaskResponse) Reset() + func (m *CancelTaskResponse) Size() (n int) + func (m *CancelTaskResponse) String() string + func (m *CancelTaskResponse) Unmarshal(dAtA []byte) error + func (m *CancelTaskResponse) XXX_DiscardUnknown() + func (m *CancelTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CancelTaskResponse) XXX_Merge(src proto.Message) + func (m *CancelTaskResponse) XXX_Size() int + func (m *CancelTaskResponse) XXX_Unmarshal(b []byte) error + type DispatchTaskRequest struct + EncodedPlan []byte + Meta *TaskMeta + Regions []*coprocessor.RegionInfo + SchemaVer int64 + TableRegions []*coprocessor.TableRegions + Timeout int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DispatchTaskRequest) Descriptor() ([]byte, []int) + func (*DispatchTaskRequest) ProtoMessage() + func (m *DispatchTaskRequest) GetEncodedPlan() []byte + func (m *DispatchTaskRequest) GetMeta() *TaskMeta + func (m *DispatchTaskRequest) GetRegions() []*coprocessor.RegionInfo + func (m *DispatchTaskRequest) GetSchemaVer() int64 + func (m *DispatchTaskRequest) GetTableRegions() []*coprocessor.TableRegions + func (m *DispatchTaskRequest) GetTimeout() int64 + func (m *DispatchTaskRequest) Marshal() (dAtA []byte, err error) + func (m *DispatchTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DispatchTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DispatchTaskRequest) Reset() + func (m *DispatchTaskRequest) Size() (n int) + func (m *DispatchTaskRequest) String() string + func (m *DispatchTaskRequest) Unmarshal(dAtA []byte) error + func (m *DispatchTaskRequest) XXX_DiscardUnknown() + func (m *DispatchTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DispatchTaskRequest) XXX_Merge(src proto.Message) + func (m *DispatchTaskRequest) XXX_Size() int + func (m *DispatchTaskRequest) XXX_Unmarshal(b []byte) error + type DispatchTaskResponse struct + Error *Error + RetryRegions []*metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DispatchTaskResponse) Descriptor() ([]byte, []int) + func (*DispatchTaskResponse) ProtoMessage() + func (m *DispatchTaskResponse) GetError() *Error + func (m *DispatchTaskResponse) GetRetryRegions() []*metapb.Region + func (m *DispatchTaskResponse) Marshal() (dAtA []byte, err error) + func (m *DispatchTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DispatchTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DispatchTaskResponse) Reset() + func (m *DispatchTaskResponse) Size() (n int) + func (m *DispatchTaskResponse) String() string + func (m *DispatchTaskResponse) Unmarshal(dAtA []byte) error + func (m *DispatchTaskResponse) XXX_DiscardUnknown() + func (m *DispatchTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DispatchTaskResponse) XXX_Merge(src proto.Message) + func (m *DispatchTaskResponse) XXX_Size() int + func (m *DispatchTaskResponse) XXX_Unmarshal(b []byte) error + type Error struct + Code int32 + MppVersion int64 + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetCode() int32 + func (m *Error) GetMppVersion() int64 + func (m *Error) GetMsg() string + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type EstablishMPPConnectionRequest struct + ReceiverMeta *TaskMeta + SenderMeta *TaskMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EstablishMPPConnectionRequest) Descriptor() ([]byte, []int) + func (*EstablishMPPConnectionRequest) ProtoMessage() + func (m *EstablishMPPConnectionRequest) GetReceiverMeta() *TaskMeta + func (m *EstablishMPPConnectionRequest) GetSenderMeta() *TaskMeta + func (m *EstablishMPPConnectionRequest) Marshal() (dAtA []byte, err error) + func (m *EstablishMPPConnectionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *EstablishMPPConnectionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EstablishMPPConnectionRequest) Reset() + func (m *EstablishMPPConnectionRequest) Size() (n int) + func (m *EstablishMPPConnectionRequest) String() string + func (m *EstablishMPPConnectionRequest) Unmarshal(dAtA []byte) error + func (m *EstablishMPPConnectionRequest) XXX_DiscardUnknown() + func (m *EstablishMPPConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EstablishMPPConnectionRequest) XXX_Merge(src proto.Message) + func (m *EstablishMPPConnectionRequest) XXX_Size() int + func (m *EstablishMPPConnectionRequest) XXX_Unmarshal(b []byte) error + type IsAliveRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IsAliveRequest) Descriptor() ([]byte, []int) + func (*IsAliveRequest) ProtoMessage() + func (m *IsAliveRequest) Marshal() (dAtA []byte, err error) + func (m *IsAliveRequest) MarshalTo(dAtA []byte) (int, error) + func (m *IsAliveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IsAliveRequest) Reset() + func (m *IsAliveRequest) Size() (n int) + func (m *IsAliveRequest) String() string + func (m *IsAliveRequest) Unmarshal(dAtA []byte) error + func (m *IsAliveRequest) XXX_DiscardUnknown() + func (m *IsAliveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IsAliveRequest) XXX_Merge(src proto.Message) + func (m *IsAliveRequest) XXX_Size() int + func (m *IsAliveRequest) XXX_Unmarshal(b []byte) error + type IsAliveResponse struct + Available bool + MppVersion int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IsAliveResponse) Descriptor() ([]byte, []int) + func (*IsAliveResponse) ProtoMessage() + func (m *IsAliveResponse) GetAvailable() bool + func (m *IsAliveResponse) GetMppVersion() int64 + func (m *IsAliveResponse) Marshal() (dAtA []byte, err error) + func (m *IsAliveResponse) MarshalTo(dAtA []byte) (int, error) + func (m *IsAliveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IsAliveResponse) Reset() + func (m *IsAliveResponse) Size() (n int) + func (m *IsAliveResponse) String() string + func (m *IsAliveResponse) Unmarshal(dAtA []byte) error + func (m *IsAliveResponse) XXX_DiscardUnknown() + func (m *IsAliveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IsAliveResponse) XXX_Merge(src proto.Message) + func (m *IsAliveResponse) XXX_Size() int + func (m *IsAliveResponse) XXX_Unmarshal(b []byte) error + type MPPDataPacket struct + Chunks [][]byte + Data []byte + Error *Error + StreamIds []uint64 + Version int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MPPDataPacket) Descriptor() ([]byte, []int) + func (*MPPDataPacket) ProtoMessage() + func (m *MPPDataPacket) GetChunks() [][]byte + func (m *MPPDataPacket) GetData() []byte + func (m *MPPDataPacket) GetError() *Error + func (m *MPPDataPacket) GetStreamIds() []uint64 + func (m *MPPDataPacket) GetVersion() int64 + func (m *MPPDataPacket) Marshal() (dAtA []byte, err error) + func (m *MPPDataPacket) MarshalTo(dAtA []byte) (int, error) + func (m *MPPDataPacket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MPPDataPacket) Reset() + func (m *MPPDataPacket) Size() (n int) + func (m *MPPDataPacket) String() string + func (m *MPPDataPacket) Unmarshal(dAtA []byte) error + func (m *MPPDataPacket) XXX_DiscardUnknown() + func (m *MPPDataPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MPPDataPacket) XXX_Merge(src proto.Message) + func (m *MPPDataPacket) XXX_Size() int + func (m *MPPDataPacket) XXX_Unmarshal(b []byte) error + type ReportTaskStatusRequest struct + Data []byte + Error *Error + Meta *TaskMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportTaskStatusRequest) Descriptor() ([]byte, []int) + func (*ReportTaskStatusRequest) ProtoMessage() + func (m *ReportTaskStatusRequest) GetData() []byte + func (m *ReportTaskStatusRequest) GetError() *Error + func (m *ReportTaskStatusRequest) GetMeta() *TaskMeta + func (m *ReportTaskStatusRequest) Marshal() (dAtA []byte, err error) + func (m *ReportTaskStatusRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ReportTaskStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReportTaskStatusRequest) Reset() + func (m *ReportTaskStatusRequest) Size() (n int) + func (m *ReportTaskStatusRequest) String() string + func (m *ReportTaskStatusRequest) Unmarshal(dAtA []byte) error + func (m *ReportTaskStatusRequest) XXX_DiscardUnknown() + func (m *ReportTaskStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReportTaskStatusRequest) XXX_Merge(src proto.Message) + func (m *ReportTaskStatusRequest) XXX_Size() int + func (m *ReportTaskStatusRequest) XXX_Unmarshal(b []byte) error + type ReportTaskStatusResponse struct + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportTaskStatusResponse) Descriptor() ([]byte, []int) + func (*ReportTaskStatusResponse) ProtoMessage() + func (m *ReportTaskStatusResponse) GetError() *Error + func (m *ReportTaskStatusResponse) Marshal() (dAtA []byte, err error) + func (m *ReportTaskStatusResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ReportTaskStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ReportTaskStatusResponse) Reset() + func (m *ReportTaskStatusResponse) Size() (n int) + func (m *ReportTaskStatusResponse) String() string + func (m *ReportTaskStatusResponse) Unmarshal(dAtA []byte) error + func (m *ReportTaskStatusResponse) XXX_DiscardUnknown() + func (m *ReportTaskStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReportTaskStatusResponse) XXX_Merge(src proto.Message) + func (m *ReportTaskStatusResponse) XXX_Size() int + func (m *ReportTaskStatusResponse) XXX_Unmarshal(b []byte) error + type TaskMeta struct + Address string + ApiVersion kvrpcpb.APIVersion + CoordinatorAddress string + GatherId uint64 + KeyspaceId uint32 + LocalQueryId uint64 + MppVersion int64 + PartitionId int64 + QueryTs uint64 + ServerId uint64 + StartTs uint64 + TaskId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TaskMeta) Descriptor() ([]byte, []int) + func (*TaskMeta) ProtoMessage() + func (m *TaskMeta) GetAddress() string + func (m *TaskMeta) GetApiVersion() kvrpcpb.APIVersion + func (m *TaskMeta) GetCoordinatorAddress() string + func (m *TaskMeta) GetGatherId() uint64 + func (m *TaskMeta) GetKeyspaceId() uint32 + func (m *TaskMeta) GetLocalQueryId() uint64 + func (m *TaskMeta) GetMppVersion() int64 + func (m *TaskMeta) GetPartitionId() int64 + func (m *TaskMeta) GetQueryTs() uint64 + func (m *TaskMeta) GetServerId() uint64 + func (m *TaskMeta) GetStartTs() uint64 + func (m *TaskMeta) GetTaskId() int64 + func (m *TaskMeta) Marshal() (dAtA []byte, err error) + func (m *TaskMeta) MarshalTo(dAtA []byte) (int, error) + func (m *TaskMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TaskMeta) Reset() + func (m *TaskMeta) Size() (n int) + func (m *TaskMeta) String() string + func (m *TaskMeta) Unmarshal(dAtA []byte) error + func (m *TaskMeta) XXX_DiscardUnknown() + func (m *TaskMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TaskMeta) XXX_Merge(src proto.Message) + func (m *TaskMeta) XXX_Size() int + func (m *TaskMeta) XXX_Unmarshal(b []byte) error