tipb

package
v1.1.0-alpha Latest Latest
Warning

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

 Go to latest Published: Oct 31, 2017 License: Apache-2.0, Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package tipb is a generated protocol buffer package.

It is generated from these files: 

analyze.proto
executor.proto
expression.proto
schema.proto
select.proto

It has these top-level messages: 

AnalyzeReq
AnalyzeIndexReq
AnalyzeColumnsReq
AnalyzeColumnsResp
AnalyzeIndexResp
Bucket
Histogram
FMSketch
SampleCollector
Executor
TableScan
IndexScan
Selection
Projection
Aggregation
TopN
Limit
FieldType
Expr
ByItem
TableInfo
ColumnInfo
IndexInfo
KeyRange
SelectRequest
Row
Error
SelectResponse
Chunk
RowMeta
DAGRequest

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAnalyze = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAnalyze   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthExecutor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExecutor   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthExpression = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExpression   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSchema = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSchema   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSelect = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSelect   = fmt.Errorf("proto: integer overflow")
)
View Source 
var AnalyzeType_name = map[int32]string{
	0: "TypeIndex",
	1: "TypeColumn",
}
View Source 
var AnalyzeType_value = map[string]int32{
	"TypeIndex":  0,
	"TypeColumn": 1,
}
View Source 
var ExecType_name = map[int32]string{
	0: "TypeTableScan",
	1: "TypeIndexScan",
	2: "TypeSelection",
	3: "TypeAggregation",
	4: "TypeTopN",
	5: "TypeLimit",
}
View Source 
var ExecType_value = map[string]int32{
	"TypeTableScan":   0,
	"TypeIndexScan":   1,
	"TypeSelection":   2,
	"TypeAggregation": 3,
	"TypeTopN":        4,
	"TypeLimit":       5,
}
View Source 
var ExprType_name = map[int32]string{}/* 112 elements not displayed */
View Source 
var ExprType_value = map[string]int32{}/* 112 elements not displayed */
View Source 
var ScalarFuncSig_name = map[int32]string{}/* 193 elements not displayed */
View Source 
var ScalarFuncSig_value = map[string]int32{}/* 193 elements not displayed */

Functions

This section is empty.

Types

type Aggregation 

type Aggregation struct {
	// Group by clause.
	GroupBy []*Expr `protobuf:"bytes,1,rep,name=group_by,json=groupBy" json:"group_by,omitempty"`
	// Aggregate functions.
	AggFunc []*Expr `protobuf:"bytes,2,rep,name=agg_func,json=aggFunc" json:"agg_func,omitempty"`
	// If it is a stream aggregation.
	Streamed         bool   `protobuf:"varint,3,opt,name=streamed" json:"streamed"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Aggregation) Descriptor 

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

func (*Aggregation) GetAggFunc 

func (m *Aggregation) GetAggFunc() []*Expr

func (*Aggregation) GetGroupBy 

func (m *Aggregation) GetGroupBy() []*Expr

func (*Aggregation) GetStreamed 

func (m *Aggregation) GetStreamed() bool

func (*Aggregation) Marshal 

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

func (*Aggregation) MarshalTo 

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

func (*Aggregation) ProtoMessage 

func (*Aggregation) ProtoMessage()

func (*Aggregation) Reset 

func (m *Aggregation) Reset()

func (*Aggregation) Size 

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

func (*Aggregation) String 

func (m *Aggregation) String() string

func (*Aggregation) Unmarshal 

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

type AnalyzeColumnsReq 

type AnalyzeColumnsReq struct {
	// bucket_size is the max histograms bucket size, we need this because when primary key is handle,
	// the histogram will be directly built.
	BucketSize int64 `protobuf:"varint,1,opt,name=bucket_size,json=bucketSize" json:"bucket_size"`
	// sample_size is the max number of samples that will be collected.
	SampleSize int64 `protobuf:"varint,2,opt,name=sample_size,json=sampleSize" json:"sample_size"`
	// sketch_size is the max sketch size.
	SketchSize int64 `protobuf:"varint,3,opt,name=sketch_size,json=sketchSize" json:"sketch_size"`
	// columns_info is the info of all the columns that needs to be analyzed.
	ColumnsInfo      []*ColumnInfo `protobuf:"bytes,4,rep,name=columns_info,json=columnsInfo" json:"columns_info,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*AnalyzeColumnsReq) Descriptor 

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

func (*AnalyzeColumnsReq) GetBucketSize 

func (m *AnalyzeColumnsReq) GetBucketSize() int64

func (*AnalyzeColumnsReq) GetColumnsInfo 

func (m *AnalyzeColumnsReq) GetColumnsInfo() []*ColumnInfo

func (*AnalyzeColumnsReq) GetSampleSize 

func (m *AnalyzeColumnsReq) GetSampleSize() int64

func (*AnalyzeColumnsReq) GetSketchSize 

func (m *AnalyzeColumnsReq) GetSketchSize() int64

func (*AnalyzeColumnsReq) Marshal 

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

func (*AnalyzeColumnsReq) MarshalTo 

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

func (*AnalyzeColumnsReq) ProtoMessage 

func (*AnalyzeColumnsReq) ProtoMessage()

func (*AnalyzeColumnsReq) Reset 

func (m *AnalyzeColumnsReq) Reset()

func (*AnalyzeColumnsReq) Size 

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

func (*AnalyzeColumnsReq) String 

func (m *AnalyzeColumnsReq) String() string

func (*AnalyzeColumnsReq) Unmarshal 

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

type AnalyzeColumnsResp 

type AnalyzeColumnsResp struct {
	// collectors is the sample collectors for columns.
	Collectors []*SampleCollector `protobuf:"bytes,1,rep,name=collectors" json:"collectors,omitempty"`
	// pk_hist is the histogram for primary key when it is the handle.
	PkHist           *Histogram `protobuf:"bytes,2,opt,name=pk_hist,json=pkHist" json:"pk_hist,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*AnalyzeColumnsResp) Descriptor 

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

func (*AnalyzeColumnsResp) GetCollectors 

func (m *AnalyzeColumnsResp) GetCollectors() []*SampleCollector

func (*AnalyzeColumnsResp) GetPkHist 

func (m *AnalyzeColumnsResp) GetPkHist() *Histogram

func (*AnalyzeColumnsResp) Marshal 

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

func (*AnalyzeColumnsResp) MarshalTo 

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

func (*AnalyzeColumnsResp) ProtoMessage 

func (*AnalyzeColumnsResp) ProtoMessage()

func (*AnalyzeColumnsResp) Reset 

func (m *AnalyzeColumnsResp) Reset()

func (*AnalyzeColumnsResp) Size 

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

func (*AnalyzeColumnsResp) String 

func (m *AnalyzeColumnsResp) String() string

func (*AnalyzeColumnsResp) Unmarshal 

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

type AnalyzeIndexReq 

type AnalyzeIndexReq struct {
	// bucket_size is the max histograms bucket size.
	BucketSize int64 `protobuf:"varint,1,opt,name=bucket_size,json=bucketSize" json:"bucket_size"`
	// num_columns is the number of columns in the index.
	NumColumns       int32  `protobuf:"varint,2,opt,name=num_columns,json=numColumns" json:"num_columns"`
	XXX_unrecognized []byte `json:"-"`
}

func (*AnalyzeIndexReq) Descriptor 

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

func (*AnalyzeIndexReq) GetBucketSize 

func (m *AnalyzeIndexReq) GetBucketSize() int64

func (*AnalyzeIndexReq) GetNumColumns 

func (m *AnalyzeIndexReq) GetNumColumns() int32

func (*AnalyzeIndexReq) Marshal 

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

func (*AnalyzeIndexReq) MarshalTo 

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

func (*AnalyzeIndexReq) ProtoMessage 

func (*AnalyzeIndexReq) ProtoMessage()

func (*AnalyzeIndexReq) Reset 

func (m *AnalyzeIndexReq) Reset()

func (*AnalyzeIndexReq) Size 

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

func (*AnalyzeIndexReq) String 

func (m *AnalyzeIndexReq) String() string

func (*AnalyzeIndexReq) Unmarshal 

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

type AnalyzeIndexResp 

type AnalyzeIndexResp struct {
	Hist             *Histogram `protobuf:"bytes,1,opt,name=hist" json:"hist,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*AnalyzeIndexResp) Descriptor 

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

func (*AnalyzeIndexResp) GetHist 

func (m *AnalyzeIndexResp) GetHist() *Histogram

func (*AnalyzeIndexResp) Marshal 

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

func (*AnalyzeIndexResp) MarshalTo 

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

func (*AnalyzeIndexResp) ProtoMessage 

func (*AnalyzeIndexResp) ProtoMessage()

func (*AnalyzeIndexResp) Reset 

func (m *AnalyzeIndexResp) Reset()

func (*AnalyzeIndexResp) Size 

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

func (*AnalyzeIndexResp) String 

func (m *AnalyzeIndexResp) String() string

func (*AnalyzeIndexResp) Unmarshal 

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

type AnalyzeReq 

type AnalyzeReq struct {
	Tp               AnalyzeType        `protobuf:"varint,1,opt,name=tp,enum=tipb.AnalyzeType" json:"tp"`
	StartTs          uint64             `protobuf:"varint,2,opt,name=start_ts,json=startTs" json:"start_ts"`
	Flags            uint64             `protobuf:"varint,3,opt,name=flags" json:"flags"`
	TimeZoneOffset   int64              `protobuf:"varint,4,opt,name=time_zone_offset,json=timeZoneOffset" json:"time_zone_offset"`
	IdxReq           *AnalyzeIndexReq   `protobuf:"bytes,5,opt,name=idx_req,json=idxReq" json:"idx_req,omitempty"`
	ColReq           *AnalyzeColumnsReq `protobuf:"bytes,6,opt,name=col_req,json=colReq" json:"col_req,omitempty"`
	XXX_unrecognized []byte             `json:"-"`
}

func (*AnalyzeReq) Descriptor 

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

func (*AnalyzeReq) GetColReq 

func (m *AnalyzeReq) GetColReq() *AnalyzeColumnsReq

func (*AnalyzeReq) GetFlags 

func (m *AnalyzeReq) GetFlags() uint64

func (*AnalyzeReq) GetIdxReq 

func (m *AnalyzeReq) GetIdxReq() *AnalyzeIndexReq

func (*AnalyzeReq) GetStartTs 

func (m *AnalyzeReq) GetStartTs() uint64

func (*AnalyzeReq) GetTimeZoneOffset 

func (m *AnalyzeReq) GetTimeZoneOffset() int64

func (*AnalyzeReq) GetTp 

func (m *AnalyzeReq) GetTp() AnalyzeType

func (*AnalyzeReq) Marshal 

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

func (*AnalyzeReq) MarshalTo 

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

func (*AnalyzeReq) ProtoMessage 

func (*AnalyzeReq) ProtoMessage()

func (*AnalyzeReq) Reset 

func (m *AnalyzeReq) Reset()

func (*AnalyzeReq) Size 

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

func (*AnalyzeReq) String 

func (m *AnalyzeReq) String() string

func (*AnalyzeReq) Unmarshal 

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

type AnalyzeType 

type AnalyzeType int32
const (
	AnalyzeType_TypeIndex  AnalyzeType = 0
	AnalyzeType_TypeColumn AnalyzeType = 1
)

func (AnalyzeType) Enum 

func (x AnalyzeType) Enum() *AnalyzeType

func (AnalyzeType) EnumDescriptor 

func (AnalyzeType) EnumDescriptor() ([]byte, []int)

func (AnalyzeType) String 

func (x AnalyzeType) String() string

func (*AnalyzeType) UnmarshalJSON 

func (x *AnalyzeType) UnmarshalJSON(data []byte) error

type Bucket 

type Bucket struct {
	Count            int64  `protobuf:"varint,1,opt,name=count" json:"count"`
	LowerBound       []byte `protobuf:"bytes,2,opt,name=lower_bound,json=lowerBound" json:"lower_bound,omitempty"`
	UpperBound       []byte `protobuf:"bytes,3,opt,name=upper_bound,json=upperBound" json:"upper_bound,omitempty"`
	Repeats          int64  `protobuf:"varint,4,opt,name=repeats" json:"repeats"`
	XXX_unrecognized []byte `json:"-"`
}

Bucket is an element of histogram.

func (*Bucket) Descriptor 

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

func (*Bucket) GetCount 

func (m *Bucket) GetCount() int64

func (*Bucket) GetLowerBound 

func (m *Bucket) GetLowerBound() []byte

func (*Bucket) GetRepeats 

func (m *Bucket) GetRepeats() int64

func (*Bucket) GetUpperBound 

func (m *Bucket) GetUpperBound() []byte

func (*Bucket) Marshal 

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

func (*Bucket) MarshalTo 

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

func (*Bucket) ProtoMessage 

func (*Bucket) ProtoMessage()

func (*Bucket) Reset 

func (m *Bucket) Reset()

func (*Bucket) Size 

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

func (*Bucket) String 

func (m *Bucket) String() string

func (*Bucket) Unmarshal 

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

type ByItem 

type ByItem struct {
	Expr             *Expr  `protobuf:"bytes,1,opt,name=expr" json:"expr,omitempty"`
	Desc             bool   `protobuf:"varint,2,opt,name=desc" json:"desc"`
	XXX_unrecognized []byte `json:"-"`
}

ByItem type for group by and order by.

func (*ByItem) Descriptor 

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

func (*ByItem) GetDesc 

func (m *ByItem) GetDesc() bool

func (*ByItem) GetExpr 

func (m *ByItem) GetExpr() *Expr

func (*ByItem) Marshal 

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

func (*ByItem) MarshalTo 

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

func (*ByItem) ProtoMessage 

func (*ByItem) ProtoMessage()

func (*ByItem) Reset 

func (m *ByItem) Reset()

func (*ByItem) Size 

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

func (*ByItem) String 

func (m *ByItem) String() string

func (*ByItem) Unmarshal 

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

type Chunk 

type Chunk struct {
	// Data for all rows in the chunk.
	RowsData github_com_pingcap_tipb_sharedbytes.SharedBytes `` /* 127-byte string literal not displayed */
	// Meta data for every row.
	RowsMeta         []RowMeta `protobuf:"bytes,4,rep,name=rows_meta,json=rowsMeta" json:"rows_meta"`
	XXX_unrecognized []byte    `json:"-"`
}

Chunk contains multiple rows data and rows meta.

func (*Chunk) Descriptor 

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

func (*Chunk) GetRowsMeta 

func (m *Chunk) GetRowsMeta() []RowMeta

func (*Chunk) Marshal 

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

func (*Chunk) MarshalTo 

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

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) Size 

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

func (*Chunk) String 

func (m *Chunk) String() string

func (*Chunk) Unmarshal 

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

type ColumnInfo 

type ColumnInfo struct {
	ColumnId         int64    `protobuf:"varint,1,opt,name=column_id,json=columnId" json:"column_id"`
	Tp               int32    `protobuf:"varint,2,opt,name=tp" json:"tp"`
	Collation        int32    `protobuf:"varint,3,opt,name=collation" json:"collation"`
	ColumnLen        int32    `protobuf:"varint,4,opt,name=columnLen" json:"columnLen"`
	Decimal          int32    `protobuf:"varint,5,opt,name=decimal" json:"decimal"`
	Flag             int32    `protobuf:"varint,6,opt,name=flag" json:"flag"`
	Elems            []string `protobuf:"bytes,7,rep,name=elems" json:"elems,omitempty"`
	DefaultVal       []byte   `protobuf:"bytes,8,opt,name=default_val,json=defaultVal" json:"default_val,omitempty"`
	PkHandle         bool     `protobuf:"varint,21,opt,name=pk_handle,json=pkHandle" json:"pk_handle"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*ColumnInfo) Descriptor 

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

func (*ColumnInfo) GetCollation 

func (m *ColumnInfo) GetCollation() int32

func (*ColumnInfo) GetColumnId 

func (m *ColumnInfo) GetColumnId() int64

func (*ColumnInfo) GetColumnLen 

func (m *ColumnInfo) GetColumnLen() int32

func (*ColumnInfo) GetDecimal 

func (m *ColumnInfo) GetDecimal() int32

func (*ColumnInfo) GetDefaultVal 

func (m *ColumnInfo) GetDefaultVal() []byte

func (*ColumnInfo) GetElems 

func (m *ColumnInfo) GetElems() []string

func (*ColumnInfo) GetFlag 

func (m *ColumnInfo) GetFlag() int32

func (*ColumnInfo) GetPkHandle 

func (m *ColumnInfo) GetPkHandle() bool

func (*ColumnInfo) GetTp 

func (m *ColumnInfo) GetTp() int32

func (*ColumnInfo) Marshal 

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

func (*ColumnInfo) MarshalTo 

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

func (*ColumnInfo) ProtoMessage 

func (*ColumnInfo) ProtoMessage()

func (*ColumnInfo) Reset 

func (m *ColumnInfo) Reset()

func (*ColumnInfo) Size 

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

func (*ColumnInfo) String 

func (m *ColumnInfo) String() string

func (*ColumnInfo) Unmarshal 

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

type DAGRequest 

type DAGRequest struct {
	// Transaction start timestamp.
	StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs" json:"start_ts"`
	// It represents push down Executors.
	Executors []*Executor `protobuf:"bytes,2,rep,name=executors" json:"executors,omitempty"`
	// time zone offset in seconds
	TimeZoneOffset int64 `protobuf:"varint,3,opt,name=time_zone_offset,json=timeZoneOffset" json:"time_zone_offset"`
	// flags are used to store flags that change the execution mode, it contains:
	// 	ignore_truncate = 1
	// 		truncate error should be ignore if set.
	// 	truncate_as_warning = 1 << 1
	// 		when ignored_truncate is not set, return warning instead of error if this flag is set.
	// 	...
	// 	add more when needed.
	Flags uint64 `protobuf:"varint,4,opt,name=flags" json:"flags"`
	// It represents which columns we should output.
	OutputOffsets    []uint32 `protobuf:"varint,5,rep,name=output_offsets,json=outputOffsets" json:"output_offsets,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

DAGRequest represents the request that will be handled with DAG mode.

func (*DAGRequest) Descriptor 

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

func (*DAGRequest) GetExecutors 

func (m *DAGRequest) GetExecutors() []*Executor

func (*DAGRequest) GetFlags 

func (m *DAGRequest) GetFlags() uint64

func (*DAGRequest) GetOutputOffsets 

func (m *DAGRequest) GetOutputOffsets() []uint32

func (*DAGRequest) GetStartTs 

func (m *DAGRequest) GetStartTs() uint64

func (*DAGRequest) GetTimeZoneOffset 

func (m *DAGRequest) GetTimeZoneOffset() int64

func (*DAGRequest) Marshal 

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

func (*DAGRequest) MarshalTo 

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

func (*DAGRequest) ProtoMessage 

func (*DAGRequest) ProtoMessage()

func (*DAGRequest) Reset 

func (m *DAGRequest) Reset()

func (*DAGRequest) Size 

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

func (*DAGRequest) String 

func (m *DAGRequest) String() string

func (*DAGRequest) Unmarshal 

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

type Error 

type Error struct {
	Code             int32  `protobuf:"varint,1,opt,name=code" json:"code"`
	Msg              string `protobuf:"bytes,2,opt,name=msg" json:"msg"`
	XXX_unrecognized []byte `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) 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

type ExecType 

type ExecType int32
const (
	ExecType_TypeTableScan   ExecType = 0
	ExecType_TypeIndexScan   ExecType = 1
	ExecType_TypeSelection   ExecType = 2
	ExecType_TypeAggregation ExecType = 3
	ExecType_TypeTopN        ExecType = 4
	ExecType_TypeLimit       ExecType = 5
)

func (ExecType) Enum 

func (x ExecType) Enum() *ExecType

func (ExecType) EnumDescriptor 

func (ExecType) EnumDescriptor() ([]byte, []int)

func (ExecType) String 

func (x ExecType) String() string

func (*ExecType) UnmarshalJSON 

func (x *ExecType) UnmarshalJSON(data []byte) error

type Executor 

type Executor struct {
	Tp               ExecType     `protobuf:"varint,1,opt,name=tp,enum=tipb.ExecType" json:"tp"`
	TblScan          *TableScan   `protobuf:"bytes,2,opt,name=tbl_scan,json=tblScan" json:"tbl_scan,omitempty"`
	IdxScan          *IndexScan   `protobuf:"bytes,3,opt,name=idx_scan,json=idxScan" json:"idx_scan,omitempty"`
	Selection        *Selection   `protobuf:"bytes,4,opt,name=selection" json:"selection,omitempty"`
	Aggregation      *Aggregation `protobuf:"bytes,5,opt,name=aggregation" json:"aggregation,omitempty"`
	TopN             *TopN        `protobuf:"bytes,6,opt,name=topN" json:"topN,omitempty"`
	Limit            *Limit       `protobuf:"bytes,7,opt,name=limit" json:"limit,omitempty"`
	XXX_unrecognized []byte       `json:"-"`
}

It represents a Executor.

func (*Executor) Descriptor 

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

func (*Executor) GetAggregation 

func (m *Executor) GetAggregation() *Aggregation

func (*Executor) GetIdxScan 

func (m *Executor) GetIdxScan() *IndexScan

func (*Executor) GetLimit 

func (m *Executor) GetLimit() *Limit

func (*Executor) GetSelection 

func (m *Executor) GetSelection() *Selection

func (*Executor) GetTblScan 

func (m *Executor) GetTblScan() *TableScan

func (*Executor) GetTopN 

func (m *Executor) GetTopN() *TopN

func (*Executor) GetTp 

func (m *Executor) GetTp() ExecType

func (*Executor) Marshal 

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

func (*Executor) MarshalTo 

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

func (*Executor) ProtoMessage 

func (*Executor) ProtoMessage()

func (*Executor) Reset 

func (m *Executor) Reset()

func (*Executor) Size 

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

func (*Executor) String 

func (m *Executor) String() string

func (*Executor) Unmarshal 

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

type Expr 

type Expr struct {
	Tp               ExprType      `protobuf:"varint,1,opt,name=tp,enum=tipb.ExprType" json:"tp"`
	Val              []byte        `protobuf:"bytes,2,opt,name=val" json:"val,omitempty"`
	Children         []*Expr       `protobuf:"bytes,3,rep,name=children" json:"children,omitempty"`
	Sig              ScalarFuncSig `protobuf:"varint,4,opt,name=sig,enum=tipb.ScalarFuncSig" json:"sig"`
	FieldType        *FieldType    `protobuf:"bytes,5,opt,name=field_type,json=fieldType" json:"field_type,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

Evaluators should implement evaluation functions for every expression type.

func (*Expr) Descriptor 

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

func (*Expr) GetChildren 

func (m *Expr) GetChildren() []*Expr

func (*Expr) GetFieldType 

func (m *Expr) GetFieldType() *FieldType

func (*Expr) GetSig 

func (m *Expr) GetSig() ScalarFuncSig

func (*Expr) GetTp 

func (m *Expr) GetTp() ExprType

func (*Expr) GetVal 

func (m *Expr) GetVal() []byte

func (*Expr) Marshal 

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

func (*Expr) MarshalTo 

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

func (*Expr) ProtoMessage 

func (*Expr) ProtoMessage()

func (*Expr) Reset 

func (m *Expr) Reset()

func (*Expr) Size 

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

func (*Expr) String 

func (m *Expr) String() string

func (*Expr) Unmarshal 

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

type ExprType 

type ExprType int32
const (
	// Values are encoded bytes.
	ExprType_Null    ExprType = 0
	ExprType_Int64   ExprType = 1
	ExprType_Uint64  ExprType = 2
	ExprType_Float32 ExprType = 3
	ExprType_Float64 ExprType = 4
	ExprType_String  ExprType = 5
	ExprType_Bytes   ExprType = 6
	// Mysql specific types.
	ExprType_MysqlBit      ExprType = 101
	ExprType_MysqlDecimal  ExprType = 102
	ExprType_MysqlDuration ExprType = 103
	ExprType_MysqlEnum     ExprType = 104
	ExprType_MysqlHex      ExprType = 105
	ExprType_MysqlSet      ExprType = 106
	ExprType_MysqlTime     ExprType = 107
	ExprType_MysqlJson     ExprType = 108
	// Encoded value list.
	ExprType_ValueList ExprType = 151
	// Column reference. value is int64 column ID.
	ExprType_ColumnRef ExprType = 201
	// Unary operations, children count 1.
	ExprType_Not    ExprType = 1001
	ExprType_Neg    ExprType = 1002
	ExprType_BitNeg ExprType = 1003
	// Comparison operations.
	ExprType_LT     ExprType = 2001
	ExprType_LE     ExprType = 2002
	ExprType_EQ     ExprType = 2003
	ExprType_NE     ExprType = 2004
	ExprType_GE     ExprType = 2005
	ExprType_GT     ExprType = 2006
	ExprType_NullEQ ExprType = 2007
	// Bit operations.
	ExprType_BitAnd    ExprType = 2101
	ExprType_BitOr     ExprType = 2102
	ExprType_BitXor    ExprType = 2103
	ExprType_LeftShift ExprType = 2104
	ExprType_RighShift ExprType = 2105
	// Arithmatic.
	ExprType_Plus   ExprType = 2201
	ExprType_Minus  ExprType = 2202
	ExprType_Mul    ExprType = 2203
	ExprType_Div    ExprType = 2204
	ExprType_IntDiv ExprType = 2205
	ExprType_Mod    ExprType = 2206
	// Logic operations.
	ExprType_And ExprType = 2301
	ExprType_Or  ExprType = 2302
	ExprType_Xor ExprType = 2303
	// Aggregate functions.
	ExprType_Count       ExprType = 3001
	ExprType_Sum         ExprType = 3002
	ExprType_Avg         ExprType = 3003
	ExprType_Min         ExprType = 3004
	ExprType_Max         ExprType = 3005
	ExprType_First       ExprType = 3006
	ExprType_GroupConcat ExprType = 3007
	// Math functions.
	ExprType_Abs   ExprType = 3101
	ExprType_Pow   ExprType = 3102
	ExprType_Round ExprType = 3103
	// String functions.
	ExprType_Concat         ExprType = 3201
	ExprType_ConcatWS       ExprType = 3202
	ExprType_Left           ExprType = 3203
	ExprType_Length         ExprType = 3204
	ExprType_Lower          ExprType = 3205
	ExprType_Repeat         ExprType = 3206
	ExprType_Replace        ExprType = 3207
	ExprType_Upper          ExprType = 3208
	ExprType_Strcmp         ExprType = 3209
	ExprType_Convert        ExprType = 3210
	ExprType_Cast           ExprType = 3211
	ExprType_Substring      ExprType = 3212
	ExprType_SubstringIndex ExprType = 3213
	ExprType_Locate         ExprType = 3214
	ExprType_Trim           ExprType = 3215
	// Control flow functions.
	ExprType_If     ExprType = 3301
	ExprType_NullIf ExprType = 3302
	ExprType_IfNull ExprType = 3303
	// Time functions.
	ExprType_Date        ExprType = 3401
	ExprType_DateAdd     ExprType = 3402
	ExprType_DateSub     ExprType = 3403
	ExprType_Year        ExprType = 3411
	ExprType_YearWeek    ExprType = 3412
	ExprType_Month       ExprType = 3421
	ExprType_Week        ExprType = 3431
	ExprType_Weekday     ExprType = 3432
	ExprType_WeekOfYear  ExprType = 3433
	ExprType_Day         ExprType = 3441
	ExprType_DayName     ExprType = 3442
	ExprType_DayOfYear   ExprType = 3443
	ExprType_DayOfMonth  ExprType = 3444
	ExprType_DayOfWeek   ExprType = 3445
	ExprType_Hour        ExprType = 3451
	ExprType_Minute      ExprType = 3452
	ExprType_Second      ExprType = 3453
	ExprType_Microsecond ExprType = 3454
	ExprType_Extract     ExprType = 3461
	// Other functions;
	ExprType_Coalesce ExprType = 3501
	ExprType_Greatest ExprType = 3502
	ExprType_Least    ExprType = 3503
	// Json functions;
	ExprType_JsonExtract      ExprType = 3601
	ExprType_JsonType         ExprType = 3602
	ExprType_JsonArray        ExprType = 3603
	ExprType_JsonObject       ExprType = 3604
	ExprType_JsonMerge        ExprType = 3605
	ExprType_JsonValid        ExprType = 3606
	ExprType_JsonSet          ExprType = 3607
	ExprType_JsonInsert       ExprType = 3608
	ExprType_JsonReplace      ExprType = 3609
	ExprType_JsonRemove       ExprType = 3610
	ExprType_JsonContains     ExprType = 3611
	ExprType_JsonUnquote      ExprType = 3612
	ExprType_JsonContainsPath ExprType = 3613
	// Other expressions.
	ExprType_In      ExprType = 4001
	ExprType_IsTruth ExprType = 4002
	ExprType_IsNull  ExprType = 4003
	ExprType_ExprRow ExprType = 4004
	ExprType_Like    ExprType = 4005
	ExprType_RLike   ExprType = 4006
	ExprType_Case    ExprType = 4007
	// Scalar Function
	ExprType_ScalarFunc ExprType = 10000
)

func (ExprType) Enum 

func (x ExprType) Enum() *ExprType

func (ExprType) EnumDescriptor 

func (ExprType) EnumDescriptor() ([]byte, []int)

func (ExprType) String 

func (x ExprType) String() string

func (*ExprType) UnmarshalJSON 

func (x *ExprType) UnmarshalJSON(data []byte) error

type FMSketch 

type FMSketch struct {
	Mask             uint64   `protobuf:"varint,1,opt,name=mask" json:"mask"`
	Hashset          []uint64 `protobuf:"varint,2,rep,name=hashset" json:"hashset,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

FMSketch is used to count distinct values for columns.

func (*FMSketch) Descriptor 

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

func (*FMSketch) GetHashset 

func (m *FMSketch) GetHashset() []uint64

func (*FMSketch) GetMask 

func (m *FMSketch) GetMask() uint64

func (*FMSketch) Marshal 

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

func (*FMSketch) MarshalTo 

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

func (*FMSketch) ProtoMessage 

func (*FMSketch) ProtoMessage()

func (*FMSketch) Reset 

func (m *FMSketch) Reset()

func (*FMSketch) Size 

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

func (*FMSketch) String 

func (m *FMSketch) String() string

func (*FMSketch) Unmarshal 

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

type FieldType 

type FieldType struct {
	Tp               int32  `protobuf:"varint,1,opt,name=tp" json:"tp"`
	Flag             uint32 `protobuf:"varint,2,opt,name=flag" json:"flag"`
	Flen             int32  `protobuf:"varint,3,opt,name=flen" json:"flen"`
	Decimal          int32  `protobuf:"varint,4,opt,name=decimal" json:"decimal"`
	Collate          int32  `protobuf:"varint,5,opt,name=collate" json:"collate"`
	Charset          string `protobuf:"bytes,6,opt,name=charset" json:"charset"`
	XXX_unrecognized []byte `json:"-"`
}

func (*FieldType) Descriptor 

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

func (*FieldType) GetCharset 

func (m *FieldType) GetCharset() string

func (*FieldType) GetCollate 

func (m *FieldType) GetCollate() int32

func (*FieldType) GetDecimal 

func (m *FieldType) GetDecimal() int32

func (*FieldType) GetFlag 

func (m *FieldType) GetFlag() uint32

func (*FieldType) GetFlen 

func (m *FieldType) GetFlen() int32

func (*FieldType) GetTp 

func (m *FieldType) GetTp() int32

func (*FieldType) Marshal 

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

func (*FieldType) MarshalTo 

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

func (*FieldType) ProtoMessage 

func (*FieldType) ProtoMessage()

func (*FieldType) Reset 

func (m *FieldType) Reset()

func (*FieldType) Size 

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

func (*FieldType) String 

func (m *FieldType) String() string

func (*FieldType) Unmarshal 

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

type Histogram 

type Histogram struct {
	// ndv is the number of distinct values.
	Ndv int64 `protobuf:"varint,1,opt,name=ndv" json:"ndv"`
	// buckets represents all the buckets.
	Buckets          []*Bucket `protobuf:"bytes,2,rep,name=buckets" json:"buckets,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*Histogram) Descriptor 

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

func (*Histogram) GetBuckets 

func (m *Histogram) GetBuckets() []*Bucket

func (*Histogram) GetNdv 

func (m *Histogram) GetNdv() int64

func (*Histogram) Marshal 

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

func (*Histogram) MarshalTo 

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

func (*Histogram) ProtoMessage 

func (*Histogram) ProtoMessage()

func (*Histogram) Reset 

func (m *Histogram) Reset()

func (*Histogram) Size 

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

func (*Histogram) String 

func (m *Histogram) String() string

func (*Histogram) Unmarshal 

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

type IndexInfo 

type IndexInfo struct {
	TableId          int64         `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"`
	IndexId          int64         `protobuf:"varint,2,opt,name=index_id,json=indexId" json:"index_id"`
	Columns          []*ColumnInfo `protobuf:"bytes,3,rep,name=columns" json:"columns,omitempty"`
	Unique           bool          `protobuf:"varint,4,opt,name=unique" json:"unique"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*IndexInfo) Descriptor 

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

func (*IndexInfo) GetColumns 

func (m *IndexInfo) GetColumns() []*ColumnInfo

func (*IndexInfo) GetIndexId 

func (m *IndexInfo) GetIndexId() int64

func (*IndexInfo) GetTableId 

func (m *IndexInfo) GetTableId() int64

func (*IndexInfo) GetUnique 

func (m *IndexInfo) GetUnique() bool

func (*IndexInfo) Marshal 

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

func (*IndexInfo) MarshalTo 

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

func (*IndexInfo) ProtoMessage 

func (*IndexInfo) ProtoMessage()

func (*IndexInfo) Reset 

func (m *IndexInfo) Reset()

func (*IndexInfo) Size 

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

func (*IndexInfo) String 

func (m *IndexInfo) String() string

func (*IndexInfo) Unmarshal 

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

type IndexScan 

type IndexScan struct {
	TableId          int64         `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"`
	IndexId          int64         `protobuf:"varint,2,opt,name=index_id,json=indexId" json:"index_id"`
	Columns          []*ColumnInfo `protobuf:"bytes,3,rep,name=columns" json:"columns,omitempty"`
	Desc             bool          `protobuf:"varint,4,opt,name=desc" json:"desc"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*IndexScan) Descriptor 

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

func (*IndexScan) GetColumns 

func (m *IndexScan) GetColumns() []*ColumnInfo

func (*IndexScan) GetDesc 

func (m *IndexScan) GetDesc() bool

func (*IndexScan) GetIndexId 

func (m *IndexScan) GetIndexId() int64

func (*IndexScan) GetTableId 

func (m *IndexScan) GetTableId() int64

func (*IndexScan) Marshal 

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

func (*IndexScan) MarshalTo 

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

func (*IndexScan) ProtoMessage 

func (*IndexScan) ProtoMessage()

func (*IndexScan) Reset 

func (m *IndexScan) Reset()

func (*IndexScan) Size 

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

func (*IndexScan) String 

func (m *IndexScan) String() string

func (*IndexScan) Unmarshal 

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

type KeyRange 

type KeyRange struct {
	Low              []byte `protobuf:"bytes,1,opt,name=low" json:"low,omitempty"`
	High             []byte `protobuf:"bytes,2,opt,name=high" json:"high,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

KeyRange is the encoded index key range, low is closed, high is open. (low <= x < high)

func (*KeyRange) Descriptor 

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

func (*KeyRange) GetHigh 

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

func (*KeyRange) GetLow 

func (m *KeyRange) GetLow() []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) 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

type Limit 

type Limit struct {
	// Limit the result to be returned.
	Limit            uint64 `protobuf:"varint,1,opt,name=limit" json:"limit"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Limit) Descriptor 

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

func (*Limit) GetLimit 

func (m *Limit) GetLimit() uint64

func (*Limit) Marshal 

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

func (*Limit) MarshalTo 

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

func (*Limit) ProtoMessage 

func (*Limit) ProtoMessage()

func (*Limit) Reset 

func (m *Limit) Reset()

func (*Limit) Size 

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

func (*Limit) String 

func (m *Limit) String() string

func (*Limit) Unmarshal 

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

type Projection 

type Projection struct {
	// Projection expressions.
	Exprs            []*Expr `protobuf:"bytes,1,rep,name=exprs" json:"exprs,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Projection) Descriptor 

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

func (*Projection) GetExprs 

func (m *Projection) GetExprs() []*Expr

func (*Projection) Marshal 

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

func (*Projection) MarshalTo 

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

func (*Projection) ProtoMessage 

func (*Projection) ProtoMessage()

func (*Projection) Reset 

func (m *Projection) Reset()

func (*Projection) Size 

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

func (*Projection) String 

func (m *Projection) String() string

func (*Projection) Unmarshal 

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

type Row 

type Row struct {
	Handle           []byte `protobuf:"bytes,1,opt,name=handle" json:"handle,omitempty"`
	Data             []byte `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

values are all in text format.

func (*Row) Descriptor 

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

func (*Row) GetData 

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

func (*Row) GetHandle 

func (m *Row) GetHandle() []byte

func (*Row) Marshal 

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

func (*Row) MarshalTo 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) Size 

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

func (*Row) String 

func (m *Row) String() string

func (*Row) Unmarshal 

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

type RowMeta 

type RowMeta struct {
	Handle           int64  `protobuf:"varint,1,opt,name=handle" json:"handle"`
	Length           int64  `protobuf:"varint,2,opt,name=length" json:"length"`
	XXX_unrecognized []byte `json:"-"`
}

RowMeta contains row handle and length of a row.

func (*RowMeta) Descriptor 

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

func (*RowMeta) GetHandle 

func (m *RowMeta) GetHandle() int64

func (*RowMeta) GetLength 

func (m *RowMeta) GetLength() int64

func (*RowMeta) Marshal 

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

func (*RowMeta) MarshalTo 

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

func (*RowMeta) ProtoMessage 

func (*RowMeta) ProtoMessage()

func (*RowMeta) Reset 

func (m *RowMeta) Reset()

func (*RowMeta) Size 

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

func (*RowMeta) String 

func (m *RowMeta) String() string

func (*RowMeta) Unmarshal 

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

type SampleCollector 

type SampleCollector struct {
	Samples          [][]byte  `protobuf:"bytes,1,rep,name=samples" json:"samples,omitempty"`
	NullCount        int64     `protobuf:"varint,2,opt,name=null_count,json=nullCount" json:"null_count"`
	Count            int64     `protobuf:"varint,3,opt,name=count" json:"count"`
	Sketch           *FMSketch `protobuf:"bytes,4,opt,name=sketch" json:"sketch,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

SampleCollector is used for collect samples and calculate the count and ndv of an column.

func (*SampleCollector) Descriptor 

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

func (*SampleCollector) GetCount 

func (m *SampleCollector) GetCount() int64

func (*SampleCollector) GetNullCount 

func (m *SampleCollector) GetNullCount() int64

func (*SampleCollector) GetSamples 

func (m *SampleCollector) GetSamples() [][]byte

func (*SampleCollector) GetSketch 

func (m *SampleCollector) GetSketch() *FMSketch

func (*SampleCollector) Marshal 

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

func (*SampleCollector) MarshalTo 

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

func (*SampleCollector) ProtoMessage 

func (*SampleCollector) ProtoMessage()

func (*SampleCollector) Reset 

func (m *SampleCollector) Reset()

func (*SampleCollector) Size 

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

func (*SampleCollector) String 

func (m *SampleCollector) String() string

func (*SampleCollector) Unmarshal 

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

type ScalarFuncSig 

type ScalarFuncSig int32
const (
	// Casting
	ScalarFuncSig_CastIntAsInt           ScalarFuncSig = 0
	ScalarFuncSig_CastIntAsReal          ScalarFuncSig = 1
	ScalarFuncSig_CastIntAsString        ScalarFuncSig = 2
	ScalarFuncSig_CastIntAsDecimal       ScalarFuncSig = 3
	ScalarFuncSig_CastIntAsTime          ScalarFuncSig = 4
	ScalarFuncSig_CastIntAsDuration      ScalarFuncSig = 5
	ScalarFuncSig_CastIntAsJson          ScalarFuncSig = 6
	ScalarFuncSig_CastRealAsInt          ScalarFuncSig = 10
	ScalarFuncSig_CastRealAsReal         ScalarFuncSig = 11
	ScalarFuncSig_CastRealAsString       ScalarFuncSig = 12
	ScalarFuncSig_CastRealAsDecimal      ScalarFuncSig = 13
	ScalarFuncSig_CastRealAsTime         ScalarFuncSig = 14
	ScalarFuncSig_CastRealAsDuration     ScalarFuncSig = 15
	ScalarFuncSig_CastRealAsJson         ScalarFuncSig = 16
	ScalarFuncSig_CastDecimalAsInt       ScalarFuncSig = 20
	ScalarFuncSig_CastDecimalAsReal      ScalarFuncSig = 21
	ScalarFuncSig_CastDecimalAsString    ScalarFuncSig = 22
	ScalarFuncSig_CastDecimalAsDecimal   ScalarFuncSig = 23
	ScalarFuncSig_CastDecimalAsTime      ScalarFuncSig = 24
	ScalarFuncSig_CastDecimalAsDuration  ScalarFuncSig = 25
	ScalarFuncSig_CastDecimalAsJson      ScalarFuncSig = 26
	ScalarFuncSig_CastStringAsInt        ScalarFuncSig = 30
	ScalarFuncSig_CastStringAsReal       ScalarFuncSig = 31
	ScalarFuncSig_CastStringAsString     ScalarFuncSig = 32
	ScalarFuncSig_CastStringAsDecimal    ScalarFuncSig = 33
	ScalarFuncSig_CastStringAsTime       ScalarFuncSig = 34
	ScalarFuncSig_CastStringAsDuration   ScalarFuncSig = 35
	ScalarFuncSig_CastStringAsJson       ScalarFuncSig = 36
	ScalarFuncSig_CastTimeAsInt          ScalarFuncSig = 40
	ScalarFuncSig_CastTimeAsReal         ScalarFuncSig = 41
	ScalarFuncSig_CastTimeAsString       ScalarFuncSig = 42
	ScalarFuncSig_CastTimeAsDecimal      ScalarFuncSig = 43
	ScalarFuncSig_CastTimeAsTime         ScalarFuncSig = 44
	ScalarFuncSig_CastTimeAsDuration     ScalarFuncSig = 45
	ScalarFuncSig_CastTimeAsJson         ScalarFuncSig = 46
	ScalarFuncSig_CastDurationAsInt      ScalarFuncSig = 50
	ScalarFuncSig_CastDurationAsReal     ScalarFuncSig = 51
	ScalarFuncSig_CastDurationAsString   ScalarFuncSig = 52
	ScalarFuncSig_CastDurationAsDecimal  ScalarFuncSig = 53
	ScalarFuncSig_CastDurationAsTime     ScalarFuncSig = 54
	ScalarFuncSig_CastDurationAsDuration ScalarFuncSig = 55
	ScalarFuncSig_CastDurationAsJson     ScalarFuncSig = 56
	ScalarFuncSig_CastJsonAsInt          ScalarFuncSig = 60
	ScalarFuncSig_CastJsonAsReal         ScalarFuncSig = 61
	ScalarFuncSig_CastJsonAsString       ScalarFuncSig = 62
	ScalarFuncSig_CastJsonAsDecimal      ScalarFuncSig = 63
	ScalarFuncSig_CastJsonAsTime         ScalarFuncSig = 64
	ScalarFuncSig_CastJsonAsDuration     ScalarFuncSig = 65
	ScalarFuncSig_CastJsonAsJson         ScalarFuncSig = 66
	ScalarFuncSig_LTInt                  ScalarFuncSig = 100
	ScalarFuncSig_LTReal                 ScalarFuncSig = 101
	ScalarFuncSig_LTDecimal              ScalarFuncSig = 102
	ScalarFuncSig_LTString               ScalarFuncSig = 103
	ScalarFuncSig_LTTime                 ScalarFuncSig = 104
	ScalarFuncSig_LTDuration             ScalarFuncSig = 105
	ScalarFuncSig_LTJson                 ScalarFuncSig = 106
	ScalarFuncSig_LEInt                  ScalarFuncSig = 110
	ScalarFuncSig_LEReal                 ScalarFuncSig = 111
	ScalarFuncSig_LEDecimal              ScalarFuncSig = 112
	ScalarFuncSig_LEString               ScalarFuncSig = 113
	ScalarFuncSig_LETime                 ScalarFuncSig = 114
	ScalarFuncSig_LEDuration             ScalarFuncSig = 115
	ScalarFuncSig_LEJson                 ScalarFuncSig = 116
	ScalarFuncSig_GTInt                  ScalarFuncSig = 120
	ScalarFuncSig_GTReal                 ScalarFuncSig = 121
	ScalarFuncSig_GTDecimal              ScalarFuncSig = 122
	ScalarFuncSig_GTString               ScalarFuncSig = 123
	ScalarFuncSig_GTTime                 ScalarFuncSig = 124
	ScalarFuncSig_GTDuration             ScalarFuncSig = 125
	ScalarFuncSig_GTJson                 ScalarFuncSig = 126
	ScalarFuncSig_GEInt                  ScalarFuncSig = 130
	ScalarFuncSig_GEReal                 ScalarFuncSig = 131
	ScalarFuncSig_GEDecimal              ScalarFuncSig = 132
	ScalarFuncSig_GEString               ScalarFuncSig = 133
	ScalarFuncSig_GETime                 ScalarFuncSig = 134
	ScalarFuncSig_GEDuration             ScalarFuncSig = 135
	ScalarFuncSig_GEJson                 ScalarFuncSig = 136
	ScalarFuncSig_EQInt                  ScalarFuncSig = 140
	ScalarFuncSig_EQReal                 ScalarFuncSig = 141
	ScalarFuncSig_EQDecimal              ScalarFuncSig = 142
	ScalarFuncSig_EQString               ScalarFuncSig = 143
	ScalarFuncSig_EQTime                 ScalarFuncSig = 144
	ScalarFuncSig_EQDuration             ScalarFuncSig = 145
	ScalarFuncSig_EQJson                 ScalarFuncSig = 146
	ScalarFuncSig_NEInt                  ScalarFuncSig = 150
	ScalarFuncSig_NEReal                 ScalarFuncSig = 151
	ScalarFuncSig_NEDecimal              ScalarFuncSig = 152
	ScalarFuncSig_NEString               ScalarFuncSig = 153
	ScalarFuncSig_NETime                 ScalarFuncSig = 154
	ScalarFuncSig_NEDuration             ScalarFuncSig = 155
	ScalarFuncSig_NEJson                 ScalarFuncSig = 156
	ScalarFuncSig_NullEQInt              ScalarFuncSig = 160
	ScalarFuncSig_NullEQReal             ScalarFuncSig = 161
	ScalarFuncSig_NullEQDecimal          ScalarFuncSig = 162
	ScalarFuncSig_NullEQString           ScalarFuncSig = 163
	ScalarFuncSig_NullEQTime             ScalarFuncSig = 164
	ScalarFuncSig_NullEQDuration         ScalarFuncSig = 165
	ScalarFuncSig_NullEQJson             ScalarFuncSig = 166
	ScalarFuncSig_PlusReal               ScalarFuncSig = 200
	ScalarFuncSig_PlusDecimal            ScalarFuncSig = 201
	ScalarFuncSig_PlusInt                ScalarFuncSig = 203
	ScalarFuncSig_MinusReal              ScalarFuncSig = 204
	ScalarFuncSig_MinusDecimal           ScalarFuncSig = 205
	ScalarFuncSig_MinusInt               ScalarFuncSig = 207
	ScalarFuncSig_MultiplyReal           ScalarFuncSig = 208
	ScalarFuncSig_MultiplyDecimal        ScalarFuncSig = 209
	ScalarFuncSig_MultiplyInt            ScalarFuncSig = 210
	ScalarFuncSig_DivideReal             ScalarFuncSig = 211
	ScalarFuncSig_DivideDecimal          ScalarFuncSig = 212
	ScalarFuncSig_AbsInt                 ScalarFuncSig = 2101
	ScalarFuncSig_AbsUInt                ScalarFuncSig = 2102
	ScalarFuncSig_AbsReal                ScalarFuncSig = 2103
	ScalarFuncSig_AbsDecimal             ScalarFuncSig = 2104
	ScalarFuncSig_CeilIntToDec           ScalarFuncSig = 2105
	ScalarFuncSig_CeilIntToInt           ScalarFuncSig = 2106
	ScalarFuncSig_CeilDecToInt           ScalarFuncSig = 2107
	ScalarFuncSig_CeilDecToDec           ScalarFuncSig = 2108
	ScalarFuncSig_CeilReal               ScalarFuncSig = 2109
	ScalarFuncSig_FloorIntToDec          ScalarFuncSig = 2110
	ScalarFuncSig_FloorIntToInt          ScalarFuncSig = 2111
	ScalarFuncSig_FloorDecToInt          ScalarFuncSig = 2112
	ScalarFuncSig_FloorDecToDec          ScalarFuncSig = 2113
	ScalarFuncSig_FloorReal              ScalarFuncSig = 2114
	ScalarFuncSig_LogicalAnd             ScalarFuncSig = 3101
	ScalarFuncSig_LogicalOr              ScalarFuncSig = 3102
	ScalarFuncSig_LogicalXor             ScalarFuncSig = 3103
	ScalarFuncSig_UnaryNot               ScalarFuncSig = 3104
	ScalarFuncSig_UnaryMinusInt          ScalarFuncSig = 3108
	ScalarFuncSig_UnaryMinusReal         ScalarFuncSig = 3109
	ScalarFuncSig_UnaryMinusDecimal      ScalarFuncSig = 3110
	ScalarFuncSig_DecimalIsNull          ScalarFuncSig = 3111
	ScalarFuncSig_DurationIsNull         ScalarFuncSig = 3112
	ScalarFuncSig_RealIsNull             ScalarFuncSig = 3113
	ScalarFuncSig_StringIsNull           ScalarFuncSig = 3114
	ScalarFuncSig_TimeIsNull             ScalarFuncSig = 3115
	ScalarFuncSig_IntIsNull              ScalarFuncSig = 3116
	ScalarFuncSig_JsonIsNull             ScalarFuncSig = 3117
	ScalarFuncSig_BitAndSig              ScalarFuncSig = 3118
	ScalarFuncSig_BitOrSig               ScalarFuncSig = 3119
	ScalarFuncSig_BitXorSig              ScalarFuncSig = 3120
	ScalarFuncSig_BitNegSig              ScalarFuncSig = 3121
	ScalarFuncSig_IntIsTrue              ScalarFuncSig = 3122
	ScalarFuncSig_RealIsTrue             ScalarFuncSig = 3123
	ScalarFuncSig_DecimalIsTrue          ScalarFuncSig = 3124
	ScalarFuncSig_IntIsFalse             ScalarFuncSig = 3125
	ScalarFuncSig_RealIsFalse            ScalarFuncSig = 3126
	ScalarFuncSig_DecimalIsFalse         ScalarFuncSig = 3127
	ScalarFuncSig_InInt                  ScalarFuncSig = 4001
	ScalarFuncSig_InReal                 ScalarFuncSig = 4002
	ScalarFuncSig_InDecimal              ScalarFuncSig = 4003
	ScalarFuncSig_InString               ScalarFuncSig = 4004
	ScalarFuncSig_InTime                 ScalarFuncSig = 4005
	ScalarFuncSig_InDuration             ScalarFuncSig = 4006
	ScalarFuncSig_InJson                 ScalarFuncSig = 4007
	ScalarFuncSig_IfNullInt              ScalarFuncSig = 4101
	ScalarFuncSig_IfNullReal             ScalarFuncSig = 4102
	ScalarFuncSig_IfNullDecimal          ScalarFuncSig = 4103
	ScalarFuncSig_IfNullString           ScalarFuncSig = 4104
	ScalarFuncSig_IfNullTime             ScalarFuncSig = 4105
	ScalarFuncSig_IfNullDuration         ScalarFuncSig = 4106
	ScalarFuncSig_IfInt                  ScalarFuncSig = 4107
	ScalarFuncSig_IfReal                 ScalarFuncSig = 4108
	ScalarFuncSig_IfDecimal              ScalarFuncSig = 4109
	ScalarFuncSig_IfString               ScalarFuncSig = 4110
	ScalarFuncSig_IfTime                 ScalarFuncSig = 4111
	ScalarFuncSig_IfDuration             ScalarFuncSig = 4112
	ScalarFuncSig_IfNullJson             ScalarFuncSig = 4113
	ScalarFuncSig_IfJson                 ScalarFuncSig = 4114
	ScalarFuncSig_CoalesceInt            ScalarFuncSig = 4201
	ScalarFuncSig_CoalesceReal           ScalarFuncSig = 4202
	ScalarFuncSig_CoalesceDecimal        ScalarFuncSig = 4203
	ScalarFuncSig_CoalesceString         ScalarFuncSig = 4204
	ScalarFuncSig_CoalesceTime           ScalarFuncSig = 4205
	ScalarFuncSig_CoalesceDuration       ScalarFuncSig = 4206
	ScalarFuncSig_CoalesceJson           ScalarFuncSig = 4207
	ScalarFuncSig_CaseWhenInt            ScalarFuncSig = 4208
	ScalarFuncSig_CaseWhenReal           ScalarFuncSig = 4209
	ScalarFuncSig_CaseWhenDecimal        ScalarFuncSig = 4210
	ScalarFuncSig_CaseWhenString         ScalarFuncSig = 4211
	ScalarFuncSig_CaseWhenTime           ScalarFuncSig = 4212
	ScalarFuncSig_CaseWhenDuration       ScalarFuncSig = 4213
	ScalarFuncSig_CaseWhenJson           ScalarFuncSig = 4214
	//
	// Here we use suffix *Sig* to avoid name conflict. After we removes
	// all same things in ExprType, we can rename them back.
	ScalarFuncSig_LikeSig        ScalarFuncSig = 4310
	ScalarFuncSig_JsonExtractSig ScalarFuncSig = 5001
	ScalarFuncSig_JsonUnquoteSig ScalarFuncSig = 5002
	ScalarFuncSig_JsonTypeSig    ScalarFuncSig = 5003
	ScalarFuncSig_JsonSetSig     ScalarFuncSig = 5004
	ScalarFuncSig_JsonInsertSig  ScalarFuncSig = 5005
	ScalarFuncSig_JsonReplaceSig ScalarFuncSig = 5006
	ScalarFuncSig_JsonRemoveSig  ScalarFuncSig = 5007
	ScalarFuncSig_JsonMergeSig   ScalarFuncSig = 5008
	ScalarFuncSig_JsonObjectSig  ScalarFuncSig = 5009
	ScalarFuncSig_JsonArraySig   ScalarFuncSig = 5010
)

func (ScalarFuncSig) Enum 

func (x ScalarFuncSig) Enum() *ScalarFuncSig

func (ScalarFuncSig) EnumDescriptor 

func (ScalarFuncSig) EnumDescriptor() ([]byte, []int)

func (ScalarFuncSig) String 

func (x ScalarFuncSig) String() string

func (*ScalarFuncSig) UnmarshalJSON 

func (x *ScalarFuncSig) UnmarshalJSON(data []byte) error

type SelectRequest 

type SelectRequest struct {
	// transaction start timestamp.
	StartTs uint64 `protobuf:"varint,1,opt,name=start_ts,json=startTs" json:"start_ts"`
	// If table_info is not null, it represents a table scan, index_info would be null.
	TableInfo *TableInfo `protobuf:"bytes,2,opt,name=table_info,json=tableInfo" json:"table_info,omitempty"`
	// If index_info is not null, it represents an index scan, table_info would be null.
	IndexInfo *IndexInfo `protobuf:"bytes,3,opt,name=index_info,json=indexInfo" json:"index_info,omitempty"`
	// fields to be selected, fields type can be column reference for simple scan.
	// or aggregation function. If no fields specified, only handle will be returned.
	Fields []*Expr `protobuf:"bytes,4,rep,name=fields" json:"fields,omitempty"`
	// disjoint handle ranges to be scanned.
	Ranges []*KeyRange `protobuf:"bytes,5,rep,name=ranges" json:"ranges,omitempty"`
	// distinct result.
	Distinct bool `protobuf:"varint,6,opt,name=distinct" json:"distinct"`
	// where condition.
	Where *Expr `protobuf:"bytes,7,opt,name=where" json:"where,omitempty"`
	// group by clause.
	GroupBy []*ByItem `protobuf:"bytes,8,rep,name=group_by,json=groupBy" json:"group_by,omitempty"`
	// having clause.
	Having *Expr `protobuf:"bytes,9,opt,name=having" json:"having,omitempty"`
	// order by clause.
	OrderBy []*ByItem `protobuf:"bytes,10,rep,name=order_by,json=orderBy" json:"order_by,omitempty"`
	// limit the result to be returned.
	Limit *int64 `protobuf:"varint,12,opt,name=limit" json:"limit,omitempty"`
	// aggregate functions
	Aggregates []*Expr `protobuf:"bytes,13,rep,name=aggregates" json:"aggregates,omitempty"`
	// time zone offset in seconds
	TimeZoneOffset int64 `protobuf:"varint,14,opt,name=time_zone_offset,json=timeZoneOffset" json:"time_zone_offset"`
	// flags is used to store flags that change the execution mode, it contains:
	// 	ignore_truncate = 1
	// 		truncate error should be ignore if set.
	// 	truncate_as_warning = 1 << 1
	// 		when ignored_truncate is not set, return warning instead of error if this flag is set.
	// 	...
	// 	add more when needed.
	Flags            uint64 `protobuf:"varint,15,opt,name=flags" json:"flags"`
	XXX_unrecognized []byte `json:"-"`
}

SelectRequest works like a simplified select statement.

func (*SelectRequest) Descriptor 

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

func (*SelectRequest) GetAggregates 

func (m *SelectRequest) GetAggregates() []*Expr

func (*SelectRequest) GetDistinct 

func (m *SelectRequest) GetDistinct() bool

func (*SelectRequest) GetFields 

func (m *SelectRequest) GetFields() []*Expr

func (*SelectRequest) GetFlags 

func (m *SelectRequest) GetFlags() uint64

func (*SelectRequest) GetGroupBy 

func (m *SelectRequest) GetGroupBy() []*ByItem

func (*SelectRequest) GetHaving 

func (m *SelectRequest) GetHaving() *Expr

func (*SelectRequest) GetIndexInfo 

func (m *SelectRequest) GetIndexInfo() *IndexInfo

func (*SelectRequest) GetLimit 

func (m *SelectRequest) GetLimit() int64

func (*SelectRequest) GetOrderBy 

func (m *SelectRequest) GetOrderBy() []*ByItem

func (*SelectRequest) GetRanges 

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

func (*SelectRequest) GetStartTs 

func (m *SelectRequest) GetStartTs() uint64

func (*SelectRequest) GetTableInfo 

func (m *SelectRequest) GetTableInfo() *TableInfo

func (*SelectRequest) GetTimeZoneOffset 

func (m *SelectRequest) GetTimeZoneOffset() int64

func (*SelectRequest) GetWhere 

func (m *SelectRequest) GetWhere() *Expr

func (*SelectRequest) Marshal 

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

func (*SelectRequest) MarshalTo 

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

func (*SelectRequest) ProtoMessage 

func (*SelectRequest) ProtoMessage()

func (*SelectRequest) Reset 

func (m *SelectRequest) Reset()

func (*SelectRequest) Size 

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

func (*SelectRequest) String 

func (m *SelectRequest) String() string

func (*SelectRequest) Unmarshal 

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

type SelectResponse 

type SelectResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// Result rows.
	Rows []*Row `protobuf:"bytes,2,rep,name=rows" json:"rows,omitempty"`
	// Use multiple chunks to reduce memory allocation and
	// avoid allocating large contiguous memory.
	Chunks           []Chunk  `protobuf:"bytes,3,rep,name=chunks" json:"chunks"`
	Warnings         []*Error `protobuf:"bytes,4,rep,name=warnings" json:"warnings,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

Response for SelectRequest.

func (*SelectResponse) Descriptor 

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

func (*SelectResponse) GetChunks 

func (m *SelectResponse) GetChunks() []Chunk

func (*SelectResponse) GetError 

func (m *SelectResponse) GetError() *Error

func (*SelectResponse) GetRows 

func (m *SelectResponse) GetRows() []*Row

func (*SelectResponse) GetWarnings 

func (m *SelectResponse) GetWarnings() []*Error

func (*SelectResponse) Marshal 

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

func (*SelectResponse) MarshalTo 

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

func (*SelectResponse) ProtoMessage 

func (*SelectResponse) ProtoMessage()

func (*SelectResponse) Reset 

func (m *SelectResponse) Reset()

func (*SelectResponse) Size 

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

func (*SelectResponse) String 

func (m *SelectResponse) String() string

func (*SelectResponse) Unmarshal 

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

type Selection 

type Selection struct {
	// Where conditions.
	Conditions       []*Expr `protobuf:"bytes,1,rep,name=conditions" json:"conditions,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Selection) Descriptor 

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

func (*Selection) GetConditions 

func (m *Selection) GetConditions() []*Expr

func (*Selection) Marshal 

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

func (*Selection) MarshalTo 

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

func (*Selection) ProtoMessage 

func (*Selection) ProtoMessage()

func (*Selection) Reset 

func (m *Selection) Reset()

func (*Selection) Size 

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

func (*Selection) String 

func (m *Selection) String() string

func (*Selection) Unmarshal 

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

type TableInfo 

type TableInfo struct {
	TableId          int64         `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"`
	Columns          []*ColumnInfo `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*TableInfo) Descriptor 

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

func (*TableInfo) GetColumns 

func (m *TableInfo) GetColumns() []*ColumnInfo

func (*TableInfo) GetTableId 

func (m *TableInfo) GetTableId() int64

func (*TableInfo) Marshal 

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

func (*TableInfo) MarshalTo 

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

func (*TableInfo) ProtoMessage 

func (*TableInfo) ProtoMessage()

func (*TableInfo) Reset 

func (m *TableInfo) Reset()

func (*TableInfo) Size 

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

func (*TableInfo) String 

func (m *TableInfo) String() string

func (*TableInfo) Unmarshal 

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

type TableScan 

type TableScan struct {
	TableId          int64         `protobuf:"varint,1,opt,name=table_id,json=tableId" json:"table_id"`
	Columns          []*ColumnInfo `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
	Desc             bool          `protobuf:"varint,3,opt,name=desc" json:"desc"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*TableScan) Descriptor 

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

func (*TableScan) GetColumns 

func (m *TableScan) GetColumns() []*ColumnInfo

func (*TableScan) GetDesc 

func (m *TableScan) GetDesc() bool

func (*TableScan) GetTableId 

func (m *TableScan) GetTableId() int64

func (*TableScan) Marshal 

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

func (*TableScan) MarshalTo 

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

func (*TableScan) ProtoMessage 

func (*TableScan) ProtoMessage()

func (*TableScan) Reset 

func (m *TableScan) Reset()

func (*TableScan) Size 

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

func (*TableScan) String 

func (m *TableScan) String() string

func (*TableScan) Unmarshal 

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

type TopN 

type TopN struct {
	// Order by clause.
	OrderBy          []*ByItem `protobuf:"bytes,1,rep,name=order_by,json=orderBy" json:"order_by,omitempty"`
	Limit            uint64    `protobuf:"varint,2,opt,name=limit" json:"limit"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TopN) Descriptor 

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

func (*TopN) GetLimit 

func (m *TopN) GetLimit() uint64

func (*TopN) GetOrderBy 

func (m *TopN) GetOrderBy() []*ByItem

func (*TopN) Marshal 

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

func (*TopN) MarshalTo 

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

func (*TopN) ProtoMessage 

func (*TopN) ProtoMessage()

func (*TopN) Reset 

func (m *TopN) Reset()

func (*TopN) Size 

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

func (*TopN) String 

func (m *TopN) String() string

func (*TopN) Unmarshal 

func (m *TopN) Unmarshal(dAtA []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.