tipb

package
v0.0.0-...-ea486a4 Latest Latest
Warning

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

Go to latest
Published: Mar 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:

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

It has these top-level messages:

Executor
TableScan
IndexScan
Selection
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{
	0:    "Null",
	1:    "Int64",
	2:    "Uint64",
	3:    "Float32",
	4:    "Float64",
	5:    "String",
	6:    "Bytes",
	101:  "MysqlBit",
	102:  "MysqlDecimal",
	103:  "MysqlDuration",
	104:  "MysqlEnum",
	105:  "MysqlHex",
	106:  "MysqlSet",
	107:  "MysqlTime",
	151:  "ValueList",
	201:  "ColumnRef",
	1001: "Not",
	1002: "Neg",
	1003: "BitNeg",
	2001: "LT",
	2002: "LE",
	2003: "EQ",
	2004: "NE",
	2005: "GE",
	2006: "GT",
	2007: "NullEQ",
	2101: "BitAnd",
	2102: "BitOr",
	2103: "BitXor",
	2104: "LeftShift",
	2105: "RighShift",
	2201: "Plus",
	2202: "Minus",
	2203: "Mul",
	2204: "Div",
	2205: "IntDiv",
	2206: "Mod",
	2301: "And",
	2302: "Or",
	2303: "Xor",
	3001: "Count",
	3002: "Sum",
	3003: "Avg",
	3004: "Min",
	3005: "Max",
	3006: "First",
	3007: "GroupConcat",
	3101: "Abs",
	3102: "Pow",
	3103: "Round",
	3201: "Concat",
	3202: "ConcatWS",
	3203: "Left",
	3204: "Length",
	3205: "Lower",
	3206: "Repeat",
	3207: "Replace",
	3208: "Upper",
	3209: "Strcmp",
	3210: "Convert",
	3211: "Cast",
	3212: "Substring",
	3213: "SubstringIndex",
	3214: "Locate",
	3215: "Trim",
	3301: "If",
	3302: "NullIf",
	3303: "IfNull",
	3401: "Date",
	3402: "DateAdd",
	3403: "DateSub",
	3411: "Year",
	3412: "YearWeek",
	3421: "Month",
	3431: "Week",
	3432: "Weekday",
	3433: "WeekOfYear",
	3441: "Day",
	3442: "DayName",
	3443: "DayOfYear",
	3444: "DayOfMonth",
	3445: "DayOfWeek",
	3451: "Hour",
	3452: "Minute",
	3453: "Second",
	3454: "Microsecond",
	3461: "Extract",
	3501: "Coalesce",
	3502: "Greatest",
	3503: "Least",
	4001: "In",
	4002: "IsTruth",
	4003: "IsNull",
	4004: "ExprRow",
	4005: "Like",
	4006: "RLike",
	4007: "Case",
}
View Source
var ExprType_value = map[string]int32{
	"Null":           0,
	"Int64":          1,
	"Uint64":         2,
	"Float32":        3,
	"Float64":        4,
	"String":         5,
	"Bytes":          6,
	"MysqlBit":       101,
	"MysqlDecimal":   102,
	"MysqlDuration":  103,
	"MysqlEnum":      104,
	"MysqlHex":       105,
	"MysqlSet":       106,
	"MysqlTime":      107,
	"ValueList":      151,
	"ColumnRef":      201,
	"Not":            1001,
	"Neg":            1002,
	"BitNeg":         1003,
	"LT":             2001,
	"LE":             2002,
	"EQ":             2003,
	"NE":             2004,
	"GE":             2005,
	"GT":             2006,
	"NullEQ":         2007,
	"BitAnd":         2101,
	"BitOr":          2102,
	"BitXor":         2103,
	"LeftShift":      2104,
	"RighShift":      2105,
	"Plus":           2201,
	"Minus":          2202,
	"Mul":            2203,
	"Div":            2204,
	"IntDiv":         2205,
	"Mod":            2206,
	"And":            2301,
	"Or":             2302,
	"Xor":            2303,
	"Count":          3001,
	"Sum":            3002,
	"Avg":            3003,
	"Min":            3004,
	"Max":            3005,
	"First":          3006,
	"GroupConcat":    3007,
	"Abs":            3101,
	"Pow":            3102,
	"Round":          3103,
	"Concat":         3201,
	"ConcatWS":       3202,
	"Left":           3203,
	"Length":         3204,
	"Lower":          3205,
	"Repeat":         3206,
	"Replace":        3207,
	"Upper":          3208,
	"Strcmp":         3209,
	"Convert":        3210,
	"Cast":           3211,
	"Substring":      3212,
	"SubstringIndex": 3213,
	"Locate":         3214,
	"Trim":           3215,
	"If":             3301,
	"NullIf":         3302,
	"IfNull":         3303,
	"Date":           3401,
	"DateAdd":        3402,
	"DateSub":        3403,
	"Year":           3411,
	"YearWeek":       3412,
	"Month":          3421,
	"Week":           3431,
	"Weekday":        3432,
	"WeekOfYear":     3433,
	"Day":            3441,
	"DayName":        3442,
	"DayOfYear":      3443,
	"DayOfMonth":     3444,
	"DayOfWeek":      3445,
	"Hour":           3451,
	"Minute":         3452,
	"Second":         3453,
	"Microsecond":    3454,
	"Extract":        3461,
	"Coalesce":       3501,
	"Greatest":       3502,
	"Least":          3503,
	"In":             4001,
	"IsTruth":        4002,
	"IsNull":         4003,
	"ExprRow":        4004,
	"Like":           4005,
	"RLike":          4006,
	"Case":           4007,
}

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"`
	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) 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 some 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"`
	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) 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
	// 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,omitempty"`
	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            *int64 `protobuf:"varint,1,opt,name=limit" json:"limit,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Limit) Descriptor

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

func (*Limit) GetLimit

func (m *Limit) GetLimit() int64

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 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,omitempty"`
	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            *int64    `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*TopN) Descriptor

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

func (*TopN) GetLimit

func (m *TopN) GetLimit() int64

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
y or Y : Canonical URL