mpp

package
v0.0.0-...-3b3056d Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMpp        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMpp          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMpp = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type CancelTaskRequest 

type CancelTaskRequest struct {
	Meta                 *TaskMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Error                *Error    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

CancelTaskRequest closes the execution of a task.

func (*CancelTaskRequest) Descriptor 

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

func (*CancelTaskRequest) GetError 

func (m *CancelTaskRequest) GetError() *Error

func (*CancelTaskRequest) GetMeta 

func (m *CancelTaskRequest) GetMeta() *TaskMeta

func (*CancelTaskRequest) Marshal 

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

func (*CancelTaskRequest) MarshalTo 

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

func (*CancelTaskRequest) MarshalToSizedBuffer 

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

func (*CancelTaskRequest) ProtoMessage 

func (*CancelTaskRequest) ProtoMessage()

func (*CancelTaskRequest) Reset 

func (m *CancelTaskRequest) Reset()

func (*CancelTaskRequest) Size 

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

func (*CancelTaskRequest) String 

func (m *CancelTaskRequest) String() string

func (*CancelTaskRequest) Unmarshal 

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

func (*CancelTaskRequest) XXX_DiscardUnknown 

func (m *CancelTaskRequest) XXX_DiscardUnknown()

func (*CancelTaskRequest) XXX_Marshal 

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

func (*CancelTaskRequest) XXX_Merge 

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

func (*CancelTaskRequest) XXX_Size 

func (m *CancelTaskRequest) XXX_Size() int

func (*CancelTaskRequest) XXX_Unmarshal 

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

type CancelTaskResponse 

type CancelTaskResponse struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelTaskResponse) Descriptor 

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

func (*CancelTaskResponse) GetError 

func (m *CancelTaskResponse) GetError() *Error

func (*CancelTaskResponse) Marshal 

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

func (*CancelTaskResponse) MarshalTo 

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

func (*CancelTaskResponse) MarshalToSizedBuffer 

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

func (*CancelTaskResponse) ProtoMessage 

func (*CancelTaskResponse) ProtoMessage()

func (*CancelTaskResponse) Reset 

func (m *CancelTaskResponse) Reset()

func (*CancelTaskResponse) Size 

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

func (*CancelTaskResponse) String 

func (m *CancelTaskResponse) String() string

func (*CancelTaskResponse) Unmarshal 

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

func (*CancelTaskResponse) XXX_DiscardUnknown 

func (m *CancelTaskResponse) XXX_DiscardUnknown()

func (*CancelTaskResponse) XXX_Marshal 

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

func (*CancelTaskResponse) XXX_Merge 

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

func (*CancelTaskResponse) XXX_Size 

func (m *CancelTaskResponse) XXX_Size() int

func (*CancelTaskResponse) XXX_Unmarshal 

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

type DispatchTaskRequest 

type DispatchTaskRequest struct {
	Meta        *TaskMeta                 `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	EncodedPlan []byte                    `protobuf:"bytes,2,opt,name=encoded_plan,json=encodedPlan,proto3" json:"encoded_plan,omitempty"`
	Timeout     int64                     `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Regions     []*coprocessor.RegionInfo `protobuf:"bytes,4,rep,name=regions,proto3" json:"regions,omitempty"`
	// If this task contains table scan, we still need their region info.
	SchemaVer int64 `protobuf:"varint,5,opt,name=schema_ver,json=schemaVer,proto3" json:"schema_ver,omitempty"`
	// Used for partition table scan
	TableRegions         []*coprocessor.TableRegions `protobuf:"bytes,6,rep,name=table_regions,json=tableRegions,proto3" json:"table_regions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Dipsatch the task request to different tiflash servers.

func (*DispatchTaskRequest) Descriptor 

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

func (*DispatchTaskRequest) GetEncodedPlan 

func (m *DispatchTaskRequest) GetEncodedPlan() []byte

func (*DispatchTaskRequest) GetMeta 

func (m *DispatchTaskRequest) GetMeta() *TaskMeta

func (*DispatchTaskRequest) GetRegions 

func (m *DispatchTaskRequest) GetRegions() []*coprocessor.RegionInfo

func (*DispatchTaskRequest) GetSchemaVer 

func (m *DispatchTaskRequest) GetSchemaVer() int64

func (*DispatchTaskRequest) GetTableRegions 

func (m *DispatchTaskRequest) GetTableRegions() []*coprocessor.TableRegions

func (*DispatchTaskRequest) GetTimeout 

func (m *DispatchTaskRequest) GetTimeout() int64

func (*DispatchTaskRequest) Marshal 

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

func (*DispatchTaskRequest) MarshalTo 

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

func (*DispatchTaskRequest) MarshalToSizedBuffer 

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

func (*DispatchTaskRequest) ProtoMessage 

func (*DispatchTaskRequest) ProtoMessage()

func (*DispatchTaskRequest) Reset 

func (m *DispatchTaskRequest) Reset()

func (*DispatchTaskRequest) Size 

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

func (*DispatchTaskRequest) String 

func (m *DispatchTaskRequest) String() string

func (*DispatchTaskRequest) Unmarshal 

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

func (*DispatchTaskRequest) XXX_DiscardUnknown 

func (m *DispatchTaskRequest) XXX_DiscardUnknown()

func (*DispatchTaskRequest) XXX_Marshal 

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

func (*DispatchTaskRequest) XXX_Merge 

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

func (*DispatchTaskRequest) XXX_Size 

func (m *DispatchTaskRequest) XXX_Size() int

func (*DispatchTaskRequest) XXX_Unmarshal 

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

type DispatchTaskResponse 

type DispatchTaskResponse struct {
	Error                *Error           `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	RetryRegions         []*metapb.Region `protobuf:"bytes,2,rep,name=retry_regions,json=retryRegions,proto3" json:"retry_regions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Get response of DispatchTaskRequest.

func (*DispatchTaskResponse) Descriptor 

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

func (*DispatchTaskResponse) GetError 

func (m *DispatchTaskResponse) GetError() *Error

func (*DispatchTaskResponse) GetRetryRegions 

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

func (*DispatchTaskResponse) Marshal 

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

func (*DispatchTaskResponse) MarshalTo 

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

func (*DispatchTaskResponse) MarshalToSizedBuffer 

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

func (*DispatchTaskResponse) ProtoMessage 

func (*DispatchTaskResponse) ProtoMessage()

func (*DispatchTaskResponse) Reset 

func (m *DispatchTaskResponse) Reset()

func (*DispatchTaskResponse) Size 

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

func (*DispatchTaskResponse) String 

func (m *DispatchTaskResponse) String() string

func (*DispatchTaskResponse) Unmarshal 

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

func (*DispatchTaskResponse) XXX_DiscardUnknown 

func (m *DispatchTaskResponse) XXX_DiscardUnknown()

func (*DispatchTaskResponse) XXX_Marshal 

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

func (*DispatchTaskResponse) XXX_Merge 

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

func (*DispatchTaskResponse) XXX_Size 

func (m *DispatchTaskResponse) XXX_Size() int

func (*DispatchTaskResponse) XXX_Unmarshal 

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

type Error 

type Error struct {
	Code                 int32    `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() int32

func (*Error) GetMsg 

func (m *Error) GetMsg() string

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type EstablishMPPConnectionRequest 

type EstablishMPPConnectionRequest struct {
	SenderMeta           *TaskMeta `protobuf:"bytes,1,opt,name=sender_meta,json=senderMeta,proto3" json:"sender_meta,omitempty"`
	ReceiverMeta         *TaskMeta `protobuf:"bytes,2,opt,name=receiver_meta,json=receiverMeta,proto3" json:"receiver_meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

build connection between different tasks. Data is sent by the tasks that are closer to the data sources.

func (*EstablishMPPConnectionRequest) Descriptor 

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

func (*EstablishMPPConnectionRequest) GetReceiverMeta 

func (m *EstablishMPPConnectionRequest) GetReceiverMeta() *TaskMeta

func (*EstablishMPPConnectionRequest) GetSenderMeta 

func (m *EstablishMPPConnectionRequest) GetSenderMeta() *TaskMeta

func (*EstablishMPPConnectionRequest) Marshal 

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

func (*EstablishMPPConnectionRequest) MarshalTo 

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

func (*EstablishMPPConnectionRequest) MarshalToSizedBuffer 

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

func (*EstablishMPPConnectionRequest) ProtoMessage 

func (*EstablishMPPConnectionRequest) ProtoMessage()

func (*EstablishMPPConnectionRequest) Reset 

func (m *EstablishMPPConnectionRequest) Reset()

func (*EstablishMPPConnectionRequest) Size 

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

func (*EstablishMPPConnectionRequest) String 

func (m *EstablishMPPConnectionRequest) String() string

func (*EstablishMPPConnectionRequest) Unmarshal 

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

func (*EstablishMPPConnectionRequest) XXX_DiscardUnknown 

func (m *EstablishMPPConnectionRequest) XXX_DiscardUnknown()

func (*EstablishMPPConnectionRequest) XXX_Marshal 

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

func (*EstablishMPPConnectionRequest) XXX_Merge 

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

func (*EstablishMPPConnectionRequest) XXX_Size 

func (m *EstablishMPPConnectionRequest) XXX_Size() int

func (*EstablishMPPConnectionRequest) XXX_Unmarshal 

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

type FillMaterializedViewRequest 

type FillMaterializedViewRequest struct {
	BaseDbId             int64    `protobuf:"varint,1,opt,name=base_db_id,json=baseDbId,proto3" json:"base_db_id,omitempty"`
	BaseTableId          int64    `protobuf:"varint,2,opt,name=base_table_id,json=baseTableId,proto3" json:"base_table_id,omitempty"`
	MvDbId               int64    `protobuf:"varint,3,opt,name=mv_db_id,json=mvDbId,proto3" json:"mv_db_id,omitempty"`
	MvTableId            int64    `protobuf:"varint,4,opt,name=mv_table_id,json=mvTableId,proto3" json:"mv_table_id,omitempty"`
	SelectQuery          []byte   `protobuf:"bytes,5,opt,name=select_query,json=selectQuery,proto3" json:"select_query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FillMaterializedViewRequest) Descriptor 

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

func (*FillMaterializedViewRequest) GetBaseDbId 

func (m *FillMaterializedViewRequest) GetBaseDbId() int64

func (*FillMaterializedViewRequest) GetBaseTableId 

func (m *FillMaterializedViewRequest) GetBaseTableId() int64

func (*FillMaterializedViewRequest) GetMvDbId 

func (m *FillMaterializedViewRequest) GetMvDbId() int64

func (*FillMaterializedViewRequest) GetMvTableId 

func (m *FillMaterializedViewRequest) GetMvTableId() int64

func (*FillMaterializedViewRequest) GetSelectQuery 

func (m *FillMaterializedViewRequest) GetSelectQuery() []byte

func (*FillMaterializedViewRequest) Marshal 

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

func (*FillMaterializedViewRequest) MarshalTo 

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

func (*FillMaterializedViewRequest) MarshalToSizedBuffer 

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

func (*FillMaterializedViewRequest) ProtoMessage 

func (*FillMaterializedViewRequest) ProtoMessage()

func (*FillMaterializedViewRequest) Reset 

func (m *FillMaterializedViewRequest) Reset()

func (*FillMaterializedViewRequest) Size 

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

func (*FillMaterializedViewRequest) String 

func (m *FillMaterializedViewRequest) String() string

func (*FillMaterializedViewRequest) Unmarshal 

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

func (*FillMaterializedViewRequest) XXX_DiscardUnknown 

func (m *FillMaterializedViewRequest) XXX_DiscardUnknown()

func (*FillMaterializedViewRequest) XXX_Marshal 

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

func (*FillMaterializedViewRequest) XXX_Merge 

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

func (*FillMaterializedViewRequest) XXX_Size 

func (m *FillMaterializedViewRequest) XXX_Size() int

func (*FillMaterializedViewRequest) XXX_Unmarshal 

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

type FillMaterializedViewResponse 

type FillMaterializedViewResponse struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FillMaterializedViewResponse) Descriptor 

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

func (*FillMaterializedViewResponse) GetError 

func (m *FillMaterializedViewResponse) GetError() string

func (*FillMaterializedViewResponse) Marshal 

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

func (*FillMaterializedViewResponse) MarshalTo 

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

func (*FillMaterializedViewResponse) MarshalToSizedBuffer 

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

func (*FillMaterializedViewResponse) ProtoMessage 

func (*FillMaterializedViewResponse) ProtoMessage()

func (*FillMaterializedViewResponse) Reset 

func (m *FillMaterializedViewResponse) Reset()

func (*FillMaterializedViewResponse) Size 

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

func (*FillMaterializedViewResponse) String 

func (m *FillMaterializedViewResponse) String() string

func (*FillMaterializedViewResponse) Unmarshal 

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

func (*FillMaterializedViewResponse) XXX_DiscardUnknown 

func (m *FillMaterializedViewResponse) XXX_DiscardUnknown()

func (*FillMaterializedViewResponse) XXX_Marshal 

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

func (*FillMaterializedViewResponse) XXX_Merge 

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

func (*FillMaterializedViewResponse) XXX_Size 

func (m *FillMaterializedViewResponse) XXX_Size() int

func (*FillMaterializedViewResponse) XXX_Unmarshal 

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

type IsAliveRequest 

type IsAliveRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsAliveRequest) Descriptor 

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

func (*IsAliveRequest) Marshal 

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

func (*IsAliveRequest) MarshalTo 

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

func (*IsAliveRequest) MarshalToSizedBuffer 

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

func (*IsAliveRequest) ProtoMessage 

func (*IsAliveRequest) ProtoMessage()

func (*IsAliveRequest) Reset 

func (m *IsAliveRequest) Reset()

func (*IsAliveRequest) Size 

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

func (*IsAliveRequest) String 

func (m *IsAliveRequest) String() string

func (*IsAliveRequest) Unmarshal 

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

func (*IsAliveRequest) XXX_DiscardUnknown 

func (m *IsAliveRequest) XXX_DiscardUnknown()

func (*IsAliveRequest) XXX_Marshal 

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

func (*IsAliveRequest) XXX_Merge 

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

func (*IsAliveRequest) XXX_Size 

func (m *IsAliveRequest) XXX_Size() int

func (*IsAliveRequest) XXX_Unmarshal 

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

type IsAliveResponse 

type IsAliveResponse struct {
	Available            bool     `protobuf:"varint,1,opt,name=available,proto3" json:"available,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsAliveResponse) Descriptor 

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

func (*IsAliveResponse) GetAvailable 

func (m *IsAliveResponse) GetAvailable() bool

func (*IsAliveResponse) Marshal 

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

func (*IsAliveResponse) MarshalTo 

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

func (*IsAliveResponse) MarshalToSizedBuffer 

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

func (*IsAliveResponse) ProtoMessage 

func (*IsAliveResponse) ProtoMessage()

func (*IsAliveResponse) Reset 

func (m *IsAliveResponse) Reset()

func (*IsAliveResponse) Size 

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

func (*IsAliveResponse) String 

func (m *IsAliveResponse) String() string

func (*IsAliveResponse) Unmarshal 

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

func (*IsAliveResponse) XXX_DiscardUnknown 

func (m *IsAliveResponse) XXX_DiscardUnknown()

func (*IsAliveResponse) XXX_Marshal 

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

func (*IsAliveResponse) XXX_Merge 

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

func (*IsAliveResponse) XXX_Size 

func (m *IsAliveResponse) XXX_Size() int

func (*IsAliveResponse) XXX_Unmarshal 

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

type MPPDataPacket 

type MPPDataPacket struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Chunks               [][]byte `protobuf:"bytes,3,rep,name=chunks,proto3" json:"chunks,omitempty"`
	StreamIds            []uint64 `protobuf:"varint,4,rep,packed,name=stream_ids,json=streamIds,proto3" json:"stream_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

when TiFlash sends data to TiDB, Data packets wrap tipb.SelectResponse, i.e., serialize tipb.SelectResponse into data; when TiFlash sends data to TiFlash, data blocks are serialized into chunks, and the execution_summaries in tipb.SelectResponse are serialized into data only for the last packet.

func (*MPPDataPacket) Descriptor 

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

func (*MPPDataPacket) GetChunks 

func (m *MPPDataPacket) GetChunks() [][]byte

func (*MPPDataPacket) GetData 

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

func (*MPPDataPacket) GetError 

func (m *MPPDataPacket) GetError() *Error

func (*MPPDataPacket) GetStreamIds 

func (m *MPPDataPacket) GetStreamIds() []uint64

func (*MPPDataPacket) Marshal 

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

func (*MPPDataPacket) MarshalTo 

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

func (*MPPDataPacket) MarshalToSizedBuffer 

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

func (*MPPDataPacket) ProtoMessage 

func (*MPPDataPacket) ProtoMessage()

func (*MPPDataPacket) Reset 

func (m *MPPDataPacket) Reset()

func (*MPPDataPacket) Size 

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

func (*MPPDataPacket) String 

func (m *MPPDataPacket) String() string

func (*MPPDataPacket) Unmarshal 

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

func (*MPPDataPacket) XXX_DiscardUnknown 

func (m *MPPDataPacket) XXX_DiscardUnknown()

func (*MPPDataPacket) XXX_Marshal 

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

func (*MPPDataPacket) XXX_Merge 

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

func (*MPPDataPacket) XXX_Size 

func (m *MPPDataPacket) XXX_Size() int

func (*MPPDataPacket) XXX_Unmarshal 

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

type TaskMeta 

type TaskMeta struct {
	StartTs              uint64   `protobuf:"varint,1,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	TaskId               int64    `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	PartitionId          int64    `protobuf:"varint,3,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Address              string   `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TaskMeta contains meta of a mpp plan, including query's ts and task address.

func (*TaskMeta) Descriptor 

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

func (*TaskMeta) GetAddress 

func (m *TaskMeta) GetAddress() string

func (*TaskMeta) GetPartitionId 

func (m *TaskMeta) GetPartitionId() int64

func (*TaskMeta) GetStartTs 

func (m *TaskMeta) GetStartTs() uint64

func (*TaskMeta) GetTaskId 

func (m *TaskMeta) GetTaskId() int64

func (*TaskMeta) Marshal 

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

func (*TaskMeta) MarshalTo 

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

func (*TaskMeta) MarshalToSizedBuffer 

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

func (*TaskMeta) ProtoMessage 

func (*TaskMeta) ProtoMessage()

func (*TaskMeta) Reset 

func (m *TaskMeta) Reset()

func (*TaskMeta) Size 

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

func (*TaskMeta) String 

func (m *TaskMeta) String() string

func (*TaskMeta) Unmarshal 

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

func (*TaskMeta) XXX_DiscardUnknown 

func (m *TaskMeta) XXX_DiscardUnknown()

func (*TaskMeta) XXX_Marshal 

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

func (*TaskMeta) XXX_Merge 

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

func (*TaskMeta) XXX_Size 

func (m *TaskMeta) XXX_Size() int

func (*TaskMeta) XXX_Unmarshal 

func (m *TaskMeta) 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.