tipb

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

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

Go to latest
Published: Jul 14, 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:

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

It has these top-level messages:

Executor
TableScan
IndexScan
Selection
Projection
Aggregation
TopN
Limit
Expr
ByItem
TableInfo
ColumnInfo
IndexInfo
KeyRange
SelectRequest
Row
Error
SelectResponse
Chunk
RowMeta
DAGRequest

Index

Constants

This section is empty.

Variables

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 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{}/* 110 elements not displayed */
View Source
var ExprType_value = map[string]int32{}/* 110 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 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"`
	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) 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
	// 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
)

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL