mpp

package
v0.0.0-...-17bdaaa Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2024 License: Apache-2.0 Imports: 9 Imported by: 37

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"`
}

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"`
}

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"`
}

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"`
}

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"`
	MppVersion int64  `protobuf:"varint,3,opt,name=mpp_version,json=mppVersion,proto3" json:"mpp_version,omitempty"`
}

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() int32

func (*Error) GetMppVersion 

func (m *Error) GetMppVersion() int64

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"`
}

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 IsAliveRequest 

type IsAliveRequest struct {
}

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"`
	MppVersion int64 `protobuf:"varint,2,opt,name=mpp_version,json=mppVersion,proto3" json:"mpp_version,omitempty"`
}

func (*IsAliveResponse) Descriptor 

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

func (*IsAliveResponse) GetAvailable 

func (m *IsAliveResponse) GetAvailable() bool

func (*IsAliveResponse) GetMppVersion 

func (m *IsAliveResponse) GetMppVersion() int64

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"`
	Version   int64    `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
}

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) GetVersion 

func (m *MPPDataPacket) GetVersion() int64

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 ReportTaskStatusRequest 

type ReportTaskStatusRequest struct {
	Meta  *TaskMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Data  []byte    `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Error *Error    `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

ReportTaskStatus reports the execution status of a task. when TiFlash reports status to TiDB, ReportTaskStatusRequest serialize tipb.TiFlashExecutionInfo into data;

func (*ReportTaskStatusRequest) Descriptor 

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

func (*ReportTaskStatusRequest) GetData 

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

func (*ReportTaskStatusRequest) GetError 

func (m *ReportTaskStatusRequest) GetError() *Error

func (*ReportTaskStatusRequest) GetMeta 

func (m *ReportTaskStatusRequest) GetMeta() *TaskMeta

func (*ReportTaskStatusRequest) Marshal 

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

func (*ReportTaskStatusRequest) MarshalTo 

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

func (*ReportTaskStatusRequest) MarshalToSizedBuffer 

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

func (*ReportTaskStatusRequest) ProtoMessage 

func (*ReportTaskStatusRequest) ProtoMessage()

func (*ReportTaskStatusRequest) Reset 

func (m *ReportTaskStatusRequest) Reset()

func (*ReportTaskStatusRequest) Size 

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

func (*ReportTaskStatusRequest) String 

func (m *ReportTaskStatusRequest) String() string

func (*ReportTaskStatusRequest) Unmarshal 

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

func (*ReportTaskStatusRequest) XXX_DiscardUnknown 

func (m *ReportTaskStatusRequest) XXX_DiscardUnknown()

func (*ReportTaskStatusRequest) XXX_Marshal 

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

func (*ReportTaskStatusRequest) XXX_Merge 

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

func (*ReportTaskStatusRequest) XXX_Size 

func (m *ReportTaskStatusRequest) XXX_Size() int

func (*ReportTaskStatusRequest) XXX_Unmarshal 

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

type ReportTaskStatusResponse 

type ReportTaskStatusResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

func (*ReportTaskStatusResponse) Descriptor 

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

func (*ReportTaskStatusResponse) GetError 

func (m *ReportTaskStatusResponse) GetError() *Error

func (*ReportTaskStatusResponse) Marshal 

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

func (*ReportTaskStatusResponse) MarshalTo 

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

func (*ReportTaskStatusResponse) MarshalToSizedBuffer 

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

func (*ReportTaskStatusResponse) ProtoMessage 

func (*ReportTaskStatusResponse) ProtoMessage()

func (*ReportTaskStatusResponse) Reset 

func (m *ReportTaskStatusResponse) Reset()

func (*ReportTaskStatusResponse) Size 

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

func (*ReportTaskStatusResponse) String 

func (m *ReportTaskStatusResponse) String() string

func (*ReportTaskStatusResponse) Unmarshal 

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

func (*ReportTaskStatusResponse) XXX_DiscardUnknown 

func (m *ReportTaskStatusResponse) XXX_DiscardUnknown()

func (*ReportTaskStatusResponse) XXX_Marshal 

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

func (*ReportTaskStatusResponse) XXX_Merge 

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

func (*ReportTaskStatusResponse) XXX_Size 

func (m *ReportTaskStatusResponse) XXX_Size() int

func (*ReportTaskStatusResponse) XXX_Unmarshal 

func (m *ReportTaskStatusResponse) 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"`
	GatherId               uint64             `protobuf:"varint,5,opt,name=gather_id,json=gatherId,proto3" json:"gather_id,omitempty"`
	QueryTs                uint64             `protobuf:"varint,6,opt,name=query_ts,json=queryTs,proto3" json:"query_ts,omitempty"`
	LocalQueryId           uint64             `protobuf:"varint,7,opt,name=local_query_id,json=localQueryId,proto3" json:"local_query_id,omitempty"`
	ServerId               uint64             `protobuf:"varint,8,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	MppVersion             int64              `protobuf:"varint,9,opt,name=mpp_version,json=mppVersion,proto3" json:"mpp_version,omitempty"`
	KeyspaceId             uint32             `protobuf:"varint,10,opt,name=keyspace_id,json=keyspaceId,proto3" json:"keyspace_id,omitempty"`
	CoordinatorAddress     string             `protobuf:"bytes,11,opt,name=coordinator_address,json=coordinatorAddress,proto3" json:"coordinator_address,omitempty"`
	ReportExecutionSummary bool               `` /* 131-byte string literal not displayed */
	ApiVersion             kvrpcpb.APIVersion `protobuf:"varint,16,opt,name=api_version,json=apiVersion,proto3,enum=kvrpcpb.APIVersion" json:"api_version,omitempty"`
	ResourceGroupName      string             `protobuf:"bytes,17,opt,name=resource_group_name,json=resourceGroupName,proto3" json:"resource_group_name,omitempty"`
	ConnectionId           uint64             `protobuf:"varint,18,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ConnectionAlias        string             `protobuf:"bytes,19,opt,name=connection_alias,json=connectionAlias,proto3" json:"connection_alias,omitempty"`
}

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) GetApiVersion 

func (m *TaskMeta) GetApiVersion() kvrpcpb.APIVersion

func (*TaskMeta) GetConnectionAlias 

func (m *TaskMeta) GetConnectionAlias() string

func (*TaskMeta) GetConnectionId 

func (m *TaskMeta) GetConnectionId() uint64

func (*TaskMeta) GetCoordinatorAddress 

func (m *TaskMeta) GetCoordinatorAddress() string

func (*TaskMeta) GetGatherId 

func (m *TaskMeta) GetGatherId() uint64

func (*TaskMeta) GetKeyspaceId 

func (m *TaskMeta) GetKeyspaceId() uint32

func (*TaskMeta) GetLocalQueryId 

func (m *TaskMeta) GetLocalQueryId() uint64

func (*TaskMeta) GetMppVersion 

func (m *TaskMeta) GetMppVersion() int64

func (*TaskMeta) GetPartitionId 

func (m *TaskMeta) GetPartitionId() int64

func (*TaskMeta) GetQueryTs 

func (m *TaskMeta) GetQueryTs() uint64

func (*TaskMeta) GetReportExecutionSummary 

func (m *TaskMeta) GetReportExecutionSummary() bool

func (*TaskMeta) GetResourceGroupName 

func (m *TaskMeta) GetResourceGroupName() string

func (*TaskMeta) GetServerId 

func (m *TaskMeta) GetServerId() uint64

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.