plan

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPlan        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPlan          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPlan = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CompressType_name = map[int32]string{
	0: "None",
	1: "Lz4",
}
View Source 
var CompressType_value = map[string]int32{
	"None": 0,
	"Lz4":  1,
}
View Source 
var DataControl_DclType_name = map[int32]string{
	0: "SET_VARIABLES",
	1: "GRANT",
	2: "REVOKE",
	3: "DENY",
	4: "PREPARE",
	5: "EXECUTE",
	6: "DEALLOCATE",
}
View Source 
var DataControl_DclType_value = map[string]int32{
	"SET_VARIABLES": 0,
	"GRANT":         1,
	"REVOKE":        2,
	"DENY":          3,
	"PREPARE":       4,
	"EXECUTE":       5,
	"DEALLOCATE":    6,
}
View Source 
var DataDefinition_DdlType_name = map[int32]string{
	0:  "CREATE_DATABASE",
	1:  "ALTER_DATABASE",
	2:  "DROP_DATABASE",
	3:  "CREATE_TABLE",
	4:  "ALTER_TABLE",
	5:  "DROP_TABLE",
	6:  "CREATE_INDEX",
	7:  "ALTER_INDEX",
	8:  "DROP_INDEX",
	9:  "TRUNCATE_TABLE",
	10: "CREATE_VIEW",
	11: "ALTER_VIEW",
	12: "DROP_VIEW",
	13: "SHOW_CREATEDATABASE",
	14: "SHOW_CREATETABLE",
	15: "SHOW_DATABASES",
	16: "SHOW_TABLES",
	17: "SHOW_COLUMNS",
	18: "SHOW_INDEX",
	19: "SHOW_VARIABLES",
	20: "SHOW_WARNINGS",
	21: "SHOW_ERRORS",
	22: "SHOW_STATUS",
	23: "SHOW_PROCESSLIST",
	24: "SHOW_TABLE_STATUS",
	25: "SHOW_TARGET",
	26: "SHOW_COLLATION",
}
View Source 
var DataDefinition_DdlType_value = map[string]int32{
	"CREATE_DATABASE":     0,
	"ALTER_DATABASE":      1,
	"DROP_DATABASE":       2,
	"CREATE_TABLE":        3,
	"ALTER_TABLE":         4,
	"DROP_TABLE":          5,
	"CREATE_INDEX":        6,
	"ALTER_INDEX":         7,
	"DROP_INDEX":          8,
	"TRUNCATE_TABLE":      9,
	"CREATE_VIEW":         10,
	"ALTER_VIEW":          11,
	"DROP_VIEW":           12,
	"SHOW_CREATEDATABASE": 13,
	"SHOW_CREATETABLE":    14,
	"SHOW_DATABASES":      15,
	"SHOW_TABLES":         16,
	"SHOW_COLUMNS":        17,
	"SHOW_INDEX":          18,
	"SHOW_VARIABLES":      19,
	"SHOW_WARNINGS":       20,
	"SHOW_ERRORS":         21,
	"SHOW_STATUS":         22,
	"SHOW_PROCESSLIST":    23,
	"SHOW_TABLE_STATUS":   24,
	"SHOW_TARGET":         25,
	"SHOW_COLLATION":      26,
}
View Source 
var ForeignKeyDef_RefAction_name = map[int32]string{
	0: "RESTRICT",
	1: "CASCADE",
	2: "SET_NULL",
	3: "SET_DEFAULT",
	4: "NO_ACTION",
}
View Source 
var ForeignKeyDef_RefAction_value = map[string]int32{
	"RESTRICT":    0,
	"CASCADE":     1,
	"SET_NULL":    2,
	"SET_DEFAULT": 3,
	"NO_ACTION":   4,
}
View Source 
var Function_FuncFlag_name = map[int32]string{
	0:   "NONE",
	1:   "INTERNAL",
	2:   "STABLE",
	4:   "VOLATILE",
	8:   "STRICT",
	16:  "PRODUCE_NULL",
	32:  "PRODUCE_NO_NULL",
	64:  "VARARG",
	128: "AGG",
	256: "WIN",
	512: "MONOTONIC",
}
View Source 
var Function_FuncFlag_value = map[string]int32{
	"NONE":            0,
	"INTERNAL":        1,
	"STABLE":          2,
	"VOLATILE":        4,
	"STRICT":          8,
	"PRODUCE_NULL":    16,
	"PRODUCE_NO_NULL": 32,
	"VARARG":          64,
	"AGG":             128,
	"WIN":             256,
	"MONOTONIC":       512,
}
View Source 
var Node_AggMode_name = map[int32]string{
	0: "FULL",
	1: "BOTTOM",
	2: "TOP",
}
View Source 
var Node_AggMode_value = map[string]int32{
	"FULL":   0,
	"BOTTOM": 1,
	"TOP":    2,
}
View Source 
var Node_JoinFlag_name = map[int32]string{
	0: "INNER",
	1: "LEFT",
	2: "RIGHT",
	3: "OUTER",
	4: "SEMI",
	5: "ANTI",
	6: "SINGLE",
	7: "MARK",
	8: "APPLY",
}
View Source 
var Node_JoinFlag_value = map[string]int32{
	"INNER":  0,
	"LEFT":   1,
	"RIGHT":  2,
	"OUTER":  3,
	"SEMI":   4,
	"ANTI":   5,
	"SINGLE": 6,
	"MARK":   7,
	"APPLY":  8,
}
View Source 
var Node_NodeType_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "VALUE_SCAN",
	2:  "TABLE_SCAN",
	3:  "FUNCTION_SCAN",
	4:  "EXTERNAL_SCAN",
	5:  "MATERIAL_SCAN",
	10: "PROJECT",
	11: "EXTERNAL_FUNCTION",
	20: "MATERIAL",
	21: "RECURSIVE_CTE",
	22: "SINK",
	23: "SINK_SCAN",
	30: "AGG",
	31: "DISTINCT",
	32: "FILTER",
	33: "JOIN",
	34: "SAMPLE",
	35: "SORT",
	36: "UNION",
	37: "UNION_ALL",
	38: "UNIQUE",
	39: "WINDOW",
	40: "BROADCAST",
	41: "SPLIT",
	42: "GATHER",
	50: "ASSERT",
	51: "INSERT",
	52: "UPDATE",
	53: "DELETE",
	54: "INTERSECT",
	55: "INTERSECT_ALL",
	56: "MINUS",
	57: "MINUS_ALL",
}
View Source 
var Node_NodeType_value = map[string]int32{
	"UNKNOWN":           0,
	"VALUE_SCAN":        1,
	"TABLE_SCAN":        2,
	"FUNCTION_SCAN":     3,
	"EXTERNAL_SCAN":     4,
	"MATERIAL_SCAN":     5,
	"PROJECT":           10,
	"EXTERNAL_FUNCTION": 11,
	"MATERIAL":          20,
	"RECURSIVE_CTE":     21,
	"SINK":              22,
	"SINK_SCAN":         23,
	"AGG":               30,
	"DISTINCT":          31,
	"FILTER":            32,
	"JOIN":              33,
	"SAMPLE":            34,
	"SORT":              35,
	"UNION":             36,
	"UNION_ALL":         37,
	"UNIQUE":            38,
	"WINDOW":            39,
	"BROADCAST":         40,
	"SPLIT":             41,
	"GATHER":            42,
	"ASSERT":            50,
	"INSERT":            51,
	"UPDATE":            52,
	"DELETE":            53,
	"INTERSECT":         54,
	"INTERSECT_ALL":     55,
	"MINUS":             56,
	"MINUS_ALL":         57,
}
View Source 
var OrderBySpec_OrderByFlag_name = map[int32]string{
	0:  "INTERNAL",
	1:  "ASC",
	2:  "DESC",
	4:  "NULLS_FIRST",
	8:  "NULLS_LAST",
	16: "UNIQUE",
}
View Source 
var OrderBySpec_OrderByFlag_value = map[string]int32{
	"INTERNAL":    0,
	"ASC":         1,
	"DESC":        2,
	"NULLS_FIRST": 4,
	"NULLS_LAST":  8,
	"UNIQUE":      16,
}
View Source 
var PartitionType_name = map[int32]string{
	0: "KEY",
	1: "LINEAR_KEY",
	2: "HASH",
	3: "LINEAR_HASH",
	4: "RANGE",
	5: "RANGE_COLUMNS",
	6: "LIST",
	7: "LIST_COLUMNS",
}
View Source 
var PartitionType_value = map[string]int32{
	"KEY":           0,
	"LINEAR_KEY":    1,
	"HASH":          2,
	"LINEAR_HASH":   3,
	"RANGE":         4,
	"RANGE_COLUMNS": 5,
	"LIST":          6,
	"LIST_COLUMNS":  7,
}
View Source 
var Query_StatementType_name = map[int32]string{
	0: "UNKNOWN",
	1: "SELECT",
	2: "INSERT",
	3: "DELETE",
	4: "UPDATE",
	5: "MERGE",
}
View Source 
var Query_StatementType_value = map[string]int32{
	"UNKNOWN": 0,
	"SELECT":  1,
	"INSERT":  2,
	"DELETE":  3,
	"UPDATE":  4,
	"MERGE":   5,
}
View Source 
var SubqueryRef_Type_name = map[int32]string{
	0: "SCALAR",
	1: "EXISTS",
	2: "NOT_EXISTS",
	3: "IN",
	4: "NOT_IN",
	5: "ANY",
	6: "ALL",
}
View Source 
var SubqueryRef_Type_value = map[string]int32{
	"SCALAR":     0,
	"EXISTS":     1,
	"NOT_EXISTS": 2,
	"IN":         3,
	"NOT_IN":     4,
	"ANY":        5,
	"ALL":        6,
}
View Source 
var TransationBegin_TransationMode_name = map[int32]string{
	0: "NONE",
	1: "READ_ONLY",
	2: "READ_WRITE",
}
View Source 
var TransationBegin_TransationMode_value = map[string]int32{
	"NONE":       0,
	"READ_ONLY":  1,
	"READ_WRITE": 2,
}
View Source 
var TransationCompletionType_name = map[int32]string{
	0: "CHAIN",
	1: "NO_CHAIN",
	2: "RELEASE",
}
View Source 
var TransationCompletionType_value = map[string]int32{
	"CHAIN":    0,
	"NO_CHAIN": 1,
	"RELEASE":  2,
}
View Source 
var TransationControl_TclType_name = map[int32]string{
	0: "BEGIN",
	1: "COMMIT",
	2: "ROLLBACK",
}
View Source 
var TransationControl_TclType_value = map[string]int32{
	"BEGIN":    0,
	"COMMIT":   1,
	"ROLLBACK": 2,
}

Functions

This section is empty.

Types

type AlterDatabase added in v0.5.0 

type AlterDatabase struct {
	IfExists             bool     `protobuf:"varint,1,opt,name=if_exists,json=ifExists,proto3" json:"if_exists,omitempty"`
	Database             string   `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AlterDatabase) Descriptor added in v0.5.0 

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

func (*AlterDatabase) GetDatabase added in v0.5.0 

func (m *AlterDatabase) GetDatabase() string

func (*AlterDatabase) GetIfExists added in v0.5.0 

func (m *AlterDatabase) GetIfExists() bool

func (*AlterDatabase) Marshal added in v0.5.0 

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

func (*AlterDatabase) MarshalTo added in v0.5.0 

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

func (*AlterDatabase) MarshalToSizedBuffer added in v0.5.0 

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

func (*AlterDatabase) ProtoMessage added in v0.5.0 

func (*AlterDatabase) ProtoMessage()

func (*AlterDatabase) ProtoSize added in v0.5.0 

func (m *AlterDatabase) ProtoSize() (n int)

func (*AlterDatabase) Reset added in v0.5.0 

func (m *AlterDatabase) Reset()

func (*AlterDatabase) String added in v0.5.0 

func (m *AlterDatabase) String() string

func (*AlterDatabase) Unmarshal added in v0.5.0 

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

func (*AlterDatabase) XXX_DiscardUnknown added in v0.5.0 

func (m *AlterDatabase) XXX_DiscardUnknown()

func (*AlterDatabase) XXX_Marshal added in v0.5.0 

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

func (*AlterDatabase) XXX_Merge added in v0.5.0 

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

func (*AlterDatabase) XXX_Size added in v0.5.0 

func (m *AlterDatabase) XXX_Size() int

func (*AlterDatabase) XXX_Unmarshal added in v0.5.0 

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

type AlterIndex added in v0.5.0 

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

func (*AlterIndex) Descriptor added in v0.5.0 

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

func (*AlterIndex) GetIndex added in v0.5.0 

func (m *AlterIndex) GetIndex() string

func (*AlterIndex) Marshal added in v0.5.0 

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

func (*AlterIndex) MarshalTo added in v0.5.0 

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

func (*AlterIndex) MarshalToSizedBuffer added in v0.5.0 

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

func (*AlterIndex) ProtoMessage added in v0.5.0 

func (*AlterIndex) ProtoMessage()

func (*AlterIndex) ProtoSize added in v0.5.0 

func (m *AlterIndex) ProtoSize() (n int)

func (*AlterIndex) Reset added in v0.5.0 

func (m *AlterIndex) Reset()

func (*AlterIndex) String added in v0.5.0 

func (m *AlterIndex) String() string

func (*AlterIndex) Unmarshal added in v0.5.0 

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

func (*AlterIndex) XXX_DiscardUnknown added in v0.5.0 

func (m *AlterIndex) XXX_DiscardUnknown()

func (*AlterIndex) XXX_Marshal added in v0.5.0 

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

func (*AlterIndex) XXX_Merge added in v0.5.0 

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

func (*AlterIndex) XXX_Size added in v0.5.0 

func (m *AlterIndex) XXX_Size() int

func (*AlterIndex) XXX_Unmarshal added in v0.5.0 

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

type AlterTable added in v0.5.0 

type AlterTable struct {
	Table                string    `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	TableDef             *TableDef `protobuf:"bytes,2,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*AlterTable) Descriptor added in v0.5.0 

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

func (*AlterTable) GetTable added in v0.5.0 

func (m *AlterTable) GetTable() string

func (*AlterTable) GetTableDef added in v0.5.0 

func (m *AlterTable) GetTableDef() *TableDef

func (*AlterTable) Marshal added in v0.5.0 

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

func (*AlterTable) MarshalTo added in v0.5.0 

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

func (*AlterTable) MarshalToSizedBuffer added in v0.5.0 

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

func (*AlterTable) ProtoMessage added in v0.5.0 

func (*AlterTable) ProtoMessage()

func (*AlterTable) ProtoSize added in v0.5.0 

func (m *AlterTable) ProtoSize() (n int)

func (*AlterTable) Reset added in v0.5.0 

func (m *AlterTable) Reset()

func (*AlterTable) String added in v0.5.0 

func (m *AlterTable) String() string

func (*AlterTable) Unmarshal added in v0.5.0 

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

func (*AlterTable) XXX_DiscardUnknown added in v0.5.0 

func (m *AlterTable) XXX_DiscardUnknown()

func (*AlterTable) XXX_Marshal added in v0.5.0 

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

func (*AlterTable) XXX_Merge added in v0.5.0 

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

func (*AlterTable) XXX_Size added in v0.5.0 

func (m *AlterTable) XXX_Size() int

func (*AlterTable) XXX_Unmarshal added in v0.5.0 

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

type AlterView added in v0.7.0 

type AlterView struct {
	IfExists             bool        `protobuf:"varint,1,opt,name=if_exists,json=ifExists,proto3" json:"if_exists,omitempty"`
	Database             string      `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	Temporary            bool        `protobuf:"varint,3,opt,name=temporary,proto3" json:"temporary,omitempty"`
	Table                string      `protobuf:"bytes,4,opt,name=table,proto3" json:"table,omitempty"`
	TableDef             *TableDef   `protobuf:"bytes,5,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
	IndexTables          []*TableDef `protobuf:"bytes,6,rep,name=index_tables,json=indexTables,proto3" json:"index_tables,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AlterView) Descriptor added in v0.7.0 

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

func (*AlterView) GetDatabase added in v0.7.0 

func (m *AlterView) GetDatabase() string

func (*AlterView) GetIfExists added in v0.7.0 

func (m *AlterView) GetIfExists() bool

func (*AlterView) GetIndexTables added in v0.7.0 

func (m *AlterView) GetIndexTables() []*TableDef

func (*AlterView) GetTable added in v0.7.0 

func (m *AlterView) GetTable() string

func (*AlterView) GetTableDef added in v0.7.0 

func (m *AlterView) GetTableDef() *TableDef

func (*AlterView) GetTemporary added in v0.7.0 

func (m *AlterView) GetTemporary() bool

func (*AlterView) Marshal added in v0.7.0 

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

func (*AlterView) MarshalTo added in v0.7.0 

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

func (*AlterView) MarshalToSizedBuffer added in v0.7.0 

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

func (*AlterView) ProtoMessage added in v0.7.0 

func (*AlterView) ProtoMessage()

func (*AlterView) ProtoSize added in v0.7.0 

func (m *AlterView) ProtoSize() (n int)

func (*AlterView) Reset added in v0.7.0 

func (m *AlterView) Reset()

func (*AlterView) String added in v0.7.0 

func (m *AlterView) String() string

func (*AlterView) Unmarshal added in v0.7.0 

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

func (*AlterView) XXX_DiscardUnknown added in v0.7.0 

func (m *AlterView) XXX_DiscardUnknown()

func (*AlterView) XXX_Marshal added in v0.7.0 

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

func (*AlterView) XXX_Merge added in v0.7.0 

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

func (*AlterView) XXX_Size added in v0.7.0 

func (m *AlterView) XXX_Size() int

func (*AlterView) XXX_Unmarshal added in v0.7.0 

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

type AnalyzeInfo added in v0.6.0 

type AnalyzeInfo struct {
	InputRows            int64    `protobuf:"varint,1,opt,name=input_rows,json=inputRows,proto3" json:"input_rows,omitempty"`
	OutputRows           int64    `protobuf:"varint,2,opt,name=output_rows,json=outputRows,proto3" json:"output_rows,omitempty"`
	InputSize            int64    `protobuf:"varint,3,opt,name=input_size,json=inputSize,proto3" json:"input_size,omitempty"`
	OutputSize           int64    `protobuf:"varint,4,opt,name=output_size,json=outputSize,proto3" json:"output_size,omitempty"`
	TimeConsumed         int64    `protobuf:"varint,5,opt,name=time_consumed,json=timeConsumed,proto3" json:"time_consumed,omitempty"`
	MemorySize           int64    `protobuf:"varint,6,opt,name=memory_size,json=memorySize,proto3" json:"memory_size,omitempty"`
	WaitTimeConsumed     int64    `protobuf:"varint,7,opt,name=wait_time_consumed,json=waitTimeConsumed,proto3" json:"wait_time_consumed,omitempty"`
	DiskIO               int64    `protobuf:"varint,8,opt,name=diskIO,proto3" json:"diskIO,omitempty"`
	S3IOByte             int64    `protobuf:"varint,9,opt,name=s3IO_byte,json=s3IOByte,proto3" json:"s3IO_byte,omitempty"`
	S3IOCount            int64    `protobuf:"varint,10,opt,name=s3IO_count,json=s3IOCount,proto3" json:"s3IO_count,omitempty"`
	NetworkIO            int64    `protobuf:"varint,11,opt,name=networkIO,proto3" json:"networkIO,omitempty"`
	ScanTime             int64    `protobuf:"varint,12,opt,name=scanTime,proto3" json:"scanTime,omitempty"`
	InsertTime           int64    `protobuf:"varint,13,opt,name=insertTime,proto3" json:"insertTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AnalyzeInfo) Descriptor added in v0.6.0 

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

func (*AnalyzeInfo) GetDiskIO added in v0.7.0 

func (m *AnalyzeInfo) GetDiskIO() int64

func (*AnalyzeInfo) GetInputRows added in v0.6.0 

func (m *AnalyzeInfo) GetInputRows() int64

func (*AnalyzeInfo) GetInputSize added in v0.6.0 

func (m *AnalyzeInfo) GetInputSize() int64

func (*AnalyzeInfo) GetInsertTime added in v0.7.0 

func (m *AnalyzeInfo) GetInsertTime() int64

func (*AnalyzeInfo) GetMemorySize added in v0.6.0 

func (m *AnalyzeInfo) GetMemorySize() int64

func (*AnalyzeInfo) GetNetworkIO added in v0.7.0 

func (m *AnalyzeInfo) GetNetworkIO() int64

func (*AnalyzeInfo) GetOutputRows added in v0.6.0 

func (m *AnalyzeInfo) GetOutputRows() int64

func (*AnalyzeInfo) GetOutputSize added in v0.6.0 

func (m *AnalyzeInfo) GetOutputSize() int64

func (*AnalyzeInfo) GetS3IOByte added in v0.7.0 

func (m *AnalyzeInfo) GetS3IOByte() int64

func (*AnalyzeInfo) GetS3IOCount added in v0.7.0 

func (m *AnalyzeInfo) GetS3IOCount() int64

func (*AnalyzeInfo) GetScanTime added in v0.7.0 

func (m *AnalyzeInfo) GetScanTime() int64

func (*AnalyzeInfo) GetTimeConsumed added in v0.6.0 

func (m *AnalyzeInfo) GetTimeConsumed() int64

func (*AnalyzeInfo) GetWaitTimeConsumed added in v0.7.0 

func (m *AnalyzeInfo) GetWaitTimeConsumed() int64

func (*AnalyzeInfo) Marshal added in v0.6.0 

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

func (*AnalyzeInfo) MarshalTo added in v0.6.0 

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

func (*AnalyzeInfo) MarshalToSizedBuffer added in v0.6.0 

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

func (*AnalyzeInfo) ProtoMessage added in v0.6.0 

func (*AnalyzeInfo) ProtoMessage()

func (*AnalyzeInfo) ProtoSize added in v0.6.0 

func (m *AnalyzeInfo) ProtoSize() (n int)

func (*AnalyzeInfo) Reset added in v0.6.0 

func (m *AnalyzeInfo) Reset()

func (*AnalyzeInfo) String added in v0.6.0 

func (m *AnalyzeInfo) String() string

func (*AnalyzeInfo) Unmarshal added in v0.6.0 

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

func (*AnalyzeInfo) XXX_DiscardUnknown added in v0.6.0 

func (m *AnalyzeInfo) XXX_DiscardUnknown()

func (*AnalyzeInfo) XXX_Marshal added in v0.6.0 

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

func (*AnalyzeInfo) XXX_Merge added in v0.6.0 

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

func (*AnalyzeInfo) XXX_Size added in v0.6.0 

func (m *AnalyzeInfo) XXX_Size() int

func (*AnalyzeInfo) XXX_Unmarshal added in v0.6.0 

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

type CheckDef added in v0.7.0 

type CheckDef struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name for anonymous constraints, __mo_chk_[INDEX_ID]
	Check                *Expr    `protobuf:"bytes,2,opt,name=check,proto3" json:"check,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckDef) Descriptor added in v0.7.0 

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

func (*CheckDef) GetCheck added in v0.7.0 

func (m *CheckDef) GetCheck() *Expr

func (*CheckDef) GetName added in v0.7.0 

func (m *CheckDef) GetName() string

func (*CheckDef) Marshal added in v0.7.0 

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

func (*CheckDef) MarshalTo added in v0.7.0 

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

func (*CheckDef) MarshalToSizedBuffer added in v0.7.0 

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

func (*CheckDef) ProtoMessage added in v0.7.0 

func (*CheckDef) ProtoMessage()

func (*CheckDef) ProtoSize added in v0.7.0 

func (m *CheckDef) ProtoSize() (n int)

func (*CheckDef) Reset added in v0.7.0 

func (m *CheckDef) Reset()

func (*CheckDef) String added in v0.7.0 

func (m *CheckDef) String() string

func (*CheckDef) Unmarshal added in v0.7.0 

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

func (*CheckDef) XXX_DiscardUnknown added in v0.7.0 

func (m *CheckDef) XXX_DiscardUnknown()

func (*CheckDef) XXX_Marshal added in v0.7.0 

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

func (*CheckDef) XXX_Merge added in v0.7.0 

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

func (*CheckDef) XXX_Size added in v0.7.0 

func (m *CheckDef) XXX_Size() int

func (*CheckDef) XXX_Unmarshal added in v0.7.0 

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

type ClusterByDef added in v0.7.0 

type ClusterByDef struct {
	Parts []*Expr `protobuf:"bytes,1,rep,name=parts,proto3" json:"parts,omitempty"`
	// XXX: Deprecated and to be removed soon.
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterByDef) Descriptor added in v0.7.0 

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

func (*ClusterByDef) GetName added in v0.7.0 

func (m *ClusterByDef) GetName() string

func (*ClusterByDef) GetParts added in v0.7.0 

func (m *ClusterByDef) GetParts() []*Expr

func (*ClusterByDef) Marshal added in v0.7.0 

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

func (*ClusterByDef) MarshalTo added in v0.7.0 

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

func (*ClusterByDef) MarshalToSizedBuffer added in v0.7.0 

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

func (*ClusterByDef) ProtoMessage added in v0.7.0 

func (*ClusterByDef) ProtoMessage()

func (*ClusterByDef) ProtoSize added in v0.7.0 

func (m *ClusterByDef) ProtoSize() (n int)

func (*ClusterByDef) Reset added in v0.7.0 

func (m *ClusterByDef) Reset()

func (*ClusterByDef) String added in v0.7.0 

func (m *ClusterByDef) String() string

func (*ClusterByDef) Unmarshal added in v0.7.0 

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

func (*ClusterByDef) XXX_DiscardUnknown added in v0.7.0 

func (m *ClusterByDef) XXX_DiscardUnknown()

func (*ClusterByDef) XXX_Marshal added in v0.7.0 

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

func (*ClusterByDef) XXX_Merge added in v0.7.0 

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

func (*ClusterByDef) XXX_Size added in v0.7.0 

func (m *ClusterByDef) XXX_Size() int

func (*ClusterByDef) XXX_Unmarshal added in v0.7.0 

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

type ClusterTable added in v0.7.0 

type ClusterTable struct {
	IsClusterTable         bool     `protobuf:"varint,1,opt,name=is_cluster_table,json=isClusterTable,proto3" json:"is_cluster_table,omitempty"`
	AccountIDs             []uint32 `protobuf:"varint,2,rep,packed,name=accountIDs,proto3" json:"accountIDs,omitempty"`
	ColumnIndexOfAccountId int32    `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*ClusterTable) Descriptor added in v0.7.0 

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

func (*ClusterTable) GetAccountIDs added in v0.7.0 

func (m *ClusterTable) GetAccountIDs() []uint32

func (*ClusterTable) GetColumnIndexOfAccountId added in v0.7.0 

func (m *ClusterTable) GetColumnIndexOfAccountId() int32

func (*ClusterTable) GetIsClusterTable added in v0.7.0 

func (m *ClusterTable) GetIsClusterTable() bool

func (*ClusterTable) Marshal added in v0.7.0 

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

func (*ClusterTable) MarshalTo added in v0.7.0 

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

func (*ClusterTable) MarshalToSizedBuffer added in v0.7.0 

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

func (*ClusterTable) ProtoMessage added in v0.7.0 

func (*ClusterTable) ProtoMessage()

func (*ClusterTable) ProtoSize added in v0.7.0 

func (m *ClusterTable) ProtoSize() (n int)

func (*ClusterTable) Reset added in v0.7.0 

func (m *ClusterTable) Reset()

func (*ClusterTable) String added in v0.7.0 

func (m *ClusterTable) String() string

func (*ClusterTable) Unmarshal added in v0.7.0 

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

func (*ClusterTable) XXX_DiscardUnknown added in v0.7.0 

func (m *ClusterTable) XXX_DiscardUnknown()

func (*ClusterTable) XXX_Marshal added in v0.7.0 

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

func (*ClusterTable) XXX_Merge added in v0.7.0 

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

func (*ClusterTable) XXX_Size added in v0.7.0 

func (m *ClusterTable) XXX_Size() int

func (*ClusterTable) XXX_Unmarshal added in v0.7.0 

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

type ColData 

type ColData struct {
	Data                 []*Expr  `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ColData) Descriptor 

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

func (*ColData) GetData added in v0.7.0 

func (m *ColData) GetData() []*Expr

func (*ColData) Marshal added in v0.5.0 

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

func (*ColData) MarshalTo added in v0.5.0 

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

func (*ColData) MarshalToSizedBuffer added in v0.5.0 

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

func (*ColData) ProtoMessage 

func (*ColData) ProtoMessage()

func (*ColData) ProtoSize added in v0.5.0 

func (m *ColData) ProtoSize() (n int)

func (*ColData) Reset 

func (m *ColData) Reset()

func (*ColData) String 

func (m *ColData) String() string

func (*ColData) Unmarshal added in v0.5.0 

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

func (*ColData) XXX_DiscardUnknown added in v0.5.0 

func (m *ColData) XXX_DiscardUnknown()

func (*ColData) XXX_Marshal added in v0.5.0 

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

func (*ColData) XXX_Merge added in v0.5.0 

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

func (*ColData) XXX_Size added in v0.5.0 

func (m *ColData) XXX_Size() int

func (*ColData) XXX_Unmarshal added in v0.5.0 

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

type ColDef 

type ColDef struct {
	ColId    uint64       `protobuf:"varint,1,opt,name=col_id,json=colId,proto3" json:"col_id,omitempty"`
	Name     string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Hidden   bool         `protobuf:"varint,3,opt,name=hidden,proto3" json:"hidden,omitempty"`
	Alg      CompressType `protobuf:"varint,4,opt,name=alg,proto3,enum=plan.CompressType" json:"alg,omitempty"`
	Typ      *Type        `protobuf:"bytes,5,opt,name=typ,proto3" json:"typ,omitempty"`
	NotNull  bool         `protobuf:"varint,6,opt,name=not_null,json=notNull,proto3" json:"not_null,omitempty"`
	Default  *Default     `protobuf:"bytes,7,opt,name=default,proto3" json:"default,omitempty"`
	Comment  string       `protobuf:"bytes,8,opt,name=comment,proto3" json:"comment,omitempty"`
	OnUpdate *OnUpdate    `protobuf:"bytes,9,opt,name=on_update,json=onUpdate,proto3" json:"on_update,omitempty"`
	LowCard  bool         `protobuf:"varint,10,opt,name=low_card,json=lowCard,proto3" json:"low_card,omitempty"`
	// XXX: Deprecated and to be removed soon.
	ClusterBy            bool     `protobuf:"varint,11,opt,name=clusterBy,proto3" json:"clusterBy,omitempty"`
	Primary              bool     `protobuf:"varint,12,opt,name=primary,proto3" json:"primary,omitempty"`
	Pkidx                int32    `protobuf:"varint,13,opt,name=pkidx,proto3" json:"pkidx,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ColDef) Descriptor 

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

func (*ColDef) GetAlg added in v0.5.0 

func (m *ColDef) GetAlg() CompressType

func (*ColDef) GetClusterBy added in v0.7.0 

func (m *ColDef) GetClusterBy() bool

func (*ColDef) GetColId added in v0.7.0 

func (m *ColDef) GetColId() uint64

func (*ColDef) GetComment added in v0.6.0 

func (m *ColDef) GetComment() string

func (*ColDef) GetDefault added in v0.5.0 

func (m *ColDef) GetDefault() *Default

func (*ColDef) GetHidden added in v0.7.0 

func (m *ColDef) GetHidden() bool

func (*ColDef) GetLowCard added in v0.7.0 

func (m *ColDef) GetLowCard() bool

func (*ColDef) GetName 

func (m *ColDef) GetName() string

func (*ColDef) GetNotNull added in v0.7.0 

func (m *ColDef) GetNotNull() bool

func (*ColDef) GetOnUpdate added in v0.6.0 

func (m *ColDef) GetOnUpdate() *OnUpdate

func (*ColDef) GetPkidx 

func (m *ColDef) GetPkidx() int32

func (*ColDef) GetPrimary added in v0.5.0 

func (m *ColDef) GetPrimary() bool

func (*ColDef) GetTyp 

func (m *ColDef) GetTyp() *Type

func (*ColDef) Marshal added in v0.5.0 

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

func (*ColDef) MarshalTo added in v0.5.0 

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

func (*ColDef) MarshalToSizedBuffer added in v0.5.0 

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

func (*ColDef) ProtoMessage 

func (*ColDef) ProtoMessage()

func (*ColDef) ProtoSize added in v0.5.0 

func (m *ColDef) ProtoSize() (n int)

func (*ColDef) Reset 

func (m *ColDef) Reset()

func (*ColDef) String 

func (m *ColDef) String() string

func (*ColDef) Unmarshal added in v0.5.0 

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

func (*ColDef) XXX_DiscardUnknown added in v0.5.0 

func (m *ColDef) XXX_DiscardUnknown()

func (*ColDef) XXX_Marshal added in v0.5.0 

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

func (*ColDef) XXX_Merge added in v0.5.0 

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

func (*ColDef) XXX_Size added in v0.5.0 

func (m *ColDef) XXX_Size() int

func (*ColDef) XXX_Unmarshal added in v0.5.0 

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

type ColPosMap added in v0.7.0 

type ColPosMap struct {
	Map                  map[string]int32 `` /* 148-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ColPosMap) Descriptor added in v0.7.0 

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

func (*ColPosMap) GetMap added in v0.7.0 

func (m *ColPosMap) GetMap() map[string]int32

func (*ColPosMap) Marshal added in v0.7.0 

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

func (*ColPosMap) MarshalTo added in v0.7.0 

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

func (*ColPosMap) MarshalToSizedBuffer added in v0.7.0 

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

func (*ColPosMap) ProtoMessage added in v0.7.0 

func (*ColPosMap) ProtoMessage()

func (*ColPosMap) ProtoSize added in v0.7.0 

func (m *ColPosMap) ProtoSize() (n int)

func (*ColPosMap) Reset added in v0.7.0 

func (m *ColPosMap) Reset()

func (*ColPosMap) String added in v0.7.0 

func (m *ColPosMap) String() string

func (*ColPosMap) Unmarshal added in v0.7.0 

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

func (*ColPosMap) XXX_DiscardUnknown added in v0.7.0 

func (m *ColPosMap) XXX_DiscardUnknown()

func (*ColPosMap) XXX_Marshal added in v0.7.0 

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

func (*ColPosMap) XXX_Merge added in v0.7.0 

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

func (*ColPosMap) XXX_Size added in v0.7.0 

func (m *ColPosMap) XXX_Size() int

func (*ColPosMap) XXX_Unmarshal added in v0.7.0 

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

type ColRef 

type ColRef struct {
	RelPos               int32    `protobuf:"varint,1,opt,name=rel_pos,json=relPos,proto3" json:"rel_pos,omitempty"`
	ColPos               int32    `protobuf:"varint,2,opt,name=col_pos,json=colPos,proto3" json:"col_pos,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Reference a column in the proj list of a node.

func (*ColRef) Descriptor 

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

func (*ColRef) GetColPos 

func (m *ColRef) GetColPos() int32

func (*ColRef) GetName 

func (m *ColRef) GetName() string

func (*ColRef) GetRelPos 

func (m *ColRef) GetRelPos() int32

func (*ColRef) Marshal added in v0.5.0 

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

func (*ColRef) MarshalTo added in v0.5.0 

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

func (*ColRef) MarshalToSizedBuffer added in v0.5.0 

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

func (*ColRef) ProtoMessage 

func (*ColRef) ProtoMessage()

func (*ColRef) ProtoSize added in v0.5.0 

func (m *ColRef) ProtoSize() (n int)

func (*ColRef) Reset 

func (m *ColRef) Reset()

func (*ColRef) String 

func (m *ColRef) String() string

func (*ColRef) Unmarshal added in v0.5.0 

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

func (*ColRef) XXX_DiscardUnknown added in v0.5.0 

func (m *ColRef) XXX_DiscardUnknown()

func (*ColRef) XXX_Marshal added in v0.5.0 

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

func (*ColRef) XXX_Merge added in v0.5.0 

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

func (*ColRef) XXX_Size added in v0.5.0 

func (m *ColRef) XXX_Size() int

func (*ColRef) XXX_Unmarshal added in v0.5.0 

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

type Column added in v0.6.0 

type Column struct {
	Column               []*Expr  `protobuf:"bytes,1,rep,name=column,proto3" json:"column,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Column) Descriptor added in v0.6.0 

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

func (*Column) GetColumn added in v0.6.0 

func (m *Column) GetColumn() []*Expr

func (*Column) Marshal added in v0.6.0 

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

func (*Column) MarshalTo added in v0.6.0 

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

func (*Column) MarshalToSizedBuffer added in v0.6.0 

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

func (*Column) ProtoMessage added in v0.6.0 

func (*Column) ProtoMessage()

func (*Column) ProtoSize added in v0.6.0 

func (m *Column) ProtoSize() (n int)

func (*Column) Reset added in v0.6.0 

func (m *Column) Reset()

func (*Column) String added in v0.6.0 

func (m *Column) String() string

func (*Column) Unmarshal added in v0.6.0 

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

func (*Column) XXX_DiscardUnknown added in v0.6.0 

func (m *Column) XXX_DiscardUnknown()

func (*Column) XXX_Marshal added in v0.6.0 

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

func (*Column) XXX_Merge added in v0.6.0 

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

func (*Column) XXX_Size added in v0.6.0 

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal added in v0.6.0 

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

type CompressType added in v0.5.0 

type CompressType int32
const (
	CompressType_None CompressType = 0
	CompressType_Lz4  CompressType = 1
)

func (CompressType) EnumDescriptor added in v0.5.0 

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

func (CompressType) String added in v0.5.0 

func (x CompressType) String() string

type Const 

type Const struct {
	Isnull bool `protobuf:"varint,1,opt,name=isnull,proto3" json:"isnull,omitempty"`
	// Types that are valid to be assigned to Value:
	//
	//	*Const_I8Val
	//	*Const_I16Val
	//	*Const_I32Val
	//	*Const_I64Val
	//	*Const_U8Val
	//	*Const_U16Val
	//	*Const_U32Val
	//	*Const_U64Val
	//	*Const_Dval
	//	*Const_Sval
	//	*Const_Bval
	//	*Const_Fval
	//	*Const_Dateval
	//	*Const_Timeval
	//	*Const_Datetimeval
	//	*Const_Decimal64Val
	//	*Const_Decimal128Val
	//	*Const_Timestampval
	//	*Const_Jsonval
	//	*Const_Defaultval
	//	*Const_UpdateVal
	Value                isConst_Value `protobuf_oneof:"value"`
	IsBin                bool          `protobuf:"varint,23,opt,name=isBin,proto3" json:"isBin,omitempty"`
	Src                  *Expr         `protobuf:"bytes,24,opt,name=src,proto3" json:"src,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Const: if a const value can be reprensented by int64 or double, use that, otherwise store a string representation.

func (*Const) Descriptor 

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

func (*Const) GetBval added in v0.5.0 

func (m *Const) GetBval() bool

func (*Const) GetDatetimeval added in v0.5.0 

func (m *Const) GetDatetimeval() int64

func (*Const) GetDateval added in v0.5.0 

func (m *Const) GetDateval() int32

func (*Const) GetDecimal128Val added in v0.5.0 

func (m *Const) GetDecimal128Val() *Decimal128

func (*Const) GetDecimal64Val added in v0.5.0 

func (m *Const) GetDecimal64Val() *Decimal64

func (*Const) GetDefaultval added in v0.6.0 

func (m *Const) GetDefaultval() bool

func (*Const) GetDval 

func (m *Const) GetDval() float64

func (*Const) GetFval added in v0.5.0 

func (m *Const) GetFval() float32

func (*Const) GetI16Val added in v0.6.0 

func (m *Const) GetI16Val() int32

func (*Const) GetI32Val added in v0.6.0 

func (m *Const) GetI32Val() int32

func (*Const) GetI64Val added in v0.6.0 

func (m *Const) GetI64Val() int64

func (*Const) GetI8Val added in v0.6.0 

func (m *Const) GetI8Val() int32

func (*Const) GetIsBin added in v0.6.0 

func (m *Const) GetIsBin() bool

func (*Const) GetIsnull 

func (m *Const) GetIsnull() bool

func (*Const) GetJsonval added in v0.6.0 

func (m *Const) GetJsonval() string

func (*Const) GetSrc added in v0.7.0 

func (m *Const) GetSrc() *Expr

func (*Const) GetSval 

func (m *Const) GetSval() string

func (*Const) GetTimestampval added in v0.5.0 

func (m *Const) GetTimestampval() int64

func (*Const) GetTimeval added in v0.6.0 

func (m *Const) GetTimeval() int64

func (*Const) GetU16Val added in v0.6.0 

func (m *Const) GetU16Val() uint32

func (*Const) GetU32Val added in v0.6.0 

func (m *Const) GetU32Val() uint32

func (*Const) GetU64Val added in v0.6.0 

func (m *Const) GetU64Val() uint64

func (*Const) GetU8Val added in v0.6.0 

func (m *Const) GetU8Val() uint32

func (*Const) GetUpdateVal added in v0.6.0 

func (m *Const) GetUpdateVal() bool

func (*Const) GetValue 

func (m *Const) GetValue() isConst_Value

func (*Const) Marshal added in v0.5.0 

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

func (*Const) MarshalTo added in v0.5.0 

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

func (*Const) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const) ProtoMessage 

func (*Const) ProtoMessage()

func (*Const) ProtoSize added in v0.5.0 

func (m *Const) ProtoSize() (n int)

func (*Const) Reset 

func (m *Const) Reset()

func (*Const) String 

func (m *Const) String() string

func (*Const) Unmarshal added in v0.5.0 

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

func (*Const) XXX_DiscardUnknown added in v0.5.0 

func (m *Const) XXX_DiscardUnknown()

func (*Const) XXX_Marshal added in v0.5.0 

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

func (*Const) XXX_Merge added in v0.5.0 

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

func (*Const) XXX_OneofWrappers added in v0.5.0 

func (*Const) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Const) XXX_Size added in v0.5.0 

func (m *Const) XXX_Size() int

func (*Const) XXX_Unmarshal added in v0.5.0 

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

type Const_Bval added in v0.5.0 

type Const_Bval struct {
	Bval bool `protobuf:"varint,12,opt,name=bval,proto3,oneof" json:"bval,omitempty"`
}

func (*Const_Bval) MarshalTo added in v0.5.0 

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

func (*Const_Bval) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Bval) ProtoSize added in v0.5.0 

func (m *Const_Bval) ProtoSize() (n int)

type Const_Datetimeval added in v0.5.0 

type Const_Datetimeval struct {
	Datetimeval int64 `protobuf:"varint,16,opt,name=datetimeval,proto3,oneof" json:"datetimeval,omitempty"`
}

func (*Const_Datetimeval) MarshalTo added in v0.5.0 

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

func (*Const_Datetimeval) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Datetimeval) ProtoSize added in v0.5.0 

func (m *Const_Datetimeval) ProtoSize() (n int)

type Const_Dateval added in v0.5.0 

type Const_Dateval struct {
	Dateval int32 `protobuf:"varint,14,opt,name=dateval,proto3,oneof" json:"dateval,omitempty"`
}

func (*Const_Dateval) MarshalTo added in v0.5.0 

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

func (*Const_Dateval) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Dateval) ProtoSize added in v0.5.0 

func (m *Const_Dateval) ProtoSize() (n int)

type Const_Decimal128Val added in v0.5.0 

type Const_Decimal128Val struct {
	Decimal128Val *Decimal128 `protobuf:"bytes,18,opt,name=decimal128val,proto3,oneof" json:"decimal128val,omitempty"`
}

func (*Const_Decimal128Val) MarshalTo added in v0.5.0 

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

func (*Const_Decimal128Val) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Decimal128Val) ProtoSize added in v0.5.0 

func (m *Const_Decimal128Val) ProtoSize() (n int)

type Const_Decimal64Val added in v0.5.0 

type Const_Decimal64Val struct {
	Decimal64Val *Decimal64 `protobuf:"bytes,17,opt,name=decimal64val,proto3,oneof" json:"decimal64val,omitempty"`
}

func (*Const_Decimal64Val) MarshalTo added in v0.5.0 

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

func (*Const_Decimal64Val) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Decimal64Val) ProtoSize added in v0.5.0 

func (m *Const_Decimal64Val) ProtoSize() (n int)

type Const_Defaultval added in v0.6.0 

type Const_Defaultval struct {
	Defaultval bool `protobuf:"varint,21,opt,name=defaultval,proto3,oneof" json:"defaultval,omitempty"`
}

func (*Const_Defaultval) MarshalTo added in v0.6.0 

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

func (*Const_Defaultval) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_Defaultval) ProtoSize added in v0.6.0 

func (m *Const_Defaultval) ProtoSize() (n int)

type Const_Dval 

type Const_Dval struct {
	Dval float64 `protobuf:"fixed64,10,opt,name=dval,proto3,oneof" json:"dval,omitempty"`
}

func (*Const_Dval) MarshalTo added in v0.5.0 

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

func (*Const_Dval) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Dval) ProtoSize added in v0.5.0 

func (m *Const_Dval) ProtoSize() (n int)

type Const_Fval added in v0.5.0 

type Const_Fval struct {
	Fval float32 `protobuf:"fixed32,13,opt,name=fval,proto3,oneof" json:"fval,omitempty"`
}

func (*Const_Fval) MarshalTo added in v0.5.0 

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

func (*Const_Fval) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Fval) ProtoSize added in v0.5.0 

func (m *Const_Fval) ProtoSize() (n int)

type Const_I16Val added in v0.6.0 

type Const_I16Val struct {
	I16Val int32 `protobuf:"varint,3,opt,name=i16val,proto3,oneof" json:"i16val,omitempty"`
}

func (*Const_I16Val) MarshalTo added in v0.6.0 

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

func (*Const_I16Val) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_I16Val) ProtoSize added in v0.6.0 

func (m *Const_I16Val) ProtoSize() (n int)

type Const_I32Val added in v0.6.0 

type Const_I32Val struct {
	I32Val int32 `protobuf:"varint,4,opt,name=i32val,proto3,oneof" json:"i32val,omitempty"`
}

func (*Const_I32Val) MarshalTo added in v0.6.0 

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

func (*Const_I32Val) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_I32Val) ProtoSize added in v0.6.0 

func (m *Const_I32Val) ProtoSize() (n int)

type Const_I64Val added in v0.6.0 

type Const_I64Val struct {
	I64Val int64 `protobuf:"varint,5,opt,name=i64val,proto3,oneof" json:"i64val,omitempty"`
}

func (*Const_I64Val) MarshalTo added in v0.6.0 

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

func (*Const_I64Val) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_I64Val) ProtoSize added in v0.6.0 

func (m *Const_I64Val) ProtoSize() (n int)

type Const_I8Val added in v0.6.0 

type Const_I8Val struct {
	I8Val int32 `protobuf:"varint,2,opt,name=i8val,proto3,oneof" json:"i8val,omitempty"`
}

func (*Const_I8Val) MarshalTo added in v0.6.0 

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

func (*Const_I8Val) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_I8Val) ProtoSize added in v0.6.0 

func (m *Const_I8Val) ProtoSize() (n int)

type Const_Jsonval added in v0.6.0 

type Const_Jsonval struct {
	Jsonval string `protobuf:"bytes,20,opt,name=jsonval,proto3,oneof" json:"jsonval,omitempty"`
}

func (*Const_Jsonval) MarshalTo added in v0.6.0 

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

func (*Const_Jsonval) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_Jsonval) ProtoSize added in v0.6.0 

func (m *Const_Jsonval) ProtoSize() (n int)

type Const_Sval 

type Const_Sval struct {
	Sval string `protobuf:"bytes,11,opt,name=sval,proto3,oneof" json:"sval,omitempty"`
}

func (*Const_Sval) MarshalTo added in v0.5.0 

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

func (*Const_Sval) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Sval) ProtoSize added in v0.5.0 

func (m *Const_Sval) ProtoSize() (n int)

type Const_Timestampval added in v0.5.0 

type Const_Timestampval struct {
	Timestampval int64 `protobuf:"varint,19,opt,name=timestampval,proto3,oneof" json:"timestampval,omitempty"`
}

func (*Const_Timestampval) MarshalTo added in v0.5.0 

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

func (*Const_Timestampval) MarshalToSizedBuffer added in v0.5.0 

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

func (*Const_Timestampval) ProtoSize added in v0.5.0 

func (m *Const_Timestampval) ProtoSize() (n int)

type Const_Timeval added in v0.6.0 

type Const_Timeval struct {
	Timeval int64 `protobuf:"varint,15,opt,name=timeval,proto3,oneof" json:"timeval,omitempty"`
}

func (*Const_Timeval) MarshalTo added in v0.6.0 

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

func (*Const_Timeval) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_Timeval) ProtoSize added in v0.6.0 

func (m *Const_Timeval) ProtoSize() (n int)

type Const_U16Val added in v0.6.0 

type Const_U16Val struct {
	U16Val uint32 `protobuf:"varint,7,opt,name=u16val,proto3,oneof" json:"u16val,omitempty"`
}

func (*Const_U16Val) MarshalTo added in v0.6.0 

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

func (*Const_U16Val) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_U16Val) ProtoSize added in v0.6.0 

func (m *Const_U16Val) ProtoSize() (n int)

type Const_U32Val added in v0.6.0 

type Const_U32Val struct {
	U32Val uint32 `protobuf:"varint,8,opt,name=u32val,proto3,oneof" json:"u32val,omitempty"`
}

func (*Const_U32Val) MarshalTo added in v0.6.0 

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

func (*Const_U32Val) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_U32Val) ProtoSize added in v0.6.0 

func (m *Const_U32Val) ProtoSize() (n int)

type Const_U64Val added in v0.6.0 

type Const_U64Val struct {
	U64Val uint64 `protobuf:"varint,9,opt,name=u64val,proto3,oneof" json:"u64val,omitempty"`
}

func (*Const_U64Val) MarshalTo added in v0.6.0 

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

func (*Const_U64Val) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_U64Val) ProtoSize added in v0.6.0 

func (m *Const_U64Val) ProtoSize() (n int)

type Const_U8Val added in v0.6.0 

type Const_U8Val struct {
	U8Val uint32 `protobuf:"varint,6,opt,name=u8val,proto3,oneof" json:"u8val,omitempty"`
}

func (*Const_U8Val) MarshalTo added in v0.6.0 

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

func (*Const_U8Val) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_U8Val) ProtoSize added in v0.6.0 

func (m *Const_U8Val) ProtoSize() (n int)

type Const_UpdateVal added in v0.6.0 

type Const_UpdateVal struct {
	UpdateVal bool `protobuf:"varint,22,opt,name=updateVal,proto3,oneof" json:"updateVal,omitempty"`
}

func (*Const_UpdateVal) MarshalTo added in v0.6.0 

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

func (*Const_UpdateVal) MarshalToSizedBuffer added in v0.6.0 

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

func (*Const_UpdateVal) ProtoSize added in v0.6.0 

func (m *Const_UpdateVal) ProtoSize() (n int)

type CorrColRef 

type CorrColRef struct {
	RelPos               int32    `protobuf:"varint,1,opt,name=rel_pos,json=relPos,proto3" json:"rel_pos,omitempty"`
	ColPos               int32    `protobuf:"varint,2,opt,name=col_pos,json=colPos,proto3" json:"col_pos,omitempty"`
	Depth                int32    `protobuf:"varint,3,opt,name=depth,proto3" json:"depth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Reference a correlated column in the proj list of a node.

func (*CorrColRef) Descriptor 

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

func (*CorrColRef) GetColPos 

func (m *CorrColRef) GetColPos() int32

func (*CorrColRef) GetDepth added in v0.5.0 

func (m *CorrColRef) GetDepth() int32

func (*CorrColRef) GetRelPos 

func (m *CorrColRef) GetRelPos() int32

func (*CorrColRef) Marshal added in v0.5.0 

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

func (*CorrColRef) MarshalTo added in v0.5.0 

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

func (*CorrColRef) MarshalToSizedBuffer added in v0.5.0 

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

func (*CorrColRef) ProtoMessage 

func (*CorrColRef) ProtoMessage()

func (*CorrColRef) ProtoSize added in v0.5.0 

func (m *CorrColRef) ProtoSize() (n int)

func (*CorrColRef) Reset 

func (m *CorrColRef) Reset()

func (*CorrColRef) String 

func (m *CorrColRef) String() string

func (*CorrColRef) Unmarshal added in v0.5.0 

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

func (*CorrColRef) XXX_DiscardUnknown added in v0.5.0 

func (m *CorrColRef) XXX_DiscardUnknown()

func (*CorrColRef) XXX_Marshal added in v0.5.0 

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

func (*CorrColRef) XXX_Merge added in v0.5.0 

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

func (*CorrColRef) XXX_Size added in v0.5.0 

func (m *CorrColRef) XXX_Size() int

func (*CorrColRef) XXX_Unmarshal added in v0.5.0 

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

type CreateDatabase added in v0.5.0 

type CreateDatabase struct {
	IfNotExists          bool     `protobuf:"varint,1,opt,name=if_not_exists,json=ifNotExists,proto3" json:"if_not_exists,omitempty"`
	Database             string   `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDatabase) Descriptor added in v0.5.0 

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

func (*CreateDatabase) GetDatabase added in v0.5.0 

func (m *CreateDatabase) GetDatabase() string

func (*CreateDatabase) GetIfNotExists added in v0.5.0 

func (m *CreateDatabase) GetIfNotExists() bool

func (*CreateDatabase) Marshal added in v0.5.0 

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

func (*CreateDatabase) MarshalTo added in v0.5.0 

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

func (*CreateDatabase) MarshalToSizedBuffer added in v0.5.0 

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

func (*CreateDatabase) ProtoMessage added in v0.5.0 

func (*CreateDatabase) ProtoMessage()

func (*CreateDatabase) ProtoSize added in v0.5.0 

func (m *CreateDatabase) ProtoSize() (n int)

func (*CreateDatabase) Reset added in v0.5.0 

func (m *CreateDatabase) Reset()

func (*CreateDatabase) String added in v0.5.0 

func (m *CreateDatabase) String() string

func (*CreateDatabase) Unmarshal added in v0.5.0 

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

func (*CreateDatabase) XXX_DiscardUnknown added in v0.5.0 

func (m *CreateDatabase) XXX_DiscardUnknown()

func (*CreateDatabase) XXX_Marshal added in v0.5.0 

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

func (*CreateDatabase) XXX_Merge added in v0.5.0 

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

func (*CreateDatabase) XXX_Size added in v0.5.0 

func (m *CreateDatabase) XXX_Size() int

func (*CreateDatabase) XXX_Unmarshal added in v0.5.0 

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

type CreateIndex added in v0.5.0 

type CreateIndex struct {
	Database              string       `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table                 string       `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	OriginTablePrimaryKey string       `` /* 128-byte string literal not displayed */
	Index                 *CreateTable `protobuf:"bytes,4,opt,name=index,proto3" json:"index,omitempty"`
	TableExist            bool         `protobuf:"varint,5,opt,name=table_exist,json=tableExist,proto3" json:"table_exist,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}     `json:"-"`
	XXX_unrecognized      []byte       `json:"-"`
	XXX_sizecache         int32        `json:"-"`
}

func (*CreateIndex) Descriptor added in v0.5.0 

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

func (*CreateIndex) GetDatabase added in v0.7.0 

func (m *CreateIndex) GetDatabase() string

func (*CreateIndex) GetIndex added in v0.5.0 

func (m *CreateIndex) GetIndex() *CreateTable

func (*CreateIndex) GetOriginTablePrimaryKey added in v0.7.0 

func (m *CreateIndex) GetOriginTablePrimaryKey() string

func (*CreateIndex) GetTable added in v0.7.0 

func (m *CreateIndex) GetTable() string

func (*CreateIndex) GetTableExist added in v0.7.0 

func (m *CreateIndex) GetTableExist() bool

func (*CreateIndex) Marshal added in v0.5.0 

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

func (*CreateIndex) MarshalTo added in v0.5.0 

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

func (*CreateIndex) MarshalToSizedBuffer added in v0.5.0 

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

func (*CreateIndex) ProtoMessage added in v0.5.0 

func (*CreateIndex) ProtoMessage()

func (*CreateIndex) ProtoSize added in v0.5.0 

func (m *CreateIndex) ProtoSize() (n int)

func (*CreateIndex) Reset added in v0.5.0 

func (m *CreateIndex) Reset()

func (*CreateIndex) String added in v0.5.0 

func (m *CreateIndex) String() string

func (*CreateIndex) Unmarshal added in v0.5.0 

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

func (*CreateIndex) XXX_DiscardUnknown added in v0.5.0 

func (m *CreateIndex) XXX_DiscardUnknown()

func (*CreateIndex) XXX_Marshal added in v0.5.0 

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

func (*CreateIndex) XXX_Merge added in v0.5.0 

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

func (*CreateIndex) XXX_Size added in v0.5.0 

func (m *CreateIndex) XXX_Size() int

func (*CreateIndex) XXX_Unmarshal added in v0.5.0 

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

type CreateTable added in v0.5.0 

type CreateTable struct {
	IfNotExists bool        `protobuf:"varint,1,opt,name=if_not_exists,json=ifNotExists,proto3" json:"if_not_exists,omitempty"`
	Temporary   bool        `protobuf:"varint,2,opt,name=temporary,proto3" json:"temporary,omitempty"`
	Database    string      `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	TableDef    *TableDef   `protobuf:"bytes,4,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
	IndexTables []*TableDef `protobuf:"bytes,5,rep,name=index_tables,json=indexTables,proto3" json:"index_tables,omitempty"`
	// we need the db/table name of foreign key when create table. but we don't need it in ForeignKeyDef
	FkDbs    []string `protobuf:"bytes,6,rep,name=fk_dbs,json=fkDbs,proto3" json:"fk_dbs,omitempty"`
	FkTables []string `protobuf:"bytes,7,rep,name=fk_tables,json=fkTables,proto3" json:"fk_tables,omitempty"`
	// we need column name when create table, but not in ForeignKeyDef
	FkCols               []*CreateTable_FkColName `protobuf:"bytes,8,rep,name=fk_cols,json=fkCols,proto3" json:"fk_cols,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*CreateTable) Descriptor added in v0.5.0 

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

func (*CreateTable) GetDatabase added in v0.5.0 

func (m *CreateTable) GetDatabase() string

func (*CreateTable) GetFkCols added in v0.7.0 

func (m *CreateTable) GetFkCols() []*CreateTable_FkColName

func (*CreateTable) GetFkDbs added in v0.7.0 

func (m *CreateTable) GetFkDbs() []string

func (*CreateTable) GetFkTables added in v0.7.0 

func (m *CreateTable) GetFkTables() []string

func (*CreateTable) GetIfNotExists added in v0.5.0 

func (m *CreateTable) GetIfNotExists() bool

func (*CreateTable) GetIndexTables added in v0.6.0 

func (m *CreateTable) GetIndexTables() []*TableDef

func (*CreateTable) GetTableDef added in v0.5.0 

func (m *CreateTable) GetTableDef() *TableDef

func (*CreateTable) GetTemporary added in v0.5.0 

func (m *CreateTable) GetTemporary() bool

func (*CreateTable) Marshal added in v0.5.0 

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

func (*CreateTable) MarshalTo added in v0.5.0 

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

func (*CreateTable) MarshalToSizedBuffer added in v0.5.0 

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

func (*CreateTable) ProtoMessage added in v0.5.0 

func (*CreateTable) ProtoMessage()

func (*CreateTable) ProtoSize added in v0.5.0 

func (m *CreateTable) ProtoSize() (n int)

func (*CreateTable) Reset added in v0.5.0 

func (m *CreateTable) Reset()

func (*CreateTable) String added in v0.5.0 

func (m *CreateTable) String() string

func (*CreateTable) Unmarshal added in v0.5.0 

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

func (*CreateTable) XXX_DiscardUnknown added in v0.5.0 

func (m *CreateTable) XXX_DiscardUnknown()

func (*CreateTable) XXX_Marshal added in v0.5.0 

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

func (*CreateTable) XXX_Merge added in v0.5.0 

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

func (*CreateTable) XXX_Size added in v0.5.0 

func (m *CreateTable) XXX_Size() int

func (*CreateTable) XXX_Unmarshal added in v0.5.0 

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

type CreateTable_FkColName added in v0.7.0 

type CreateTable_FkColName struct {
	Cols                 []string `protobuf:"bytes,1,rep,name=cols,proto3" json:"cols,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTable_FkColName) Descriptor added in v0.7.0 

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

func (*CreateTable_FkColName) GetCols added in v0.7.0 

func (m *CreateTable_FkColName) GetCols() []string

func (*CreateTable_FkColName) Marshal added in v0.7.0 

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

func (*CreateTable_FkColName) MarshalTo added in v0.7.0 

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

func (*CreateTable_FkColName) MarshalToSizedBuffer added in v0.7.0 

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

func (*CreateTable_FkColName) ProtoMessage added in v0.7.0 

func (*CreateTable_FkColName) ProtoMessage()

func (*CreateTable_FkColName) ProtoSize added in v0.7.0 

func (m *CreateTable_FkColName) ProtoSize() (n int)

func (*CreateTable_FkColName) Reset added in v0.7.0 

func (m *CreateTable_FkColName) Reset()

func (*CreateTable_FkColName) String added in v0.7.0 

func (m *CreateTable_FkColName) String() string

func (*CreateTable_FkColName) Unmarshal added in v0.7.0 

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

func (*CreateTable_FkColName) XXX_DiscardUnknown added in v0.7.0 

func (m *CreateTable_FkColName) XXX_DiscardUnknown()

func (*CreateTable_FkColName) XXX_Marshal added in v0.7.0 

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

func (*CreateTable_FkColName) XXX_Merge added in v0.7.0 

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

func (*CreateTable_FkColName) XXX_Size added in v0.7.0 

func (m *CreateTable_FkColName) XXX_Size() int

func (*CreateTable_FkColName) XXX_Unmarshal added in v0.7.0 

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

type DataControl added in v0.5.0 

type DataControl struct {
	// DataDefinition type
	DclType DataControl_DclType `protobuf:"varint,1,opt,name=dcl_type,json=dclType,proto3,enum=plan.DataControl_DclType" json:"dcl_type,omitempty"`
	// Types that are valid to be assigned to Control:
	//
	//	*DataControl_SetVariables
	//	*DataControl_Prepare
	//	*DataControl_Execute
	//	*DataControl_Deallocate
	Control              isDataControl_Control `protobuf_oneof:"control"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*DataControl) Descriptor added in v0.5.0 

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

func (*DataControl) GetControl added in v0.5.0 

func (m *DataControl) GetControl() isDataControl_Control

func (*DataControl) GetDclType added in v0.5.0 

func (m *DataControl) GetDclType() DataControl_DclType

func (*DataControl) GetDeallocate added in v0.5.1 

func (m *DataControl) GetDeallocate() *Deallocate

func (*DataControl) GetExecute added in v0.5.1 

func (m *DataControl) GetExecute() *Execute

func (*DataControl) GetPrepare added in v0.5.1 

func (m *DataControl) GetPrepare() *Prepare

func (*DataControl) GetSetVariables added in v0.5.0 

func (m *DataControl) GetSetVariables() *SetVariables

func (*DataControl) Marshal added in v0.5.0 

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

func (*DataControl) MarshalTo added in v0.5.0 

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

func (*DataControl) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataControl) ProtoMessage added in v0.5.0 

func (*DataControl) ProtoMessage()

func (*DataControl) ProtoSize added in v0.5.0 

func (m *DataControl) ProtoSize() (n int)

func (*DataControl) Reset added in v0.5.0 

func (m *DataControl) Reset()

func (*DataControl) String added in v0.5.0 

func (m *DataControl) String() string

func (*DataControl) Unmarshal added in v0.5.0 

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

func (*DataControl) XXX_DiscardUnknown added in v0.5.0 

func (m *DataControl) XXX_DiscardUnknown()

func (*DataControl) XXX_Marshal added in v0.5.0 

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

func (*DataControl) XXX_Merge added in v0.5.0 

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

func (*DataControl) XXX_OneofWrappers added in v0.5.0 

func (*DataControl) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DataControl) XXX_Size added in v0.5.0 

func (m *DataControl) XXX_Size() int

func (*DataControl) XXX_Unmarshal added in v0.5.0 

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

type DataControl_DclType added in v0.5.0 

type DataControl_DclType int32
const (
	DataControl_SET_VARIABLES DataControl_DclType = 0
	DataControl_GRANT         DataControl_DclType = 1
	DataControl_REVOKE        DataControl_DclType = 2
	DataControl_DENY          DataControl_DclType = 3
	DataControl_PREPARE       DataControl_DclType = 4
	DataControl_EXECUTE       DataControl_DclType = 5
	DataControl_DEALLOCATE    DataControl_DclType = 6
)

func (DataControl_DclType) EnumDescriptor added in v0.5.0 

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

func (DataControl_DclType) String added in v0.5.0 

func (x DataControl_DclType) String() string

type DataControl_Deallocate added in v0.5.1 

type DataControl_Deallocate struct {
	Deallocate *Deallocate `protobuf:"bytes,5,opt,name=deallocate,proto3,oneof" json:"deallocate,omitempty"`
}

func (*DataControl_Deallocate) MarshalTo added in v0.5.1 

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

func (*DataControl_Deallocate) MarshalToSizedBuffer added in v0.5.1 

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

func (*DataControl_Deallocate) ProtoSize added in v0.5.1 

func (m *DataControl_Deallocate) ProtoSize() (n int)

type DataControl_Execute added in v0.5.1 

type DataControl_Execute struct {
	Execute *Execute `protobuf:"bytes,4,opt,name=execute,proto3,oneof" json:"execute,omitempty"`
}

func (*DataControl_Execute) MarshalTo added in v0.5.1 

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

func (*DataControl_Execute) MarshalToSizedBuffer added in v0.5.1 

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

func (*DataControl_Execute) ProtoSize added in v0.5.1 

func (m *DataControl_Execute) ProtoSize() (n int)

type DataControl_Prepare added in v0.5.1 

type DataControl_Prepare struct {
	Prepare *Prepare `protobuf:"bytes,3,opt,name=prepare,proto3,oneof" json:"prepare,omitempty"`
}

func (*DataControl_Prepare) MarshalTo added in v0.5.1 

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

func (*DataControl_Prepare) MarshalToSizedBuffer added in v0.5.1 

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

func (*DataControl_Prepare) ProtoSize added in v0.5.1 

func (m *DataControl_Prepare) ProtoSize() (n int)

type DataControl_SetVariables added in v0.5.0 

type DataControl_SetVariables struct {
	SetVariables *SetVariables `protobuf:"bytes,2,opt,name=set_variables,json=setVariables,proto3,oneof" json:"set_variables,omitempty"`
}

func (*DataControl_SetVariables) MarshalTo added in v0.5.0 

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

func (*DataControl_SetVariables) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataControl_SetVariables) ProtoSize added in v0.5.0 

func (m *DataControl_SetVariables) ProtoSize() (n int)

type DataDefinition added in v0.5.0 

type DataDefinition struct {
	// DataDefinition type
	DdlType DataDefinition_DdlType `protobuf:"varint,1,opt,name=ddl_type,json=ddlType,proto3,enum=plan.DataDefinition_DdlType" json:"ddl_type,omitempty"`
	// other show statement we will rewrite to a select statement
	// then we will get a Query
	// eg: 'show databases' will rewrite to 'select md.datname as `Database` from mo_database md'
	Query *Query `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Types that are valid to be assigned to Definition:
	//
	//	*DataDefinition_CreateDatabase
	//	*DataDefinition_AlterDatabase
	//	*DataDefinition_DropDatabase
	//	*DataDefinition_CreateTable
	//	*DataDefinition_AlterTable
	//	*DataDefinition_DropTable
	//	*DataDefinition_CreateIndex
	//	*DataDefinition_AlterIndex
	//	*DataDefinition_DropIndex
	//	*DataDefinition_TruncateTable
	//	*DataDefinition_ShowVariables
	//	*DataDefinition_AlterView
	Definition           isDataDefinition_Definition `protobuf_oneof:"definition"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*DataDefinition) Descriptor added in v0.5.0 

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

func (*DataDefinition) GetAlterDatabase added in v0.5.0 

func (m *DataDefinition) GetAlterDatabase() *AlterDatabase

func (*DataDefinition) GetAlterIndex added in v0.5.0 

func (m *DataDefinition) GetAlterIndex() *AlterIndex

func (*DataDefinition) GetAlterTable added in v0.5.0 

func (m *DataDefinition) GetAlterTable() *AlterTable

func (*DataDefinition) GetAlterView added in v0.7.0 

func (m *DataDefinition) GetAlterView() *AlterView

func (*DataDefinition) GetCreateDatabase added in v0.5.0 

func (m *DataDefinition) GetCreateDatabase() *CreateDatabase

func (*DataDefinition) GetCreateIndex added in v0.5.0 

func (m *DataDefinition) GetCreateIndex() *CreateIndex

func (*DataDefinition) GetCreateTable added in v0.5.0 

func (m *DataDefinition) GetCreateTable() *CreateTable

func (*DataDefinition) GetDdlType added in v0.5.0 

func (m *DataDefinition) GetDdlType() DataDefinition_DdlType

func (*DataDefinition) GetDefinition added in v0.5.0 

func (m *DataDefinition) GetDefinition() isDataDefinition_Definition

func (*DataDefinition) GetDropDatabase added in v0.5.0 

func (m *DataDefinition) GetDropDatabase() *DropDatabase

func (*DataDefinition) GetDropIndex added in v0.5.0 

func (m *DataDefinition) GetDropIndex() *DropIndex

func (*DataDefinition) GetDropTable added in v0.5.0 

func (m *DataDefinition) GetDropTable() *DropTable

func (*DataDefinition) GetQuery added in v0.5.0 

func (m *DataDefinition) GetQuery() *Query

func (*DataDefinition) GetShowVariables added in v0.5.0 

func (m *DataDefinition) GetShowVariables() *ShowVariables

func (*DataDefinition) GetTruncateTable added in v0.5.0 

func (m *DataDefinition) GetTruncateTable() *TruncateTable

func (*DataDefinition) Marshal added in v0.5.0 

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

func (*DataDefinition) MarshalTo added in v0.5.0 

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

func (*DataDefinition) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition) ProtoMessage added in v0.5.0 

func (*DataDefinition) ProtoMessage()

func (*DataDefinition) ProtoSize added in v0.5.0 

func (m *DataDefinition) ProtoSize() (n int)

func (*DataDefinition) Reset added in v0.5.0 

func (m *DataDefinition) Reset()

func (*DataDefinition) String added in v0.5.0 

func (m *DataDefinition) String() string

func (*DataDefinition) Unmarshal added in v0.5.0 

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

func (*DataDefinition) XXX_DiscardUnknown added in v0.5.0 

func (m *DataDefinition) XXX_DiscardUnknown()

func (*DataDefinition) XXX_Marshal added in v0.5.0 

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

func (*DataDefinition) XXX_Merge added in v0.5.0 

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

func (*DataDefinition) XXX_OneofWrappers added in v0.5.0 

func (*DataDefinition) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*DataDefinition) XXX_Size added in v0.5.0 

func (m *DataDefinition) XXX_Size() int

func (*DataDefinition) XXX_Unmarshal added in v0.5.0 

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

type DataDefinition_AlterDatabase added in v0.5.0 

type DataDefinition_AlterDatabase struct {
	AlterDatabase *AlterDatabase `protobuf:"bytes,4,opt,name=alter_database,json=alterDatabase,proto3,oneof" json:"alter_database,omitempty"`
}

func (*DataDefinition_AlterDatabase) MarshalTo added in v0.5.0 

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

func (*DataDefinition_AlterDatabase) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_AlterDatabase) ProtoSize added in v0.5.0 

func (m *DataDefinition_AlterDatabase) ProtoSize() (n int)

type DataDefinition_AlterIndex added in v0.5.0 

type DataDefinition_AlterIndex struct {
	AlterIndex *AlterIndex `protobuf:"bytes,10,opt,name=alter_index,json=alterIndex,proto3,oneof" json:"alter_index,omitempty"`
}

func (*DataDefinition_AlterIndex) MarshalTo added in v0.5.0 

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

func (*DataDefinition_AlterIndex) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_AlterIndex) ProtoSize added in v0.5.0 

func (m *DataDefinition_AlterIndex) ProtoSize() (n int)

type DataDefinition_AlterTable added in v0.5.0 

type DataDefinition_AlterTable struct {
	AlterTable *AlterTable `protobuf:"bytes,7,opt,name=alter_table,json=alterTable,proto3,oneof" json:"alter_table,omitempty"`
}

func (*DataDefinition_AlterTable) MarshalTo added in v0.5.0 

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

func (*DataDefinition_AlterTable) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_AlterTable) ProtoSize added in v0.5.0 

func (m *DataDefinition_AlterTable) ProtoSize() (n int)

type DataDefinition_AlterView added in v0.7.0 

type DataDefinition_AlterView struct {
	AlterView *AlterView `protobuf:"bytes,14,opt,name=alter_view,json=alterView,proto3,oneof" json:"alter_view,omitempty"`
}

func (*DataDefinition_AlterView) MarshalTo added in v0.7.0 

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

func (*DataDefinition_AlterView) MarshalToSizedBuffer added in v0.7.0 

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

func (*DataDefinition_AlterView) ProtoSize added in v0.7.0 

func (m *DataDefinition_AlterView) ProtoSize() (n int)

type DataDefinition_CreateDatabase added in v0.5.0 

type DataDefinition_CreateDatabase struct {
	CreateDatabase *CreateDatabase `protobuf:"bytes,3,opt,name=create_database,json=createDatabase,proto3,oneof" json:"create_database,omitempty"`
}

func (*DataDefinition_CreateDatabase) MarshalTo added in v0.5.0 

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

func (*DataDefinition_CreateDatabase) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_CreateDatabase) ProtoSize added in v0.5.0 

func (m *DataDefinition_CreateDatabase) ProtoSize() (n int)

type DataDefinition_CreateIndex added in v0.5.0 

type DataDefinition_CreateIndex struct {
	CreateIndex *CreateIndex `protobuf:"bytes,9,opt,name=create_index,json=createIndex,proto3,oneof" json:"create_index,omitempty"`
}

func (*DataDefinition_CreateIndex) MarshalTo added in v0.5.0 

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

func (*DataDefinition_CreateIndex) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_CreateIndex) ProtoSize added in v0.5.0 

func (m *DataDefinition_CreateIndex) ProtoSize() (n int)

type DataDefinition_CreateTable added in v0.5.0 

type DataDefinition_CreateTable struct {
	CreateTable *CreateTable `protobuf:"bytes,6,opt,name=create_table,json=createTable,proto3,oneof" json:"create_table,omitempty"`
}

func (*DataDefinition_CreateTable) MarshalTo added in v0.5.0 

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

func (*DataDefinition_CreateTable) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_CreateTable) ProtoSize added in v0.5.0 

func (m *DataDefinition_CreateTable) ProtoSize() (n int)

type DataDefinition_DdlType added in v0.5.0 

type DataDefinition_DdlType int32
const (
	DataDefinition_CREATE_DATABASE     DataDefinition_DdlType = 0
	DataDefinition_ALTER_DATABASE      DataDefinition_DdlType = 1
	DataDefinition_DROP_DATABASE       DataDefinition_DdlType = 2
	DataDefinition_CREATE_TABLE        DataDefinition_DdlType = 3
	DataDefinition_ALTER_TABLE         DataDefinition_DdlType = 4
	DataDefinition_DROP_TABLE          DataDefinition_DdlType = 5
	DataDefinition_CREATE_INDEX        DataDefinition_DdlType = 6
	DataDefinition_ALTER_INDEX         DataDefinition_DdlType = 7
	DataDefinition_DROP_INDEX          DataDefinition_DdlType = 8
	DataDefinition_TRUNCATE_TABLE      DataDefinition_DdlType = 9
	DataDefinition_CREATE_VIEW         DataDefinition_DdlType = 10
	DataDefinition_ALTER_VIEW          DataDefinition_DdlType = 11
	DataDefinition_DROP_VIEW           DataDefinition_DdlType = 12
	DataDefinition_SHOW_CREATEDATABASE DataDefinition_DdlType = 13
	DataDefinition_SHOW_CREATETABLE    DataDefinition_DdlType = 14
	DataDefinition_SHOW_DATABASES      DataDefinition_DdlType = 15
	DataDefinition_SHOW_TABLES         DataDefinition_DdlType = 16
	DataDefinition_SHOW_COLUMNS        DataDefinition_DdlType = 17
	DataDefinition_SHOW_INDEX          DataDefinition_DdlType = 18
	DataDefinition_SHOW_VARIABLES      DataDefinition_DdlType = 19
	DataDefinition_SHOW_WARNINGS       DataDefinition_DdlType = 20
	DataDefinition_SHOW_ERRORS         DataDefinition_DdlType = 21
	DataDefinition_SHOW_STATUS         DataDefinition_DdlType = 22
	DataDefinition_SHOW_PROCESSLIST    DataDefinition_DdlType = 23
	DataDefinition_SHOW_TABLE_STATUS   DataDefinition_DdlType = 24
	DataDefinition_SHOW_TARGET         DataDefinition_DdlType = 25
	DataDefinition_SHOW_COLLATION      DataDefinition_DdlType = 26
)

func (DataDefinition_DdlType) EnumDescriptor added in v0.5.0 

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

func (DataDefinition_DdlType) String added in v0.5.0 

func (x DataDefinition_DdlType) String() string

type DataDefinition_DropDatabase added in v0.5.0 

type DataDefinition_DropDatabase struct {
	DropDatabase *DropDatabase `protobuf:"bytes,5,opt,name=drop_database,json=dropDatabase,proto3,oneof" json:"drop_database,omitempty"`
}

func (*DataDefinition_DropDatabase) MarshalTo added in v0.5.0 

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

func (*DataDefinition_DropDatabase) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_DropDatabase) ProtoSize added in v0.5.0 

func (m *DataDefinition_DropDatabase) ProtoSize() (n int)

type DataDefinition_DropIndex added in v0.5.0 

type DataDefinition_DropIndex struct {
	DropIndex *DropIndex `protobuf:"bytes,11,opt,name=drop_index,json=dropIndex,proto3,oneof" json:"drop_index,omitempty"`
}

func (*DataDefinition_DropIndex) MarshalTo added in v0.5.0 

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

func (*DataDefinition_DropIndex) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_DropIndex) ProtoSize added in v0.5.0 

func (m *DataDefinition_DropIndex) ProtoSize() (n int)

type DataDefinition_DropTable added in v0.5.0 

type DataDefinition_DropTable struct {
	DropTable *DropTable `protobuf:"bytes,8,opt,name=drop_table,json=dropTable,proto3,oneof" json:"drop_table,omitempty"`
}

func (*DataDefinition_DropTable) MarshalTo added in v0.5.0 

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

func (*DataDefinition_DropTable) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_DropTable) ProtoSize added in v0.5.0 

func (m *DataDefinition_DropTable) ProtoSize() (n int)

type DataDefinition_ShowVariables added in v0.5.0 

type DataDefinition_ShowVariables struct {
	ShowVariables *ShowVariables `protobuf:"bytes,13,opt,name=show_variables,json=showVariables,proto3,oneof" json:"show_variables,omitempty"`
}

func (*DataDefinition_ShowVariables) MarshalTo added in v0.5.0 

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

func (*DataDefinition_ShowVariables) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_ShowVariables) ProtoSize added in v0.5.0 

func (m *DataDefinition_ShowVariables) ProtoSize() (n int)

type DataDefinition_TruncateTable added in v0.5.0 

type DataDefinition_TruncateTable struct {
	TruncateTable *TruncateTable `protobuf:"bytes,12,opt,name=truncate_table,json=truncateTable,proto3,oneof" json:"truncate_table,omitempty"`
}

func (*DataDefinition_TruncateTable) MarshalTo added in v0.5.0 

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

func (*DataDefinition_TruncateTable) MarshalToSizedBuffer added in v0.5.0 

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

func (*DataDefinition_TruncateTable) ProtoSize added in v0.5.0 

func (m *DataDefinition_TruncateTable) ProtoSize() (n int)

type Deallocate added in v0.5.1 

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

func (*Deallocate) Descriptor added in v0.5.1 

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

func (*Deallocate) GetName added in v0.5.1 

func (m *Deallocate) GetName() string

func (*Deallocate) Marshal added in v0.5.1 

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

func (*Deallocate) MarshalTo added in v0.5.1 

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

func (*Deallocate) MarshalToSizedBuffer added in v0.5.1 

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

func (*Deallocate) ProtoMessage added in v0.5.1 

func (*Deallocate) ProtoMessage()

func (*Deallocate) ProtoSize added in v0.5.1 

func (m *Deallocate) ProtoSize() (n int)

func (*Deallocate) Reset added in v0.5.1 

func (m *Deallocate) Reset()

func (*Deallocate) String added in v0.5.1 

func (m *Deallocate) String() string

func (*Deallocate) Unmarshal added in v0.5.1 

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

func (*Deallocate) XXX_DiscardUnknown added in v0.5.1 

func (m *Deallocate) XXX_DiscardUnknown()

func (*Deallocate) XXX_Marshal added in v0.5.1 

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

func (*Deallocate) XXX_Merge added in v0.5.1 

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

func (*Deallocate) XXX_Size added in v0.5.1 

func (m *Deallocate) XXX_Size() int

func (*Deallocate) XXX_Unmarshal added in v0.5.1 

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

type Decimal128 added in v0.5.0 

type Decimal128 struct {
	A                    int64    `protobuf:"varint,1,opt,name=a,proto3" json:"a,omitempty"`
	B                    int64    `protobuf:"varint,2,opt,name=b,proto3" json:"b,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Decimal128) Descriptor added in v0.5.0 

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

func (*Decimal128) GetA added in v0.6.0 

func (m *Decimal128) GetA() int64

func (*Decimal128) GetB added in v0.6.0 

func (m *Decimal128) GetB() int64

func (*Decimal128) Marshal added in v0.5.0 

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

func (*Decimal128) MarshalTo added in v0.5.0 

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

func (*Decimal128) MarshalToSizedBuffer added in v0.5.0 

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

func (*Decimal128) ProtoMessage added in v0.5.0 

func (*Decimal128) ProtoMessage()

func (*Decimal128) ProtoSize added in v0.5.0 

func (m *Decimal128) ProtoSize() (n int)

func (*Decimal128) Reset added in v0.5.0 

func (m *Decimal128) Reset()

func (*Decimal128) String added in v0.5.0 

func (m *Decimal128) String() string

func (*Decimal128) Unmarshal added in v0.5.0 

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

func (*Decimal128) XXX_DiscardUnknown added in v0.5.0 

func (m *Decimal128) XXX_DiscardUnknown()

func (*Decimal128) XXX_Marshal added in v0.5.0 

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

func (*Decimal128) XXX_Merge added in v0.5.0 

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

func (*Decimal128) XXX_Size added in v0.5.0 

func (m *Decimal128) XXX_Size() int

func (*Decimal128) XXX_Unmarshal added in v0.5.0 

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

type Decimal64 added in v0.6.0 

type Decimal64 struct {
	A                    int64    `protobuf:"varint,1,opt,name=a,proto3" json:"a,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Decimal64) Descriptor added in v0.6.0 

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

func (*Decimal64) GetA added in v0.6.0 

func (m *Decimal64) GetA() int64

func (*Decimal64) Marshal added in v0.6.0 

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

func (*Decimal64) MarshalTo added in v0.6.0 

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

func (*Decimal64) MarshalToSizedBuffer added in v0.6.0 

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

func (*Decimal64) ProtoMessage added in v0.6.0 

func (*Decimal64) ProtoMessage()

func (*Decimal64) ProtoSize added in v0.6.0 

func (m *Decimal64) ProtoSize() (n int)

func (*Decimal64) Reset added in v0.6.0 

func (m *Decimal64) Reset()

func (*Decimal64) String added in v0.6.0 

func (m *Decimal64) String() string

func (*Decimal64) Unmarshal added in v0.6.0 

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

func (*Decimal64) XXX_DiscardUnknown added in v0.6.0 

func (m *Decimal64) XXX_DiscardUnknown()

func (*Decimal64) XXX_Marshal added in v0.6.0 

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

func (*Decimal64) XXX_Merge added in v0.6.0 

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

func (*Decimal64) XXX_Size added in v0.6.0 

func (m *Decimal64) XXX_Size() int

func (*Decimal64) XXX_Unmarshal added in v0.6.0 

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

type Default added in v0.6.0 

type Default struct {
	Expr         *Expr  `protobuf:"bytes,1,opt,name=expr,proto3" json:"expr,omitempty"`
	OriginString string `protobuf:"bytes,2,opt,name=origin_string,json=originString,proto3" json:"origin_string,omitempty"`
	// XXX: Deprecated and to be removed soon.
	NullAbility          bool     `protobuf:"varint,3,opt,name=null_ability,json=nullAbility,proto3" json:"null_ability,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Default) Descriptor added in v0.6.0 

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

func (*Default) GetExpr added in v0.6.0 

func (m *Default) GetExpr() *Expr

func (*Default) GetNullAbility added in v0.6.0 

func (m *Default) GetNullAbility() bool

func (*Default) GetOriginString added in v0.6.0 

func (m *Default) GetOriginString() string

func (*Default) Marshal added in v0.6.0 

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

func (*Default) MarshalTo added in v0.6.0 

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

func (*Default) MarshalToSizedBuffer added in v0.6.0 

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

func (*Default) ProtoMessage added in v0.6.0 

func (*Default) ProtoMessage()

func (*Default) ProtoSize added in v0.6.0 

func (m *Default) ProtoSize() (n int)

func (*Default) Reset added in v0.6.0 

func (m *Default) Reset()

func (*Default) String added in v0.6.0 

func (m *Default) String() string

func (*Default) Unmarshal added in v0.6.0 

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

func (*Default) XXX_DiscardUnknown added in v0.6.0 

func (m *Default) XXX_DiscardUnknown()

func (*Default) XXX_Marshal added in v0.6.0 

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

func (*Default) XXX_Merge added in v0.6.0 

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

func (*Default) XXX_Size added in v0.6.0 

func (m *Default) XXX_Size() int

func (*Default) XXX_Unmarshal added in v0.6.0 

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

type DeleteCtx added in v0.7.0 

type DeleteCtx struct {
	Ref                  []*ObjectRef `protobuf:"bytes,1,rep,name=ref,proto3" json:"ref,omitempty"`
	IdxRef               []*ObjectRef `protobuf:"bytes,2,rep,name=idx_ref,json=idxRef,proto3" json:"idx_ref,omitempty"`
	IdxIdx               []int32      `protobuf:"varint,3,rep,packed,name=idx_idx,json=idxIdx,proto3" json:"idx_idx,omitempty"`
	OnRestrictRef        []*ObjectRef `protobuf:"bytes,4,rep,name=on_restrict_ref,json=onRestrictRef,proto3" json:"on_restrict_ref,omitempty"`
	OnRestrictIdx        []int32      `protobuf:"varint,5,rep,packed,name=on_restrict_idx,json=onRestrictIdx,proto3" json:"on_restrict_idx,omitempty"`
	OnCascadeRef         []*ObjectRef `protobuf:"bytes,6,rep,name=on_cascade_ref,json=onCascadeRef,proto3" json:"on_cascade_ref,omitempty"`
	OnCascadeIdx         []int32      `protobuf:"varint,7,rep,packed,name=on_cascade_idx,json=onCascadeIdx,proto3" json:"on_cascade_idx,omitempty"`
	OnSetRef             []*ObjectRef `protobuf:"bytes,8,rep,name=on_set_ref,json=onSetRef,proto3" json:"on_set_ref,omitempty"`
	OnSetDef             []*TableDef  `protobuf:"bytes,9,rep,name=on_set_def,json=onSetDef,proto3" json:"on_set_def,omitempty"`
	OnSetIdx             []*IdList    `protobuf:"bytes,10,rep,name=on_set_idx,json=onSetIdx,proto3" json:"on_set_idx,omitempty"`
	OnSetUpdateCol       []*ColPosMap `protobuf:"bytes,11,rep,name=on_set_update_col,json=onSetUpdateCol,proto3" json:"on_set_update_col,omitempty"`
	CanTruncate          bool         `protobuf:"varint,12,opt,name=can_truncate,json=canTruncate,proto3" json:"can_truncate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*DeleteCtx) Descriptor added in v0.7.0 

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

func (*DeleteCtx) GetCanTruncate added in v0.7.0 

func (m *DeleteCtx) GetCanTruncate() bool

func (*DeleteCtx) GetIdxIdx added in v0.7.0 

func (m *DeleteCtx) GetIdxIdx() []int32

func (*DeleteCtx) GetIdxRef added in v0.7.0 

func (m *DeleteCtx) GetIdxRef() []*ObjectRef

func (*DeleteCtx) GetOnCascadeIdx added in v0.7.0 

func (m *DeleteCtx) GetOnCascadeIdx() []int32

func (*DeleteCtx) GetOnCascadeRef added in v0.7.0 

func (m *DeleteCtx) GetOnCascadeRef() []*ObjectRef

func (*DeleteCtx) GetOnRestrictIdx added in v0.7.0 

func (m *DeleteCtx) GetOnRestrictIdx() []int32

func (*DeleteCtx) GetOnRestrictRef added in v0.7.0 

func (m *DeleteCtx) GetOnRestrictRef() []*ObjectRef

func (*DeleteCtx) GetOnSetDef added in v0.7.0 

func (m *DeleteCtx) GetOnSetDef() []*TableDef

func (*DeleteCtx) GetOnSetIdx added in v0.7.0 

func (m *DeleteCtx) GetOnSetIdx() []*IdList

func (*DeleteCtx) GetOnSetRef added in v0.7.0 

func (m *DeleteCtx) GetOnSetRef() []*ObjectRef

func (*DeleteCtx) GetOnSetUpdateCol added in v0.7.0 

func (m *DeleteCtx) GetOnSetUpdateCol() []*ColPosMap

func (*DeleteCtx) GetRef added in v0.7.0 

func (m *DeleteCtx) GetRef() []*ObjectRef

func (*DeleteCtx) Marshal added in v0.7.0 

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

func (*DeleteCtx) MarshalTo added in v0.7.0 

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

func (*DeleteCtx) MarshalToSizedBuffer added in v0.7.0 

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

func (*DeleteCtx) ProtoMessage added in v0.7.0 

func (*DeleteCtx) ProtoMessage()

func (*DeleteCtx) ProtoSize added in v0.7.0 

func (m *DeleteCtx) ProtoSize() (n int)

func (*DeleteCtx) Reset added in v0.7.0 

func (m *DeleteCtx) Reset()

func (*DeleteCtx) String added in v0.7.0 

func (m *DeleteCtx) String() string

func (*DeleteCtx) Unmarshal added in v0.7.0 

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

func (*DeleteCtx) XXX_DiscardUnknown added in v0.7.0 

func (m *DeleteCtx) XXX_DiscardUnknown()

func (*DeleteCtx) XXX_Marshal added in v0.7.0 

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

func (*DeleteCtx) XXX_Merge added in v0.7.0 

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

func (*DeleteCtx) XXX_Size added in v0.7.0 

func (m *DeleteCtx) XXX_Size() int

func (*DeleteCtx) XXX_Unmarshal added in v0.7.0 

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

type DropDatabase added in v0.5.0 

type DropDatabase struct {
	IfExists             bool     `protobuf:"varint,1,opt,name=if_exists,json=ifExists,proto3" json:"if_exists,omitempty"`
	Database             string   `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropDatabase) Descriptor added in v0.5.0 

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

func (*DropDatabase) GetDatabase added in v0.5.0 

func (m *DropDatabase) GetDatabase() string

func (*DropDatabase) GetIfExists added in v0.5.0 

func (m *DropDatabase) GetIfExists() bool

func (*DropDatabase) Marshal added in v0.5.0 

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

func (*DropDatabase) MarshalTo added in v0.5.0 

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

func (*DropDatabase) MarshalToSizedBuffer added in v0.5.0 

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

func (*DropDatabase) ProtoMessage added in v0.5.0 

func (*DropDatabase) ProtoMessage()

func (*DropDatabase) ProtoSize added in v0.5.0 

func (m *DropDatabase) ProtoSize() (n int)

func (*DropDatabase) Reset added in v0.5.0 

func (m *DropDatabase) Reset()

func (*DropDatabase) String added in v0.5.0 

func (m *DropDatabase) String() string

func (*DropDatabase) Unmarshal added in v0.5.0 

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

func (*DropDatabase) XXX_DiscardUnknown added in v0.5.0 

func (m *DropDatabase) XXX_DiscardUnknown()

func (*DropDatabase) XXX_Marshal added in v0.5.0 

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

func (*DropDatabase) XXX_Merge added in v0.5.0 

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

func (*DropDatabase) XXX_Size added in v0.5.0 

func (m *DropDatabase) XXX_Size() int

func (*DropDatabase) XXX_Unmarshal added in v0.5.0 

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

type DropIndex added in v0.5.0 

type DropIndex struct {
	Database             string   `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table                string   `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	IndexName            string   `protobuf:"bytes,3,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	IndexTableName       string   `protobuf:"bytes,4,opt,name=index_table_name,json=indexTableName,proto3" json:"index_table_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropIndex) Descriptor added in v0.5.0 

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

func (*DropIndex) GetDatabase added in v0.7.0 

func (m *DropIndex) GetDatabase() string

func (*DropIndex) GetIndexName added in v0.7.0 

func (m *DropIndex) GetIndexName() string

func (*DropIndex) GetIndexTableName added in v0.7.0 

func (m *DropIndex) GetIndexTableName() string

func (*DropIndex) GetTable added in v0.7.0 

func (m *DropIndex) GetTable() string

func (*DropIndex) Marshal added in v0.5.0 

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

func (*DropIndex) MarshalTo added in v0.5.0 

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

func (*DropIndex) MarshalToSizedBuffer added in v0.5.0 

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

func (*DropIndex) ProtoMessage added in v0.5.0 

func (*DropIndex) ProtoMessage()

func (*DropIndex) ProtoSize added in v0.5.0 

func (m *DropIndex) ProtoSize() (n int)

func (*DropIndex) Reset added in v0.5.0 

func (m *DropIndex) Reset()

func (*DropIndex) String added in v0.5.0 

func (m *DropIndex) String() string

func (*DropIndex) Unmarshal added in v0.5.0 

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

func (*DropIndex) XXX_DiscardUnknown added in v0.5.0 

func (m *DropIndex) XXX_DiscardUnknown()

func (*DropIndex) XXX_Marshal added in v0.5.0 

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

func (*DropIndex) XXX_Merge added in v0.5.0 

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

func (*DropIndex) XXX_Size added in v0.5.0 

func (m *DropIndex) XXX_Size() int

func (*DropIndex) XXX_Unmarshal added in v0.5.0 

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

type DropTable added in v0.5.0 

type DropTable struct {
	IfExists             bool          `protobuf:"varint,1,opt,name=if_exists,json=ifExists,proto3" json:"if_exists,omitempty"`
	Database             string        `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	Table                string        `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	IndexTableNames      []string      `protobuf:"bytes,4,rep,name=index_table_names,json=indexTableNames,proto3" json:"index_table_names,omitempty"`
	ClusterTable         *ClusterTable `protobuf:"bytes,5,opt,name=cluster_table,json=clusterTable,proto3" json:"cluster_table,omitempty"`
	TableId              uint64        `protobuf:"varint,6,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	ForeignTbl           []uint64      `protobuf:"varint,7,rep,packed,name=foreign_tbl,json=foreignTbl,proto3" json:"foreign_tbl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*DropTable) Descriptor added in v0.5.0 

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

func (*DropTable) GetClusterTable added in v0.7.0 

func (m *DropTable) GetClusterTable() *ClusterTable

func (*DropTable) GetDatabase added in v0.5.0 

func (m *DropTable) GetDatabase() string

func (*DropTable) GetForeignTbl added in v0.7.0 

func (m *DropTable) GetForeignTbl() []uint64

func (*DropTable) GetIfExists added in v0.5.0 

func (m *DropTable) GetIfExists() bool

func (*DropTable) GetIndexTableNames added in v0.6.0 

func (m *DropTable) GetIndexTableNames() []string

func (*DropTable) GetTable added in v0.5.0 

func (m *DropTable) GetTable() string

func (*DropTable) GetTableId added in v0.7.0 

func (m *DropTable) GetTableId() uint64

func (*DropTable) Marshal added in v0.5.0 

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

func (*DropTable) MarshalTo added in v0.5.0 

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

func (*DropTable) MarshalToSizedBuffer added in v0.5.0 

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

func (*DropTable) ProtoMessage added in v0.5.0 

func (*DropTable) ProtoMessage()

func (*DropTable) ProtoSize added in v0.5.0 

func (m *DropTable) ProtoSize() (n int)

func (*DropTable) Reset added in v0.5.0 

func (m *DropTable) Reset()

func (*DropTable) String added in v0.5.0 

func (m *DropTable) String() string

func (*DropTable) Unmarshal added in v0.5.0 

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

func (*DropTable) XXX_DiscardUnknown added in v0.5.0 

func (m *DropTable) XXX_DiscardUnknown()

func (*DropTable) XXX_Marshal added in v0.5.0 

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

func (*DropTable) XXX_Merge added in v0.5.0 

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

func (*DropTable) XXX_Size added in v0.5.0 

func (m *DropTable) XXX_Size() int

func (*DropTable) XXX_Unmarshal added in v0.5.0 

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

type Execute added in v0.5.1 

type Execute struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args                 []*Expr  `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Execute) Descriptor added in v0.5.1 

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

func (*Execute) GetArgs added in v0.5.1 

func (m *Execute) GetArgs() []*Expr

func (*Execute) GetName added in v0.5.1 

func (m *Execute) GetName() string

func (*Execute) Marshal added in v0.5.1 

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

func (*Execute) MarshalTo added in v0.5.1 

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

func (*Execute) MarshalToSizedBuffer added in v0.5.1 

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

func (*Execute) ProtoMessage added in v0.5.1 

func (*Execute) ProtoMessage()

func (*Execute) ProtoSize added in v0.5.1 

func (m *Execute) ProtoSize() (n int)

func (*Execute) Reset added in v0.5.1 

func (m *Execute) Reset()

func (*Execute) String added in v0.5.1 

func (m *Execute) String() string

func (*Execute) Unmarshal added in v0.5.1 

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

func (*Execute) XXX_DiscardUnknown added in v0.5.1 

func (m *Execute) XXX_DiscardUnknown()

func (*Execute) XXX_Marshal added in v0.5.1 

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

func (*Execute) XXX_Merge added in v0.5.1 

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

func (*Execute) XXX_Size added in v0.5.1 

func (m *Execute) XXX_Size() int

func (*Execute) XXX_Unmarshal added in v0.5.1 

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

type Expr 

type Expr struct {
	Typ *Type `protobuf:"bytes,1,opt,name=typ,proto3" json:"typ,omitempty"`
	// Types that are valid to be assigned to Expr:
	//
	//	*Expr_C
	//	*Expr_P
	//	*Expr_V
	//	*Expr_Col
	//	*Expr_Raw
	//	*Expr_F
	//	*Expr_Sub
	//	*Expr_Corr
	//	*Expr_T
	//	*Expr_List
	//	*Expr_Max
	Expr                 isExpr_Expr `protobuf_oneof:"expr"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Expr) Descriptor 

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

func (*Expr) GetC 

func (m *Expr) GetC() *Const

func (*Expr) GetCol 

func (m *Expr) GetCol() *ColRef

func (*Expr) GetCorr 

func (m *Expr) GetCorr() *CorrColRef

func (*Expr) GetExpr 

func (m *Expr) GetExpr() isExpr_Expr

func (*Expr) GetF 

func (m *Expr) GetF() *Function

func (*Expr) GetList 

func (m *Expr) GetList() *ExprList

func (*Expr) GetMax added in v0.6.0 

func (m *Expr) GetMax() *MaxValue

func (*Expr) GetP 

func (m *Expr) GetP() *ParamRef

func (*Expr) GetRaw added in v0.7.0 

func (m *Expr) GetRaw() *RawColRef

func (*Expr) GetSub 

func (m *Expr) GetSub() *SubqueryRef

func (*Expr) GetT added in v0.5.0 

func (m *Expr) GetT() *TargetType

func (*Expr) GetTyp 

func (m *Expr) GetTyp() *Type

func (*Expr) GetV 

func (m *Expr) GetV() *VarRef

func (*Expr) Marshal added in v0.5.0 

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

func (*Expr) MarshalTo added in v0.5.0 

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

func (*Expr) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr) ProtoMessage 

func (*Expr) ProtoMessage()

func (*Expr) ProtoSize added in v0.5.0 

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

func (*Expr) Reset 

func (m *Expr) Reset()

func (*Expr) String 

func (m *Expr) String() string

func (*Expr) Unmarshal added in v0.5.0 

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

func (*Expr) XXX_DiscardUnknown added in v0.5.0 

func (m *Expr) XXX_DiscardUnknown()

func (*Expr) XXX_Marshal added in v0.5.0 

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

func (*Expr) XXX_Merge added in v0.5.0 

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

func (*Expr) XXX_OneofWrappers added in v0.5.0 

func (*Expr) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Expr) XXX_Size added in v0.5.0 

func (m *Expr) XXX_Size() int

func (*Expr) XXX_Unmarshal added in v0.5.0 

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

type ExprList 

type ExprList struct {
	List                 []*Expr  `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ExprList is a type of Expr

func (*ExprList) Descriptor 

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

func (*ExprList) GetList 

func (m *ExprList) GetList() []*Expr

func (*ExprList) Marshal added in v0.5.0 

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

func (*ExprList) MarshalTo added in v0.5.0 

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

func (*ExprList) MarshalToSizedBuffer added in v0.5.0 

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

func (*ExprList) ProtoMessage 

func (*ExprList) ProtoMessage()

func (*ExprList) ProtoSize added in v0.5.0 

func (m *ExprList) ProtoSize() (n int)

func (*ExprList) Reset 

func (m *ExprList) Reset()

func (*ExprList) String 

func (m *ExprList) String() string

func (*ExprList) Unmarshal added in v0.5.0 

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

func (*ExprList) XXX_DiscardUnknown added in v0.5.0 

func (m *ExprList) XXX_DiscardUnknown()

func (*ExprList) XXX_Marshal added in v0.5.0 

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

func (*ExprList) XXX_Merge added in v0.5.0 

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

func (*ExprList) XXX_Size added in v0.5.0 

func (m *ExprList) XXX_Size() int

func (*ExprList) XXX_Unmarshal added in v0.5.0 

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

type Expr_C 

type Expr_C struct {
	C *Const `protobuf:"bytes,2,opt,name=c,proto3,oneof" json:"c,omitempty"`
}

func (*Expr_C) MarshalTo added in v0.5.0 

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

func (*Expr_C) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_C) ProtoSize added in v0.5.0 

func (m *Expr_C) ProtoSize() (n int)

type Expr_Col 

type Expr_Col struct {
	Col *ColRef `protobuf:"bytes,5,opt,name=col,proto3,oneof" json:"col,omitempty"`
}

func (*Expr_Col) MarshalTo added in v0.5.0 

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

func (*Expr_Col) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_Col) ProtoSize added in v0.5.0 

func (m *Expr_Col) ProtoSize() (n int)

type Expr_Corr 

type Expr_Corr struct {
	Corr *CorrColRef `protobuf:"bytes,9,opt,name=corr,proto3,oneof" json:"corr,omitempty"`
}

func (*Expr_Corr) MarshalTo added in v0.5.0 

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

func (*Expr_Corr) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_Corr) ProtoSize added in v0.5.0 

func (m *Expr_Corr) ProtoSize() (n int)

type Expr_F 

type Expr_F struct {
	F *Function `protobuf:"bytes,7,opt,name=f,proto3,oneof" json:"f,omitempty"`
}

func (*Expr_F) MarshalTo added in v0.5.0 

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

func (*Expr_F) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_F) ProtoSize added in v0.5.0 

func (m *Expr_F) ProtoSize() (n int)

type Expr_List 

type Expr_List struct {
	List *ExprList `protobuf:"bytes,11,opt,name=list,proto3,oneof" json:"list,omitempty"`
}

func (*Expr_List) MarshalTo added in v0.5.0 

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

func (*Expr_List) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_List) ProtoSize added in v0.5.0 

func (m *Expr_List) ProtoSize() (n int)

type Expr_Max added in v0.6.0 

type Expr_Max struct {
	Max *MaxValue `protobuf:"bytes,12,opt,name=max,proto3,oneof" json:"max,omitempty"`
}

func (*Expr_Max) MarshalTo added in v0.6.0 

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

func (*Expr_Max) MarshalToSizedBuffer added in v0.6.0 

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

func (*Expr_Max) ProtoSize added in v0.6.0 

func (m *Expr_Max) ProtoSize() (n int)

type Expr_P 

type Expr_P struct {
	P *ParamRef `protobuf:"bytes,3,opt,name=p,proto3,oneof" json:"p,omitempty"`
}

func (*Expr_P) MarshalTo added in v0.5.0 

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

func (*Expr_P) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_P) ProtoSize added in v0.5.0 

func (m *Expr_P) ProtoSize() (n int)

type Expr_Raw added in v0.7.0 

type Expr_Raw struct {
	Raw *RawColRef `protobuf:"bytes,6,opt,name=raw,proto3,oneof" json:"raw,omitempty"`
}

func (*Expr_Raw) MarshalTo added in v0.7.0 

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

func (*Expr_Raw) MarshalToSizedBuffer added in v0.7.0 

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

func (*Expr_Raw) ProtoSize added in v0.7.0 

func (m *Expr_Raw) ProtoSize() (n int)

type Expr_Sub 

type Expr_Sub struct {
	Sub *SubqueryRef `protobuf:"bytes,8,opt,name=sub,proto3,oneof" json:"sub,omitempty"`
}

func (*Expr_Sub) MarshalTo added in v0.5.0 

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

func (*Expr_Sub) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_Sub) ProtoSize added in v0.5.0 

func (m *Expr_Sub) ProtoSize() (n int)

type Expr_T added in v0.5.0 

type Expr_T struct {
	T *TargetType `protobuf:"bytes,10,opt,name=t,proto3,oneof" json:"t,omitempty"`
}

func (*Expr_T) MarshalTo added in v0.5.0 

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

func (*Expr_T) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_T) ProtoSize added in v0.5.0 

func (m *Expr_T) ProtoSize() (n int)

type Expr_V 

type Expr_V struct {
	V *VarRef `protobuf:"bytes,4,opt,name=v,proto3,oneof" json:"v,omitempty"`
}

func (*Expr_V) MarshalTo added in v0.5.0 

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

func (*Expr_V) MarshalToSizedBuffer added in v0.5.0 

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

func (*Expr_V) ProtoSize added in v0.5.0 

func (m *Expr_V) ProtoSize() (n int)

type ForeignKeyDef added in v0.7.0 

type ForeignKeyDef struct {
	Name                 string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Cols                 []uint64                `protobuf:"varint,2,rep,packed,name=cols,proto3" json:"cols,omitempty"`
	ForeignTbl           uint64                  `protobuf:"varint,3,opt,name=foreign_tbl,json=foreignTbl,proto3" json:"foreign_tbl,omitempty"`
	ForeignCols          []uint64                `protobuf:"varint,4,rep,packed,name=foreign_cols,json=foreignCols,proto3" json:"foreign_cols,omitempty"`
	OnDelete             ForeignKeyDef_RefAction `protobuf:"varint,5,opt,name=on_delete,json=onDelete,proto3,enum=plan.ForeignKeyDef_RefAction" json:"on_delete,omitempty"`
	OnUpdate             ForeignKeyDef_RefAction `protobuf:"varint,6,opt,name=on_update,json=onUpdate,proto3,enum=plan.ForeignKeyDef_RefAction" json:"on_update,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ForeignKeyDef) Descriptor added in v0.7.0 

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

func (*ForeignKeyDef) GetCols added in v0.7.0 

func (m *ForeignKeyDef) GetCols() []uint64

func (*ForeignKeyDef) GetForeignCols added in v0.7.0 

func (m *ForeignKeyDef) GetForeignCols() []uint64

func (*ForeignKeyDef) GetForeignTbl added in v0.7.0 

func (m *ForeignKeyDef) GetForeignTbl() uint64

func (*ForeignKeyDef) GetName added in v0.7.0 

func (m *ForeignKeyDef) GetName() string

func (*ForeignKeyDef) GetOnDelete added in v0.7.0 

func (m *ForeignKeyDef) GetOnDelete() ForeignKeyDef_RefAction

func (*ForeignKeyDef) GetOnUpdate added in v0.7.0 

func (m *ForeignKeyDef) GetOnUpdate() ForeignKeyDef_RefAction

func (*ForeignKeyDef) Marshal added in v0.7.0 

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

func (*ForeignKeyDef) MarshalTo added in v0.7.0 

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

func (*ForeignKeyDef) MarshalToSizedBuffer added in v0.7.0 

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

func (*ForeignKeyDef) ProtoMessage added in v0.7.0 

func (*ForeignKeyDef) ProtoMessage()

func (*ForeignKeyDef) ProtoSize added in v0.7.0 

func (m *ForeignKeyDef) ProtoSize() (n int)

func (*ForeignKeyDef) Reset added in v0.7.0 

func (m *ForeignKeyDef) Reset()

func (*ForeignKeyDef) String added in v0.7.0 

func (m *ForeignKeyDef) String() string

func (*ForeignKeyDef) Unmarshal added in v0.7.0 

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

func (*ForeignKeyDef) XXX_DiscardUnknown added in v0.7.0 

func (m *ForeignKeyDef) XXX_DiscardUnknown()

func (*ForeignKeyDef) XXX_Marshal added in v0.7.0 

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

func (*ForeignKeyDef) XXX_Merge added in v0.7.0 

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

func (*ForeignKeyDef) XXX_Size added in v0.7.0 

func (m *ForeignKeyDef) XXX_Size() int

func (*ForeignKeyDef) XXX_Unmarshal added in v0.7.0 

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

type ForeignKeyDef_RefAction added in v0.7.0 

type ForeignKeyDef_RefAction int32
const (
	ForeignKeyDef_RESTRICT    ForeignKeyDef_RefAction = 0
	ForeignKeyDef_CASCADE     ForeignKeyDef_RefAction = 1
	ForeignKeyDef_SET_NULL    ForeignKeyDef_RefAction = 2
	ForeignKeyDef_SET_DEFAULT ForeignKeyDef_RefAction = 3
	ForeignKeyDef_NO_ACTION   ForeignKeyDef_RefAction = 4
)

func (ForeignKeyDef_RefAction) EnumDescriptor added in v0.7.0 

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

func (ForeignKeyDef_RefAction) String added in v0.7.0 

func (x ForeignKeyDef_RefAction) String() string

type Function 

type Function struct {
	Func                 *ObjectRef `protobuf:"bytes,1,opt,name=func,proto3" json:"func,omitempty"`
	Args                 []*Expr    `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Function) Descriptor 

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

func (*Function) GetArgs 

func (m *Function) GetArgs() []*Expr

func (*Function) GetFunc 

func (m *Function) GetFunc() *ObjectRef

func (*Function) Marshal added in v0.5.0 

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

func (*Function) MarshalTo added in v0.5.0 

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

func (*Function) MarshalToSizedBuffer added in v0.5.0 

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

func (*Function) ProtoMessage 

func (*Function) ProtoMessage()

func (*Function) ProtoSize added in v0.5.0 

func (m *Function) ProtoSize() (n int)

func (*Function) Reset 

func (m *Function) Reset()

func (*Function) String 

func (m *Function) String() string

func (*Function) Unmarshal added in v0.5.0 

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

func (*Function) XXX_DiscardUnknown added in v0.5.0 

func (m *Function) XXX_DiscardUnknown()

func (*Function) XXX_Marshal added in v0.5.0 

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

func (*Function) XXX_Merge added in v0.5.0 

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

func (*Function) XXX_Size added in v0.5.0 

func (m *Function) XXX_Size() int

func (*Function) XXX_Unmarshal added in v0.5.0 

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

type Function_FuncFlag 

type Function_FuncFlag int32

Function flags 

const (
	Function_NONE Function_FuncFlag = 0
	// Internal function is generated by system, cannot
	// by called by user.
	Function_INTERNAL Function_FuncFlag = 1
	// Function, by default is immutable.
	Function_STABLE   Function_FuncFlag = 2
	Function_VOLATILE Function_FuncFlag = 4
	// Nulls
	Function_STRICT          Function_FuncFlag = 8
	Function_PRODUCE_NULL    Function_FuncFlag = 16
	Function_PRODUCE_NO_NULL Function_FuncFlag = 32
	// Vararg, all trailing args must be of the same type.
	Function_VARARG Function_FuncFlag = 64
	// Window and Agg
	Function_AGG Function_FuncFlag = 128
	Function_WIN Function_FuncFlag = 256
	// Monotonic function can filter by zonemap
	Function_MONOTONIC Function_FuncFlag = 512
)

func (Function_FuncFlag) EnumDescriptor 

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

func (Function_FuncFlag) String 

func (x Function_FuncFlag) String() string

type IdList added in v0.7.0 

type IdList struct {
	List                 []int64  `protobuf:"varint,1,rep,packed,name=list,proto3" json:"list,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IdList) Descriptor added in v0.7.0 

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

func (*IdList) GetList added in v0.7.0 

func (m *IdList) GetList() []int64

func (*IdList) Marshal added in v0.7.0 

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

func (*IdList) MarshalTo added in v0.7.0 

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

func (*IdList) MarshalToSizedBuffer added in v0.7.0 

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

func (*IdList) ProtoMessage added in v0.7.0 

func (*IdList) ProtoMessage()

func (*IdList) ProtoSize added in v0.7.0 

func (m *IdList) ProtoSize() (n int)

func (*IdList) Reset added in v0.7.0 

func (m *IdList) Reset()

func (*IdList) String added in v0.7.0 

func (m *IdList) String() string

func (*IdList) Unmarshal added in v0.7.0 

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

func (*IdList) XXX_DiscardUnknown added in v0.7.0 

func (m *IdList) XXX_DiscardUnknown()

func (*IdList) XXX_Marshal added in v0.7.0 

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

func (*IdList) XXX_Merge added in v0.7.0 

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

func (*IdList) XXX_Size added in v0.7.0 

func (m *IdList) XXX_Size() int

func (*IdList) XXX_Unmarshal added in v0.7.0 

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

type IndexDef added in v0.5.0 

type IndexDef struct {
	// Generate UUID for each index, currently not used
	IdxId     string `protobuf:"bytes,1,opt,name=idx_id,json=idxId,proto3" json:"idx_id,omitempty"`
	IndexName string `protobuf:"bytes,2,opt,name=index_name,json=indexName,proto3" json:"index_name,omitempty"`
	// The constituent columns of the index
	Parts          []string `protobuf:"bytes,3,rep,name=parts,proto3" json:"parts,omitempty"`
	Unique         bool     `protobuf:"varint,4,opt,name=unique,proto3" json:"unique,omitempty"`
	IndexTableName string   `protobuf:"bytes,5,opt,name=index_table_name,json=indexTableName,proto3" json:"index_table_name,omitempty"`
	TableExist     bool     `protobuf:"varint,6,opt,name=table_exist,json=tableExist,proto3" json:"table_exist,omitempty"`
	Comment        string   `protobuf:"bytes,7,opt,name=comment,proto3" json:"comment,omitempty"`
	// currently not used
	Option               *IndexOption `protobuf:"bytes,8,opt,name=option,proto3" json:"option,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*IndexDef) Descriptor added in v0.5.0 

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

func (*IndexDef) GetComment added in v0.7.0 

func (m *IndexDef) GetComment() string

func (*IndexDef) GetIdxId added in v0.7.0 

func (m *IndexDef) GetIdxId() string

func (*IndexDef) GetIndexName added in v0.7.0 

func (m *IndexDef) GetIndexName() string

func (*IndexDef) GetIndexTableName added in v0.7.0 

func (m *IndexDef) GetIndexTableName() string

func (*IndexDef) GetOption added in v0.7.0 

func (m *IndexDef) GetOption() *IndexOption

func (*IndexDef) GetParts added in v0.7.0 

func (m *IndexDef) GetParts() []string

func (*IndexDef) GetTableExist added in v0.7.0 

func (m *IndexDef) GetTableExist() bool

func (*IndexDef) GetUnique added in v0.7.0 

func (m *IndexDef) GetUnique() bool

func (*IndexDef) Marshal added in v0.5.0 

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

func (*IndexDef) MarshalTo added in v0.5.0 

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

func (*IndexDef) MarshalToSizedBuffer added in v0.5.0 

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

func (*IndexDef) ProtoMessage added in v0.5.0 

func (*IndexDef) ProtoMessage()

func (*IndexDef) ProtoSize added in v0.5.0 

func (m *IndexDef) ProtoSize() (n int)

func (*IndexDef) Reset added in v0.5.0 

func (m *IndexDef) Reset()

func (*IndexDef) String added in v0.5.0 

func (m *IndexDef) String() string

func (*IndexDef) Unmarshal added in v0.5.0 

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

func (*IndexDef) XXX_DiscardUnknown added in v0.5.0 

func (m *IndexDef) XXX_DiscardUnknown()

func (*IndexDef) XXX_Marshal added in v0.5.0 

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

func (*IndexDef) XXX_Merge added in v0.5.0 

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

func (*IndexDef) XXX_Size added in v0.5.0 

func (m *IndexDef) XXX_Size() int

func (*IndexDef) XXX_Unmarshal added in v0.5.0 

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

type IndexOption added in v0.7.0 

type IndexOption struct {
	CreateExtraTable     bool     `protobuf:"varint,1,opt,name=create_extra_table,json=createExtraTable,proto3" json:"create_extra_table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexOption) Descriptor added in v0.7.0 

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

func (*IndexOption) GetCreateExtraTable added in v0.7.0 

func (m *IndexOption) GetCreateExtraTable() bool

func (*IndexOption) Marshal added in v0.7.0 

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

func (*IndexOption) MarshalTo added in v0.7.0 

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

func (*IndexOption) MarshalToSizedBuffer added in v0.7.0 

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

func (*IndexOption) ProtoMessage added in v0.7.0 

func (*IndexOption) ProtoMessage()

func (*IndexOption) ProtoSize added in v0.7.0 

func (m *IndexOption) ProtoSize() (n int)

func (*IndexOption) Reset added in v0.7.0 

func (m *IndexOption) Reset()

func (*IndexOption) String added in v0.7.0 

func (m *IndexOption) String() string

func (*IndexOption) Unmarshal added in v0.7.0 

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

func (*IndexOption) XXX_DiscardUnknown added in v0.7.0 

func (m *IndexOption) XXX_DiscardUnknown()

func (*IndexOption) XXX_Marshal added in v0.7.0 

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

func (*IndexOption) XXX_Merge added in v0.7.0 

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

func (*IndexOption) XXX_Size added in v0.7.0 

func (m *IndexOption) XXX_Size() int

func (*IndexOption) XXX_Unmarshal added in v0.7.0 

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

type InsertCtx added in v0.7.0 

type InsertCtx struct {
	Ref                  *ObjectRef       `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Idx                  []int32          `protobuf:"varint,2,rep,packed,name=idx,proto3" json:"idx,omitempty"`
	TableDef             *TableDef        `protobuf:"bytes,3,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
	ParentIdx            map[string]int32 `` /* 177-byte string literal not displayed */
	ClusterTable         *ClusterTable    `protobuf:"bytes,5,opt,name=cluster_table,json=clusterTable,proto3" json:"cluster_table,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*InsertCtx) Descriptor added in v0.7.0 

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

func (*InsertCtx) GetClusterTable added in v0.7.0 

func (m *InsertCtx) GetClusterTable() *ClusterTable

func (*InsertCtx) GetIdx added in v0.7.0 

func (m *InsertCtx) GetIdx() []int32

func (*InsertCtx) GetParentIdx added in v0.7.0 

func (m *InsertCtx) GetParentIdx() map[string]int32

func (*InsertCtx) GetRef added in v0.7.0 

func (m *InsertCtx) GetRef() *ObjectRef

func (*InsertCtx) GetTableDef added in v0.7.0 

func (m *InsertCtx) GetTableDef() *TableDef

func (*InsertCtx) Marshal added in v0.7.0 

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

func (*InsertCtx) MarshalTo added in v0.7.0 

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

func (*InsertCtx) MarshalToSizedBuffer added in v0.7.0 

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

func (*InsertCtx) ProtoMessage added in v0.7.0 

func (*InsertCtx) ProtoMessage()

func (*InsertCtx) ProtoSize added in v0.7.0 

func (m *InsertCtx) ProtoSize() (n int)

func (*InsertCtx) Reset added in v0.7.0 

func (m *InsertCtx) Reset()

func (*InsertCtx) String added in v0.7.0 

func (m *InsertCtx) String() string

func (*InsertCtx) Unmarshal added in v0.7.0 

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

func (*InsertCtx) XXX_DiscardUnknown added in v0.7.0 

func (m *InsertCtx) XXX_DiscardUnknown()

func (*InsertCtx) XXX_Marshal added in v0.7.0 

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

func (*InsertCtx) XXX_Merge added in v0.7.0 

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

func (*InsertCtx) XXX_Size added in v0.7.0 

func (m *InsertCtx) XXX_Size() int

func (*InsertCtx) XXX_Unmarshal added in v0.7.0 

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

type MaxValue added in v0.6.0 

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

func (*MaxValue) Descriptor added in v0.6.0 

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

func (*MaxValue) GetValue added in v0.6.0 

func (m *MaxValue) GetValue() string

func (*MaxValue) Marshal added in v0.6.0 

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

func (*MaxValue) MarshalTo added in v0.6.0 

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

func (*MaxValue) MarshalToSizedBuffer added in v0.6.0 

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

func (*MaxValue) ProtoMessage added in v0.6.0 

func (*MaxValue) ProtoMessage()

func (*MaxValue) ProtoSize added in v0.6.0 

func (m *MaxValue) ProtoSize() (n int)

func (*MaxValue) Reset added in v0.6.0 

func (m *MaxValue) Reset()

func (*MaxValue) String added in v0.6.0 

func (m *MaxValue) String() string

func (*MaxValue) Unmarshal added in v0.6.0 

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

func (*MaxValue) XXX_DiscardUnknown added in v0.6.0 

func (m *MaxValue) XXX_DiscardUnknown()

func (*MaxValue) XXX_Marshal added in v0.6.0 

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

func (*MaxValue) XXX_Merge added in v0.6.0 

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

func (*MaxValue) XXX_Size added in v0.6.0 

func (m *MaxValue) XXX_Size() int

func (*MaxValue) XXX_Unmarshal added in v0.6.0 

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

type Node 

type Node struct {
	NodeType        Node_NodeType  `protobuf:"varint,1,opt,name=node_type,json=nodeType,proto3,enum=plan.Node_NodeType" json:"node_type,omitempty"`
	NodeId          int32          `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Stats           *Stats         `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
	ProjectList     []*Expr        `protobuf:"bytes,4,rep,name=project_list,json=projectList,proto3" json:"project_list,omitempty"`
	Children        []int32        `protobuf:"varint,5,rep,packed,name=children,proto3" json:"children,omitempty"`
	JoinType        Node_JoinFlag  `protobuf:"varint,6,opt,name=join_type,json=joinType,proto3,enum=plan.Node_JoinFlag" json:"join_type,omitempty"`
	OnList          []*Expr        `protobuf:"bytes,7,rep,name=on_list,json=onList,proto3" json:"on_list,omitempty"`
	FilterList      []*Expr        `protobuf:"bytes,8,rep,name=filter_list,json=filterList,proto3" json:"filter_list,omitempty"`
	GroupBy         []*Expr        `protobuf:"bytes,9,rep,name=group_by,json=groupBy,proto3" json:"group_by,omitempty"`
	GroupingSet     []*Expr        `protobuf:"bytes,10,rep,name=grouping_set,json=groupingSet,proto3" json:"grouping_set,omitempty"`
	AggList         []*Expr        `protobuf:"bytes,11,rep,name=agg_list,json=aggList,proto3" json:"agg_list,omitempty"`
	OrderBy         []*OrderBySpec `protobuf:"bytes,12,rep,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	UpdateCtx       *UpdateCtx     `protobuf:"bytes,13,opt,name=update_ctx,json=updateCtx,proto3" json:"update_ctx,omitempty"`
	WinSpec         *WindowSpec    `protobuf:"bytes,14,opt,name=win_spec,json=winSpec,proto3" json:"win_spec,omitempty"`
	Limit           *Expr          `protobuf:"bytes,15,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset          *Expr          `protobuf:"bytes,16,opt,name=offset,proto3" json:"offset,omitempty"`
	TableDef        *TableDef      `protobuf:"bytes,17,opt,name=table_def,json=tableDef,proto3" json:"table_def,omitempty"`
	TableDefVec     []*TableDef    `protobuf:"bytes,18,rep,name=table_def_vec,json=tableDefVec,proto3" json:"table_def_vec,omitempty"`
	ObjRef          *ObjectRef     `protobuf:"bytes,19,opt,name=obj_ref,json=objRef,proto3" json:"obj_ref,omitempty"`
	RowsetData      *RowsetData    `protobuf:"bytes,20,opt,name=rowset_data,json=rowsetData,proto3" json:"rowset_data,omitempty"`
	ExtraOptions    string         `protobuf:"bytes,21,opt,name=extra_options,json=extraOptions,proto3" json:"extra_options,omitempty"`
	DeleteCtx       *DeleteCtx     `protobuf:"bytes,22,opt,name=delete_ctx,json=deleteCtx,proto3" json:"delete_ctx,omitempty"`
	BindingTags     []int32        `protobuf:"varint,23,rep,packed,name=binding_tags,json=bindingTags,proto3" json:"binding_tags,omitempty"`
	AnalyzeInfo     *AnalyzeInfo   `protobuf:"bytes,24,opt,name=analyze_info,json=analyzeInfo,proto3" json:"analyze_info,omitempty"`
	TblFuncExprList []*Expr        `protobuf:"bytes,25,rep,name=tbl_func_expr_list,json=tblFuncExprList,proto3" json:"tbl_func_expr_list,omitempty"`
	// The pipeline will determine the parallelism by traversing the plan
	// when it is received. Then the build is built based on this information.
	Parallelism          int32         `protobuf:"varint,26,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	ClusterTable         *ClusterTable `protobuf:"bytes,27,opt,name=cluster_table,json=clusterTable,proto3" json:"cluster_table,omitempty"`
	NotCacheable         bool          `protobuf:"varint,28,opt,name=not_cacheable,json=notCacheable,proto3" json:"not_cacheable,omitempty"`
	InsertCtx            *InsertCtx    `protobuf:"bytes,29,opt,name=insert_ctx,json=insertCtx,proto3" json:"insert_ctx,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetAggList added in v0.5.0 

func (m *Node) GetAggList() []*Expr

func (*Node) GetAnalyzeInfo added in v0.6.0 

func (m *Node) GetAnalyzeInfo() *AnalyzeInfo

func (*Node) GetBindingTags added in v0.5.0 

func (m *Node) GetBindingTags() []int32

func (*Node) GetChildren 

func (m *Node) GetChildren() []int32

func (*Node) GetClusterTable added in v0.7.0 

func (m *Node) GetClusterTable() *ClusterTable

func (*Node) GetDeleteCtx added in v0.7.0 

func (m *Node) GetDeleteCtx() *DeleteCtx

func (*Node) GetExtraOptions 

func (m *Node) GetExtraOptions() string

func (*Node) GetFilterList added in v0.5.0 

func (m *Node) GetFilterList() []*Expr

func (*Node) GetGroupBy 

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

func (*Node) GetGroupingSet 

func (m *Node) GetGroupingSet() []*Expr

func (*Node) GetInsertCtx added in v0.7.0 

func (m *Node) GetInsertCtx() *InsertCtx

func (*Node) GetJoinType 

func (m *Node) GetJoinType() Node_JoinFlag

func (*Node) GetLimit 

func (m *Node) GetLimit() *Expr

func (*Node) GetNodeId 

func (m *Node) GetNodeId() int32

func (*Node) GetNodeType 

func (m *Node) GetNodeType() Node_NodeType

func (*Node) GetNotCacheable added in v0.7.0 

func (m *Node) GetNotCacheable() bool

func (*Node) GetObjRef 

func (m *Node) GetObjRef() *ObjectRef

func (*Node) GetOffset 

func (m *Node) GetOffset() *Expr

func (*Node) GetOnList 

func (m *Node) GetOnList() []*Expr

func (*Node) GetOrderBy 

func (m *Node) GetOrderBy() []*OrderBySpec

func (*Node) GetParallelism added in v0.7.0 

func (m *Node) GetParallelism() int32

func (*Node) GetProjectList 

func (m *Node) GetProjectList() []*Expr

func (*Node) GetRowsetData 

func (m *Node) GetRowsetData() *RowsetData

func (*Node) GetStats added in v0.7.0 

func (m *Node) GetStats() *Stats

func (*Node) GetTableDef 

func (m *Node) GetTableDef() *TableDef

func (*Node) GetTableDefVec added in v0.6.0 

func (m *Node) GetTableDefVec() []*TableDef

func (*Node) GetTblFuncExprList added in v0.6.0 

func (m *Node) GetTblFuncExprList() []*Expr

func (*Node) GetUpdateCtx added in v0.7.0 

func (m *Node) GetUpdateCtx() *UpdateCtx

func (*Node) GetWinSpec 

func (m *Node) GetWinSpec() *WindowSpec

func (*Node) Marshal added in v0.5.0 

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

func (*Node) MarshalTo added in v0.5.0 

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

func (*Node) MarshalToSizedBuffer added in v0.5.0 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoSize added in v0.5.0 

func (m *Node) ProtoSize() (n int)

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal added in v0.5.0 

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

func (*Node) XXX_DiscardUnknown added in v0.5.0 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal added in v0.5.0 

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

func (*Node) XXX_Merge added in v0.5.0 

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

func (*Node) XXX_Size added in v0.5.0 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal added in v0.5.0 

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

type Node_AggMode 

type Node_AggMode int32
const (
	Node_FULL   Node_AggMode = 0
	Node_BOTTOM Node_AggMode = 1
	Node_TOP    Node_AggMode = 2
)

func (Node_AggMode) EnumDescriptor 

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

func (Node_AggMode) String 

func (x Node_AggMode) String() string

type Node_JoinFlag 

type Node_JoinFlag int32
const (
	Node_INNER  Node_JoinFlag = 0
	Node_LEFT   Node_JoinFlag = 1
	Node_RIGHT  Node_JoinFlag = 2
	Node_OUTER  Node_JoinFlag = 3
	Node_SEMI   Node_JoinFlag = 4
	Node_ANTI   Node_JoinFlag = 5
	Node_SINGLE Node_JoinFlag = 6
	Node_MARK   Node_JoinFlag = 7
	Node_APPLY  Node_JoinFlag = 8
)

func (Node_JoinFlag) EnumDescriptor 

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

func (Node_JoinFlag) String 

func (x Node_JoinFlag) String() string

type Node_NodeType 

type Node_NodeType int32
const (
	Node_UNKNOWN Node_NodeType = 0
	// Scans
	Node_VALUE_SCAN    Node_NodeType = 1
	Node_TABLE_SCAN    Node_NodeType = 2
	Node_FUNCTION_SCAN Node_NodeType = 3
	Node_EXTERNAL_SCAN Node_NodeType = 4
	Node_MATERIAL_SCAN Node_NodeType = 5
	// Proj, for convenience
	Node_PROJECT Node_NodeType = 10
	// External function call (UDF)
	Node_EXTERNAL_FUNCTION Node_NodeType = 11
	// Material, CTE, etc.
	Node_MATERIAL      Node_NodeType = 20
	Node_RECURSIVE_CTE Node_NodeType = 21
	Node_SINK          Node_NodeType = 22
	Node_SINK_SCAN     Node_NodeType = 23
	// Proper Relational Operators
	Node_AGG       Node_NodeType = 30
	Node_DISTINCT  Node_NodeType = 31
	Node_FILTER    Node_NodeType = 32
	Node_JOIN      Node_NodeType = 33
	Node_SAMPLE    Node_NodeType = 34
	Node_SORT      Node_NodeType = 35
	Node_UNION     Node_NodeType = 36
	Node_UNION_ALL Node_NodeType = 37
	Node_UNIQUE    Node_NodeType = 38
	Node_WINDOW    Node_NodeType = 39
	// Physical tuple mover
	Node_BROADCAST Node_NodeType = 40
	Node_SPLIT     Node_NodeType = 41
	Node_GATHER    Node_NodeType = 42
	// Misc
	Node_ASSERT Node_NodeType = 50
	//
	Node_INSERT Node_NodeType = 51
	Node_UPDATE Node_NodeType = 52
	Node_DELETE Node_NodeType = 53
	//
	Node_INTERSECT     Node_NodeType = 54
	Node_INTERSECT_ALL Node_NodeType = 55
	Node_MINUS         Node_NodeType = 56
	Node_MINUS_ALL     Node_NodeType = 57
)

func (Node_NodeType) EnumDescriptor 

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

func (Node_NodeType) String 

func (x Node_NodeType) String() string

type ObjectRef 

type ObjectRef struct {
	Server               int64    `protobuf:"varint,1,opt,name=server,proto3" json:"server,omitempty"`
	Db                   int64    `protobuf:"varint,2,opt,name=db,proto3" json:"db,omitempty"`
	Schema               int64    `protobuf:"varint,3,opt,name=schema,proto3" json:"schema,omitempty"`
	Obj                  int64    `protobuf:"varint,4,opt,name=obj,proto3" json:"obj,omitempty"`
	ServerName           string   `protobuf:"bytes,5,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	DbName               string   `protobuf:"bytes,6,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	SchemaName           string   `protobuf:"bytes,7,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	ObjName              string   `protobuf:"bytes,8,opt,name=obj_name,json=objName,proto3" json:"obj_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Object ref, reference a object in database, 4 part name.

func (*ObjectRef) Descriptor 

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

func (*ObjectRef) GetDb 

func (m *ObjectRef) GetDb() int64

func (*ObjectRef) GetDbName 

func (m *ObjectRef) GetDbName() string

func (*ObjectRef) GetObj 

func (m *ObjectRef) GetObj() int64

func (*ObjectRef) GetObjName 

func (m *ObjectRef) GetObjName() string

func (*ObjectRef) GetSchema 

func (m *ObjectRef) GetSchema() int64

func (*ObjectRef) GetSchemaName 

func (m *ObjectRef) GetSchemaName() string

func (*ObjectRef) GetServer 

func (m *ObjectRef) GetServer() int64

func (*ObjectRef) GetServerName 

func (m *ObjectRef) GetServerName() string

func (*ObjectRef) Marshal added in v0.5.0 

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

func (*ObjectRef) MarshalTo added in v0.5.0 

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

func (*ObjectRef) MarshalToSizedBuffer added in v0.5.0 

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

func (*ObjectRef) ProtoMessage 

func (*ObjectRef) ProtoMessage()

func (*ObjectRef) ProtoSize added in v0.5.0 

func (m *ObjectRef) ProtoSize() (n int)

func (*ObjectRef) Reset 

func (m *ObjectRef) Reset()

func (*ObjectRef) String 

func (m *ObjectRef) String() string

func (*ObjectRef) Unmarshal added in v0.5.0 

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

func (*ObjectRef) XXX_DiscardUnknown added in v0.5.0 

func (m *ObjectRef) XXX_DiscardUnknown()

func (*ObjectRef) XXX_Marshal added in v0.5.0 

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

func (*ObjectRef) XXX_Merge added in v0.5.0 

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

func (*ObjectRef) XXX_Size added in v0.5.0 

func (m *ObjectRef) XXX_Size() int

func (*ObjectRef) XXX_Unmarshal added in v0.5.0 

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

type OnUpdate added in v0.6.0 

type OnUpdate struct {
	Expr                 *Expr    `protobuf:"bytes,1,opt,name=expr,proto3" json:"expr,omitempty"`
	OriginString         string   `protobuf:"bytes,2,opt,name=origin_string,json=originString,proto3" json:"origin_string,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OnUpdate) Descriptor added in v0.6.0 

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

func (*OnUpdate) GetExpr added in v0.6.0 

func (m *OnUpdate) GetExpr() *Expr

func (*OnUpdate) GetOriginString added in v0.6.0 

func (m *OnUpdate) GetOriginString() string

func (*OnUpdate) Marshal added in v0.6.0 

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

func (*OnUpdate) MarshalTo added in v0.6.0 

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

func (*OnUpdate) MarshalToSizedBuffer added in v0.6.0 

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

func (*OnUpdate) ProtoMessage added in v0.6.0 

func (*OnUpdate) ProtoMessage()

func (*OnUpdate) ProtoSize added in v0.6.0 

func (m *OnUpdate) ProtoSize() (n int)

func (*OnUpdate) Reset added in v0.6.0 

func (m *OnUpdate) Reset()

func (*OnUpdate) String added in v0.6.0 

func (m *OnUpdate) String() string

func (*OnUpdate) Unmarshal added in v0.6.0 

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

func (*OnUpdate) XXX_DiscardUnknown added in v0.6.0 

func (m *OnUpdate) XXX_DiscardUnknown()

func (*OnUpdate) XXX_Marshal added in v0.6.0 

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

func (*OnUpdate) XXX_Merge added in v0.6.0 

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

func (*OnUpdate) XXX_Size added in v0.6.0 

func (m *OnUpdate) XXX_Size() int

func (*OnUpdate) XXX_Unmarshal added in v0.6.0 

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

type OrderBySpec 

type OrderBySpec struct {
	Expr                 *Expr                   `protobuf:"bytes,1,opt,name=expr,proto3" json:"expr,omitempty"`
	Collation            string                  `protobuf:"bytes,2,opt,name=collation,proto3" json:"collation,omitempty"`
	Flag                 OrderBySpec_OrderByFlag `protobuf:"varint,3,opt,name=flag,proto3,enum=plan.OrderBySpec_OrderByFlag" json:"flag,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*OrderBySpec) Descriptor 

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

func (*OrderBySpec) GetCollation added in v0.5.0 

func (m *OrderBySpec) GetCollation() string

func (*OrderBySpec) GetExpr added in v0.5.0 

func (m *OrderBySpec) GetExpr() *Expr

func (*OrderBySpec) GetFlag added in v0.5.0 

func (m *OrderBySpec) GetFlag() OrderBySpec_OrderByFlag

func (*OrderBySpec) Marshal added in v0.5.0 

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

func (*OrderBySpec) MarshalTo added in v0.5.0 

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

func (*OrderBySpec) MarshalToSizedBuffer added in v0.5.0 

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

func (*OrderBySpec) ProtoMessage 

func (*OrderBySpec) ProtoMessage()

func (*OrderBySpec) ProtoSize added in v0.5.0 

func (m *OrderBySpec) ProtoSize() (n int)

func (*OrderBySpec) Reset 

func (m *OrderBySpec) Reset()

func (*OrderBySpec) String 

func (m *OrderBySpec) String() string

func (*OrderBySpec) Unmarshal added in v0.5.0 

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

func (*OrderBySpec) XXX_DiscardUnknown added in v0.5.0 

func (m *OrderBySpec) XXX_DiscardUnknown()

func (*OrderBySpec) XXX_Marshal added in v0.5.0 

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

func (*OrderBySpec) XXX_Merge added in v0.5.0 

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

func (*OrderBySpec) XXX_Size added in v0.5.0 

func (m *OrderBySpec) XXX_Size() int

func (*OrderBySpec) XXX_Unmarshal added in v0.5.0 

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

type OrderBySpec_OrderByFlag 

type OrderBySpec_OrderByFlag int32
const (
	OrderBySpec_INTERNAL    OrderBySpec_OrderByFlag = 0
	OrderBySpec_ASC         OrderBySpec_OrderByFlag = 1
	OrderBySpec_DESC        OrderBySpec_OrderByFlag = 2
	OrderBySpec_NULLS_FIRST OrderBySpec_OrderByFlag = 4
	OrderBySpec_NULLS_LAST  OrderBySpec_OrderByFlag = 8
	OrderBySpec_UNIQUE      OrderBySpec_OrderByFlag = 16
)

func (OrderBySpec_OrderByFlag) EnumDescriptor 

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

func (OrderBySpec_OrderByFlag) String 

func (x OrderBySpec_OrderByFlag) String() string

type ParamRef 

type ParamRef struct {
	Pos                  int32    `protobuf:"varint,1,opt,name=pos,proto3" json:"pos,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Bounded param for prepared statement. User fill on execution.

func (*ParamRef) Descriptor 

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

func (*ParamRef) GetPos 

func (m *ParamRef) GetPos() int32

func (*ParamRef) Marshal added in v0.5.0 

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

func (*ParamRef) MarshalTo added in v0.5.0 

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

func (*ParamRef) MarshalToSizedBuffer added in v0.5.0 

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

func (*ParamRef) ProtoMessage 

func (*ParamRef) ProtoMessage()

func (*ParamRef) ProtoSize added in v0.5.0 

func (m *ParamRef) ProtoSize() (n int)

func (*ParamRef) Reset 

func (m *ParamRef) Reset()

func (*ParamRef) String 

func (m *ParamRef) String() string

func (*ParamRef) Unmarshal added in v0.5.0 

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

func (*ParamRef) XXX_DiscardUnknown added in v0.5.0 

func (m *ParamRef) XXX_DiscardUnknown()

func (*ParamRef) XXX_Marshal added in v0.5.0 

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

func (*ParamRef) XXX_Merge added in v0.5.0 

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

func (*ParamRef) XXX_Size added in v0.5.0 

func (m *ParamRef) XXX_Size() int

func (*ParamRef) XXX_Unmarshal added in v0.5.0 

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

type PartitionByDef added in v0.7.0 

type PartitionByDef struct {
	Type                 PartitionType     `protobuf:"varint,1,opt,name=type,proto3,enum=plan.PartitionType" json:"type,omitempty"`
	PartitionExpr        *PartitionExpr    `protobuf:"bytes,2,opt,name=partition_expr,json=partitionExpr,proto3" json:"partition_expr,omitempty"`
	PartitionExpression  *Expr             `protobuf:"bytes,3,opt,name=partition_expression,json=partitionExpression,proto3" json:"partition_expression,omitempty"`
	PartitionColumns     *PartitionColumns `protobuf:"bytes,4,opt,name=partition_columns,json=partitionColumns,proto3" json:"partition_columns,omitempty"`
	PartitionNum         uint64            `protobuf:"varint,5,opt,name=partitionNum,proto3" json:"partitionNum,omitempty"`
	Partitions           []*PartitionItem  `protobuf:"bytes,6,rep,name=partitions,proto3" json:"partitions,omitempty"`
	Algorithm            int64             `protobuf:"varint,7,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	IsSubPartition       bool              `protobuf:"varint,8,opt,name=is_sub_partition,json=isSubPartition,proto3" json:"is_sub_partition,omitempty"`
	PartitionMsg         string            `protobuf:"bytes,9,opt,name=partition_msg,json=partitionMsg,proto3" json:"partition_msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PartitionByDef) Descriptor added in v0.7.0 

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

func (*PartitionByDef) GetAlgorithm added in v0.7.0 

func (m *PartitionByDef) GetAlgorithm() int64

func (*PartitionByDef) GetIsSubPartition added in v0.7.0 

func (m *PartitionByDef) GetIsSubPartition() bool

func (*PartitionByDef) GetPartitionColumns added in v0.7.0 

func (m *PartitionByDef) GetPartitionColumns() *PartitionColumns

func (*PartitionByDef) GetPartitionExpr added in v0.7.0 

func (m *PartitionByDef) GetPartitionExpr() *PartitionExpr

func (*PartitionByDef) GetPartitionExpression added in v0.7.0 

func (m *PartitionByDef) GetPartitionExpression() *Expr

func (*PartitionByDef) GetPartitionMsg added in v0.7.0 

func (m *PartitionByDef) GetPartitionMsg() string

func (*PartitionByDef) GetPartitionNum added in v0.7.0 

func (m *PartitionByDef) GetPartitionNum() uint64

func (*PartitionByDef) GetPartitions added in v0.7.0 

func (m *PartitionByDef) GetPartitions() []*PartitionItem

func (*PartitionByDef) GetType added in v0.7.0 

func (m *PartitionByDef) GetType() PartitionType

func (*PartitionByDef) Marshal added in v0.7.0 

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

func (*PartitionByDef) MarshalPartitionInfo added in v0.7.0 

func (p *PartitionByDef) MarshalPartitionInfo() ([]byte, error)

func (*PartitionByDef) MarshalTo added in v0.7.0 

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

func (*PartitionByDef) MarshalToSizedBuffer added in v0.7.0 

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

func (*PartitionByDef) ProtoMessage added in v0.7.0 

func (*PartitionByDef) ProtoMessage()

func (*PartitionByDef) ProtoSize added in v0.7.0 

func (m *PartitionByDef) ProtoSize() (n int)

func (*PartitionByDef) Reset added in v0.7.0 

func (m *PartitionByDef) Reset()

func (*PartitionByDef) String added in v0.7.0 

func (m *PartitionByDef) String() string

func (*PartitionByDef) UnMarshalPartitionInfo added in v0.7.0 

func (p *PartitionByDef) UnMarshalPartitionInfo(data []byte) error

func (*PartitionByDef) Unmarshal added in v0.7.0 

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

func (*PartitionByDef) XXX_DiscardUnknown added in v0.7.0 

func (m *PartitionByDef) XXX_DiscardUnknown()

func (*PartitionByDef) XXX_Marshal added in v0.7.0 

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

func (*PartitionByDef) XXX_Merge added in v0.7.0 

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

func (*PartitionByDef) XXX_Size added in v0.7.0 

func (m *PartitionByDef) XXX_Size() int

func (*PartitionByDef) XXX_Unmarshal added in v0.7.0 

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

type PartitionColumns added in v0.7.0 

type PartitionColumns struct {
	Columns              []*Expr  `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	PartitionColumns     []string `protobuf:"bytes,2,rep,name=partition_columns,json=partitionColumns,proto3" json:"partition_columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PartitionColumns) Descriptor added in v0.7.0 

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

func (*PartitionColumns) GetColumns added in v0.7.0 

func (m *PartitionColumns) GetColumns() []*Expr

func (*PartitionColumns) GetPartitionColumns added in v0.7.0 

func (m *PartitionColumns) GetPartitionColumns() []string

func (*PartitionColumns) Marshal added in v0.7.0 

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

func (*PartitionColumns) MarshalTo added in v0.7.0 

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

func (*PartitionColumns) MarshalToSizedBuffer added in v0.7.0 

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

func (*PartitionColumns) ProtoMessage added in v0.7.0 

func (*PartitionColumns) ProtoMessage()

func (*PartitionColumns) ProtoSize added in v0.7.0 

func (m *PartitionColumns) ProtoSize() (n int)

func (*PartitionColumns) Reset added in v0.7.0 

func (m *PartitionColumns) Reset()

func (*PartitionColumns) String added in v0.7.0 

func (m *PartitionColumns) String() string

func (*PartitionColumns) Unmarshal added in v0.7.0 

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

func (*PartitionColumns) XXX_DiscardUnknown added in v0.7.0 

func (m *PartitionColumns) XXX_DiscardUnknown()

func (*PartitionColumns) XXX_Marshal added in v0.7.0 

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

func (*PartitionColumns) XXX_Merge added in v0.7.0 

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

func (*PartitionColumns) XXX_Size added in v0.7.0 

func (m *PartitionColumns) XXX_Size() int

func (*PartitionColumns) XXX_Unmarshal added in v0.7.0 

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

type PartitionExpr added in v0.7.0 

type PartitionExpr struct {
	Expr                 *Expr    `protobuf:"bytes,1,opt,name=expr,proto3" json:"expr,omitempty"`
	ExprStr              string   `protobuf:"bytes,2,opt,name=expr_str,json=exprStr,proto3" json:"expr_str,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PartitionExpr) Descriptor added in v0.7.0 

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

func (*PartitionExpr) GetExpr added in v0.7.0 

func (m *PartitionExpr) GetExpr() *Expr

func (*PartitionExpr) GetExprStr added in v0.7.0 

func (m *PartitionExpr) GetExprStr() string

func (*PartitionExpr) Marshal added in v0.7.0 

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

func (*PartitionExpr) MarshalTo added in v0.7.0 

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

func (*PartitionExpr) MarshalToSizedBuffer added in v0.7.0 

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

func (*PartitionExpr) ProtoMessage added in v0.7.0 

func (*PartitionExpr) ProtoMessage()

func (*PartitionExpr) ProtoSize added in v0.7.0 

func (m *PartitionExpr) ProtoSize() (n int)

func (*PartitionExpr) Reset added in v0.7.0 

func (m *PartitionExpr) Reset()

func (*PartitionExpr) String added in v0.7.0 

func (m *PartitionExpr) String() string

func (*PartitionExpr) Unmarshal added in v0.7.0 

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

func (*PartitionExpr) XXX_DiscardUnknown added in v0.7.0 

func (m *PartitionExpr) XXX_DiscardUnknown()

func (*PartitionExpr) XXX_Marshal added in v0.7.0 

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

func (*PartitionExpr) XXX_Merge added in v0.7.0 

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

func (*PartitionExpr) XXX_Size added in v0.7.0 

func (m *PartitionExpr) XXX_Size() int

func (*PartitionExpr) XXX_Unmarshal added in v0.7.0 

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

type PartitionItem added in v0.6.0 

type PartitionItem struct {
	PartitionName        string   `protobuf:"bytes,1,opt,name=partition_name,json=partitionName,proto3" json:"partition_name,omitempty"`
	OrdinalPosition      uint32   `protobuf:"varint,2,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Comment              string   `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	LessThan             []*Expr  `protobuf:"bytes,5,rep,name=less_than,json=lessThan,proto3" json:"less_than,omitempty"`
	InValues             []*Expr  `protobuf:"bytes,6,rep,name=in_values,json=inValues,proto3" json:"in_values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PartitionItem) Descriptor added in v0.6.0 

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

func (*PartitionItem) GetComment added in v0.6.0 

func (m *PartitionItem) GetComment() string

func (*PartitionItem) GetDescription added in v0.6.0 

func (m *PartitionItem) GetDescription() string

func (*PartitionItem) GetInValues added in v0.6.0 

func (m *PartitionItem) GetInValues() []*Expr

func (*PartitionItem) GetLessThan added in v0.6.0 

func (m *PartitionItem) GetLessThan() []*Expr

func (*PartitionItem) GetOrdinalPosition added in v0.6.0 

func (m *PartitionItem) GetOrdinalPosition() uint32

func (*PartitionItem) GetPartitionName added in v0.6.0 

func (m *PartitionItem) GetPartitionName() string

func (*PartitionItem) Marshal added in v0.6.0 

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

func (*PartitionItem) MarshalTo added in v0.6.0 

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

func (*PartitionItem) MarshalToSizedBuffer added in v0.6.0 

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

func (*PartitionItem) ProtoMessage added in v0.6.0 

func (*PartitionItem) ProtoMessage()

func (*PartitionItem) ProtoSize added in v0.6.0 

func (m *PartitionItem) ProtoSize() (n int)

func (*PartitionItem) Reset added in v0.6.0 

func (m *PartitionItem) Reset()

func (*PartitionItem) String added in v0.6.0 

func (m *PartitionItem) String() string

func (*PartitionItem) Unmarshal added in v0.6.0 

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

func (*PartitionItem) XXX_DiscardUnknown added in v0.6.0 

func (m *PartitionItem) XXX_DiscardUnknown()

func (*PartitionItem) XXX_Marshal added in v0.6.0 

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

func (*PartitionItem) XXX_Merge added in v0.6.0 

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

func (*PartitionItem) XXX_Size added in v0.6.0 

func (m *PartitionItem) XXX_Size() int

func (*PartitionItem) XXX_Unmarshal added in v0.6.0 

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

type PartitionType added in v0.6.0 

type PartitionType int32
const (
	PartitionType_KEY           PartitionType = 0
	PartitionType_LINEAR_KEY    PartitionType = 1
	PartitionType_HASH          PartitionType = 2
	PartitionType_LINEAR_HASH   PartitionType = 3
	PartitionType_RANGE         PartitionType = 4
	PartitionType_RANGE_COLUMNS PartitionType = 5
	PartitionType_LIST          PartitionType = 6
	PartitionType_LIST_COLUMNS  PartitionType = 7
)

func (PartitionType) EnumDescriptor added in v0.6.0 

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

func (PartitionType) String added in v0.6.0 

func (x PartitionType) String() string

type Plan added in v0.5.0 

type Plan struct {
	// Types that are valid to be assigned to Plan:
	//
	//	*Plan_Query
	//	*Plan_Tcl
	//	*Plan_Ddl
	//	*Plan_Dcl
	Plan                 isPlan_Plan `protobuf_oneof:"plan"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Plan) Descriptor added in v0.5.0 

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

func (*Plan) GetDcl added in v0.5.0 

func (m *Plan) GetDcl() *DataControl

func (*Plan) GetDdl added in v0.5.0 

func (m *Plan) GetDdl() *DataDefinition

func (*Plan) GetPlan added in v0.5.0 

func (m *Plan) GetPlan() isPlan_Plan

func (*Plan) GetQuery added in v0.5.0 

func (m *Plan) GetQuery() *Query

func (*Plan) GetTcl added in v0.5.0 

func (m *Plan) GetTcl() *TransationControl

func (*Plan) Marshal added in v0.5.0 

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

func (*Plan) MarshalBinary added in v0.6.0 

func (p *Plan) MarshalBinary() ([]byte, error)

func (*Plan) MarshalTo added in v0.5.0 

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

func (*Plan) MarshalToSizedBuffer added in v0.5.0 

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

func (*Plan) NeedImplicitTxn added in v0.6.0 

func (p *Plan) NeedImplicitTxn() bool

when autocommit is set to false, and no active txn is started an implicit txn need to be started for statements , like insert/delete/update and most select statement, like select * from t1. but for statement like select 1 or SELECT @@session.autocommit , implicit txn is not needed walk through the plan for select statement and check if there is an node_table_scan

func (*Plan) ProtoMessage added in v0.5.0 

func (*Plan) ProtoMessage()

func (*Plan) ProtoSize added in v0.5.0 

func (m *Plan) ProtoSize() (n int)

func (*Plan) Reset added in v0.5.0 

func (m *Plan) Reset()

func (*Plan) String added in v0.5.0 

func (m *Plan) String() string

func (*Plan) Unmarshal added in v0.5.0 

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

func (*Plan) UnmarshalBinary added in v0.6.0 

func (p *Plan) UnmarshalBinary(data []byte) error

func (*Plan) XXX_DiscardUnknown added in v0.5.0 

func (m *Plan) XXX_DiscardUnknown()

func (*Plan) XXX_Marshal added in v0.5.0 

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

func (*Plan) XXX_Merge added in v0.5.0 

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

func (*Plan) XXX_OneofWrappers added in v0.5.0 

func (*Plan) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Plan) XXX_Size added in v0.5.0 

func (m *Plan) XXX_Size() int

func (*Plan) XXX_Unmarshal added in v0.5.0 

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

type Plan_Dcl added in v0.5.0 

type Plan_Dcl struct {
	Dcl *DataControl `protobuf:"bytes,4,opt,name=dcl,proto3,oneof" json:"dcl,omitempty"`
}

func (*Plan_Dcl) MarshalTo added in v0.5.0 

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

func (*Plan_Dcl) MarshalToSizedBuffer added in v0.5.0 

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

func (*Plan_Dcl) ProtoSize added in v0.5.0 

func (m *Plan_Dcl) ProtoSize() (n int)

type Plan_Ddl added in v0.5.0 

type Plan_Ddl struct {
	Ddl *DataDefinition `protobuf:"bytes,3,opt,name=ddl,proto3,oneof" json:"ddl,omitempty"`
}

func (*Plan_Ddl) MarshalTo added in v0.5.0 

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

func (*Plan_Ddl) MarshalToSizedBuffer added in v0.5.0 

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

func (*Plan_Ddl) ProtoSize added in v0.5.0 

func (m *Plan_Ddl) ProtoSize() (n int)

type Plan_Query added in v0.5.0 

type Plan_Query struct {
	Query *Query `protobuf:"bytes,1,opt,name=query,proto3,oneof" json:"query,omitempty"`
}

func (*Plan_Query) MarshalTo added in v0.5.0 

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

func (*Plan_Query) MarshalToSizedBuffer added in v0.5.0 

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

func (*Plan_Query) ProtoSize added in v0.5.0 

func (m *Plan_Query) ProtoSize() (n int)

type Plan_Tcl added in v0.5.0 

type Plan_Tcl struct {
	Tcl *TransationControl `protobuf:"bytes,2,opt,name=tcl,proto3,oneof" json:"tcl,omitempty"`
}

func (*Plan_Tcl) MarshalTo added in v0.5.0 

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

func (*Plan_Tcl) MarshalToSizedBuffer added in v0.5.0 

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

func (*Plan_Tcl) ProtoSize added in v0.5.0 

func (m *Plan_Tcl) ProtoSize() (n int)

type Prepare added in v0.5.1 

type Prepare struct {
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Schemas              []*ObjectRef `protobuf:"bytes,2,rep,name=schemas,proto3" json:"schemas,omitempty"`
	Plan                 *Plan        `protobuf:"bytes,3,opt,name=plan,proto3" json:"plan,omitempty"`
	ParamTypes           []int32      `protobuf:"varint,4,rep,packed,name=param_types,json=paramTypes,proto3" json:"param_types,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Prepare) Descriptor added in v0.5.1 

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

func (*Prepare) GetName added in v0.5.1 

func (m *Prepare) GetName() string

func (*Prepare) GetParamTypes added in v0.6.0 

func (m *Prepare) GetParamTypes() []int32

func (*Prepare) GetPlan added in v0.5.1 

func (m *Prepare) GetPlan() *Plan

func (*Prepare) GetSchemas added in v0.6.0 

func (m *Prepare) GetSchemas() []*ObjectRef

func (*Prepare) Marshal added in v0.5.1 

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

func (*Prepare) MarshalTo added in v0.5.1 

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

func (*Prepare) MarshalToSizedBuffer added in v0.5.1 

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

func (*Prepare) ProtoMessage added in v0.5.1 

func (*Prepare) ProtoMessage()

func (*Prepare) ProtoSize added in v0.5.1 

func (m *Prepare) ProtoSize() (n int)

func (*Prepare) Reset added in v0.5.1 

func (m *Prepare) Reset()

func (*Prepare) String added in v0.5.1 

func (m *Prepare) String() string

func (*Prepare) Unmarshal added in v0.5.1 

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

func (*Prepare) XXX_DiscardUnknown added in v0.5.1 

func (m *Prepare) XXX_DiscardUnknown()

func (*Prepare) XXX_Marshal added in v0.5.1 

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

func (*Prepare) XXX_Merge added in v0.5.1 

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

func (*Prepare) XXX_Size added in v0.5.1 

func (m *Prepare) XXX_Size() int

func (*Prepare) XXX_Unmarshal added in v0.5.1 

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

type PrimaryKeyDef added in v0.5.0 

type PrimaryKeyDef struct {
	// currently not used
	Cols []uint64 `protobuf:"varint,1,rep,packed,name=cols,proto3" json:"cols,omitempty"`
	// currently not used
	PkeyColId uint64 `protobuf:"varint,2,opt,name=pkey_col_id,json=pkeyColId,proto3" json:"pkey_col_id,omitempty"`
	// currently not used
	Option *IndexOption `protobuf:"bytes,3,opt,name=option,proto3" json:"option,omitempty"`
	// Composed primary key column name: __mo_cpkey
	PkeyColName string `protobuf:"bytes,4,opt,name=pkey_col_name,json=pkeyColName,proto3" json:"pkey_col_name,omitempty"`
	// XXX: Deprecated and to be removed soon.
	Names                []string `protobuf:"bytes,5,rep,name=names,proto3" json:"names,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrimaryKeyDef) Descriptor added in v0.5.0 

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

func (*PrimaryKeyDef) GetCols added in v0.7.0 

func (m *PrimaryKeyDef) GetCols() []uint64

func (*PrimaryKeyDef) GetNames added in v0.5.0 

func (m *PrimaryKeyDef) GetNames() []string

func (*PrimaryKeyDef) GetOption added in v0.7.0 

func (m *PrimaryKeyDef) GetOption() *IndexOption

func (*PrimaryKeyDef) GetPkeyColId added in v0.7.0 

func (m *PrimaryKeyDef) GetPkeyColId() uint64

func (*PrimaryKeyDef) GetPkeyColName added in v0.7.0 

func (m *PrimaryKeyDef) GetPkeyColName() string

func (*PrimaryKeyDef) Marshal added in v0.5.0 

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

func (*PrimaryKeyDef) MarshalTo added in v0.5.0 

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

func (*PrimaryKeyDef) MarshalToSizedBuffer added in v0.5.0 

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

func (*PrimaryKeyDef) ProtoMessage added in v0.5.0 

func (*PrimaryKeyDef) ProtoMessage()

func (*PrimaryKeyDef) ProtoSize added in v0.5.0 

func (m *PrimaryKeyDef) ProtoSize() (n int)

func (*PrimaryKeyDef) Reset added in v0.5.0 

func (m *PrimaryKeyDef) Reset()

func (*PrimaryKeyDef) String added in v0.5.0 

func (m *PrimaryKeyDef) String() string

func (*PrimaryKeyDef) Unmarshal added in v0.5.0 

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

func (*PrimaryKeyDef) XXX_DiscardUnknown added in v0.5.0 

func (m *PrimaryKeyDef) XXX_DiscardUnknown()

func (*PrimaryKeyDef) XXX_Marshal added in v0.5.0 

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

func (*PrimaryKeyDef) XXX_Merge added in v0.5.0 

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

func (*PrimaryKeyDef) XXX_Size added in v0.5.0 

func (m *PrimaryKeyDef) XXX_Size() int

func (*PrimaryKeyDef) XXX_Unmarshal added in v0.5.0 

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

type PropertiesDef added in v0.5.0 

type PropertiesDef struct {
	Properties           []*Property `protobuf:"bytes,1,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*PropertiesDef) Descriptor added in v0.5.0 

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

func (*PropertiesDef) GetProperties added in v0.5.0 

func (m *PropertiesDef) GetProperties() []*Property

func (*PropertiesDef) Marshal added in v0.5.0 

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

func (*PropertiesDef) MarshalTo added in v0.5.0 

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

func (*PropertiesDef) MarshalToSizedBuffer added in v0.5.0 

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

func (*PropertiesDef) ProtoMessage added in v0.5.0 

func (*PropertiesDef) ProtoMessage()

func (*PropertiesDef) ProtoSize added in v0.5.0 

func (m *PropertiesDef) ProtoSize() (n int)

func (*PropertiesDef) Reset added in v0.5.0 

func (m *PropertiesDef) Reset()

func (*PropertiesDef) String added in v0.5.0 

func (m *PropertiesDef) String() string

func (*PropertiesDef) Unmarshal added in v0.5.0 

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

func (*PropertiesDef) XXX_DiscardUnknown added in v0.5.0 

func (m *PropertiesDef) XXX_DiscardUnknown()

func (*PropertiesDef) XXX_Marshal added in v0.5.0 

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

func (*PropertiesDef) XXX_Merge added in v0.5.0 

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

func (*PropertiesDef) XXX_Size added in v0.5.0 

func (m *PropertiesDef) XXX_Size() int

func (*PropertiesDef) XXX_Unmarshal added in v0.5.0 

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

type Property added in v0.5.0 

type Property struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Property) Descriptor added in v0.5.0 

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

func (*Property) GetKey added in v0.5.0 

func (m *Property) GetKey() string

func (*Property) GetValue added in v0.5.0 

func (m *Property) GetValue() string

func (*Property) Marshal added in v0.5.0 

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

func (*Property) MarshalTo added in v0.5.0 

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

func (*Property) MarshalToSizedBuffer added in v0.5.0 

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

func (*Property) ProtoMessage added in v0.5.0 

func (*Property) ProtoMessage()

func (*Property) ProtoSize added in v0.5.0 

func (m *Property) ProtoSize() (n int)

func (*Property) Reset added in v0.5.0 

func (m *Property) Reset()

func (*Property) String added in v0.5.0 

func (m *Property) String() string

func (*Property) Unmarshal added in v0.5.0 

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

func (*Property) XXX_DiscardUnknown added in v0.5.0 

func (m *Property) XXX_DiscardUnknown()

func (*Property) XXX_Marshal added in v0.5.0 

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

func (*Property) XXX_Merge added in v0.5.0 

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

func (*Property) XXX_Size added in v0.5.0 

func (m *Property) XXX_Size() int

func (*Property) XXX_Unmarshal added in v0.5.0 

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

type PropertyDef added in v0.7.0 

type PropertyDef struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PropertyDef) Descriptor added in v0.7.0 

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

func (*PropertyDef) GetKey added in v0.7.0 

func (m *PropertyDef) GetKey() string

func (*PropertyDef) GetValue added in v0.7.0 

func (m *PropertyDef) GetValue() string

func (*PropertyDef) Marshal added in v0.7.0 

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

func (*PropertyDef) MarshalTo added in v0.7.0 

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

func (*PropertyDef) MarshalToSizedBuffer added in v0.7.0 

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

func (*PropertyDef) ProtoMessage added in v0.7.0 

func (*PropertyDef) ProtoMessage()

func (*PropertyDef) ProtoSize added in v0.7.0 

func (m *PropertyDef) ProtoSize() (n int)

func (*PropertyDef) Reset added in v0.7.0 

func (m *PropertyDef) Reset()

func (*PropertyDef) String added in v0.7.0 

func (m *PropertyDef) String() string

func (*PropertyDef) Unmarshal added in v0.7.0 

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

func (*PropertyDef) XXX_DiscardUnknown added in v0.7.0 

func (m *PropertyDef) XXX_DiscardUnknown()

func (*PropertyDef) XXX_Marshal added in v0.7.0 

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

func (*PropertyDef) XXX_Merge added in v0.7.0 

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

func (*PropertyDef) XXX_Size added in v0.7.0 

func (m *PropertyDef) XXX_Size() int

func (*PropertyDef) XXX_Unmarshal added in v0.7.0 

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

type Query 

type Query struct {
	StmtType Query_StatementType `protobuf:"varint,1,opt,name=stmt_type,json=stmtType,proto3,enum=plan.Query_StatementType" json:"stmt_type,omitempty"`
	// Each step is simply a root node.  Root node refers to other
	// node as children and the whole step is a DAG.
	Steps []int32 `protobuf:"varint,2,rep,packed,name=steps,proto3" json:"steps,omitempty"`
	// All the nodes.  It is OK to have dangle nodes, we only excute nodes
	// reachable from step roots.
	Nodes []*Node `protobuf:"bytes,3,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// Bound Parameter for the query.
	Params []*Expr `protobuf:"bytes,4,rep,name=params,proto3" json:"params,omitempty"`
	// return head
	Headings []string `protobuf:"bytes,5,rep,name=headings,proto3" json:"headings,omitempty"`
	// load Tag
	LoadTag              bool     `protobuf:"varint,6,opt,name=loadTag,proto3" json:"loadTag,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Query) Descriptor 

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

func (*Query) GetHeadings added in v0.5.0 

func (m *Query) GetHeadings() []string

func (*Query) GetLoadTag added in v0.6.0 

func (m *Query) GetLoadTag() bool

func (*Query) GetNodes 

func (m *Query) GetNodes() []*Node

func (*Query) GetParams 

func (m *Query) GetParams() []*Expr

func (*Query) GetSteps 

func (m *Query) GetSteps() []int32

func (*Query) GetStmtType 

func (m *Query) GetStmtType() Query_StatementType

func (*Query) Marshal added in v0.5.0 

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

func (*Query) MarshalTo added in v0.5.0 

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

func (*Query) MarshalToSizedBuffer added in v0.5.0 

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

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoSize added in v0.5.0 

func (m *Query) ProtoSize() (n int)

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

func (*Query) Unmarshal added in v0.5.0 

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

func (*Query) XXX_DiscardUnknown added in v0.5.0 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal added in v0.5.0 

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

func (*Query) XXX_Merge added in v0.5.0 

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

func (*Query) XXX_Size added in v0.5.0 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal added in v0.5.0 

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

type Query_StatementType 

type Query_StatementType int32
const (
	Query_UNKNOWN Query_StatementType = 0
	Query_SELECT  Query_StatementType = 1
	Query_INSERT  Query_StatementType = 2
	Query_DELETE  Query_StatementType = 3
	Query_UPDATE  Query_StatementType = 4
	Query_MERGE   Query_StatementType = 5
)

func (Query_StatementType) EnumDescriptor 

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

func (Query_StatementType) String 

func (x Query_StatementType) String() string

type RawColRef added in v0.7.0 

type RawColRef struct {
	TblId                uint64   `protobuf:"varint,1,opt,name=tbl_id,json=tblId,proto3" json:"tbl_id,omitempty"`
	ColId                uint64   `protobuf:"varint,2,opt,name=col_id,json=colId,proto3" json:"col_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Reference a column by its internal table id and column id

func (*RawColRef) Descriptor added in v0.7.0 

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

func (*RawColRef) GetColId added in v0.7.0 

func (m *RawColRef) GetColId() uint64

func (*RawColRef) GetTblId added in v0.7.0 

func (m *RawColRef) GetTblId() uint64

func (*RawColRef) Marshal added in v0.7.0 

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

func (*RawColRef) MarshalTo added in v0.7.0 

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

func (*RawColRef) MarshalToSizedBuffer added in v0.7.0 

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

func (*RawColRef) ProtoMessage added in v0.7.0 

func (*RawColRef) ProtoMessage()

func (*RawColRef) ProtoSize added in v0.7.0 

func (m *RawColRef) ProtoSize() (n int)

func (*RawColRef) Reset added in v0.7.0 

func (m *RawColRef) Reset()

func (*RawColRef) String added in v0.7.0 

func (m *RawColRef) String() string

func (*RawColRef) Unmarshal added in v0.7.0 

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

func (*RawColRef) XXX_DiscardUnknown added in v0.7.0 

func (m *RawColRef) XXX_DiscardUnknown()

func (*RawColRef) XXX_Marshal added in v0.7.0 

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

func (*RawColRef) XXX_Merge added in v0.7.0 

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

func (*RawColRef) XXX_Size added in v0.7.0 

func (m *RawColRef) XXX_Size() int

func (*RawColRef) XXX_Unmarshal added in v0.7.0 

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

type ResultColDef added in v0.7.0 

type ResultColDef struct {
	ResultCols           []*ColDef `protobuf:"bytes,1,rep,name=ResultCols,proto3" json:"ResultCols,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ResultColDef) Descriptor added in v0.7.0 

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

func (*ResultColDef) GetResultCols added in v0.7.0 

func (m *ResultColDef) GetResultCols() []*ColDef

func (*ResultColDef) Marshal added in v0.7.0 

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

func (*ResultColDef) MarshalTo added in v0.7.0 

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

func (*ResultColDef) MarshalToSizedBuffer added in v0.7.0 

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

func (*ResultColDef) ProtoMessage added in v0.7.0 

func (*ResultColDef) ProtoMessage()

func (*ResultColDef) ProtoSize added in v0.7.0 

func (m *ResultColDef) ProtoSize() (n int)

func (*ResultColDef) Reset added in v0.7.0 

func (m *ResultColDef) Reset()

func (*ResultColDef) String added in v0.7.0 

func (m *ResultColDef) String() string

func (*ResultColDef) Unmarshal added in v0.7.0 

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

func (*ResultColDef) XXX_DiscardUnknown added in v0.7.0 

func (m *ResultColDef) XXX_DiscardUnknown()

func (*ResultColDef) XXX_Marshal added in v0.7.0 

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

func (*ResultColDef) XXX_Merge added in v0.7.0 

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

func (*ResultColDef) XXX_Size added in v0.7.0 

func (m *ResultColDef) XXX_Size() int

func (*ResultColDef) XXX_Unmarshal added in v0.7.0 

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

type RowsetData 

type RowsetData struct {
	Cols                 []*ColData `protobuf:"bytes,1,rep,name=cols,proto3" json:"cols,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*RowsetData) Descriptor 

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

func (*RowsetData) GetCols 

func (m *RowsetData) GetCols() []*ColData

func (*RowsetData) Marshal added in v0.5.0 

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

func (*RowsetData) MarshalTo added in v0.5.0 

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

func (*RowsetData) MarshalToSizedBuffer added in v0.5.0 

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

func (*RowsetData) ProtoMessage 

func (*RowsetData) ProtoMessage()

func (*RowsetData) ProtoSize added in v0.5.0 

func (m *RowsetData) ProtoSize() (n int)

func (*RowsetData) Reset 

func (m *RowsetData) Reset()

func (*RowsetData) String 

func (m *RowsetData) String() string

func (*RowsetData) Unmarshal added in v0.5.0 

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

func (*RowsetData) XXX_DiscardUnknown added in v0.5.0 

func (m *RowsetData) XXX_DiscardUnknown()

func (*RowsetData) XXX_Marshal added in v0.5.0 

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

func (*RowsetData) XXX_Merge added in v0.5.0 

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

func (*RowsetData) XXX_Size added in v0.5.0 

func (m *RowsetData) XXX_Size() int

func (*RowsetData) XXX_Unmarshal added in v0.5.0 

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

type SetVariables added in v0.5.0 

type SetVariables struct {
	Items                []*SetVariablesItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SetVariables) Descriptor added in v0.5.0 

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

func (*SetVariables) GetItems added in v0.5.0 

func (m *SetVariables) GetItems() []*SetVariablesItem

func (*SetVariables) Marshal added in v0.5.0 

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

func (*SetVariables) MarshalTo added in v0.5.0 

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

func (*SetVariables) MarshalToSizedBuffer added in v0.5.0 

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

func (*SetVariables) ProtoMessage added in v0.5.0 

func (*SetVariables) ProtoMessage()

func (*SetVariables) ProtoSize added in v0.5.0 

func (m *SetVariables) ProtoSize() (n int)

func (*SetVariables) Reset added in v0.5.0 

func (m *SetVariables) Reset()

func (*SetVariables) String added in v0.5.0 

func (m *SetVariables) String() string

func (*SetVariables) Unmarshal added in v0.5.0 

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

func (*SetVariables) XXX_DiscardUnknown added in v0.5.0 

func (m *SetVariables) XXX_DiscardUnknown()

func (*SetVariables) XXX_Marshal added in v0.5.0 

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

func (*SetVariables) XXX_Merge added in v0.5.0 

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

func (*SetVariables) XXX_Size added in v0.5.0 

func (m *SetVariables) XXX_Size() int

func (*SetVariables) XXX_Unmarshal added in v0.5.0 

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

type SetVariablesItem added in v0.5.0 

type SetVariablesItem struct {
	System               bool     `protobuf:"varint,1,opt,name=system,proto3" json:"system,omitempty"`
	Global               bool     `protobuf:"varint,2,opt,name=global,proto3" json:"global,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Value                *Expr    `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	Reserved             *Expr    `protobuf:"bytes,5,opt,name=reserved,proto3" json:"reserved,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetVariablesItem) Descriptor added in v0.5.0 

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

func (*SetVariablesItem) GetGlobal added in v0.5.0 

func (m *SetVariablesItem) GetGlobal() bool

func (*SetVariablesItem) GetName added in v0.5.0 

func (m *SetVariablesItem) GetName() string

func (*SetVariablesItem) GetReserved added in v0.5.0 

func (m *SetVariablesItem) GetReserved() *Expr

func (*SetVariablesItem) GetSystem added in v0.5.0 

func (m *SetVariablesItem) GetSystem() bool

func (*SetVariablesItem) GetValue added in v0.5.0 

func (m *SetVariablesItem) GetValue() *Expr

func (*SetVariablesItem) Marshal added in v0.5.0 

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

func (*SetVariablesItem) MarshalTo added in v0.5.0 

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

func (*SetVariablesItem) MarshalToSizedBuffer added in v0.5.0 

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

func (*SetVariablesItem) ProtoMessage added in v0.5.0 

func (*SetVariablesItem) ProtoMessage()

func (*SetVariablesItem) ProtoSize added in v0.5.0 

func (m *SetVariablesItem) ProtoSize() (n int)

func (*SetVariablesItem) Reset added in v0.5.0 

func (m *SetVariablesItem) Reset()

func (*SetVariablesItem) String added in v0.5.0 

func (m *SetVariablesItem) String() string

func (*SetVariablesItem) Unmarshal added in v0.5.0 

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

func (*SetVariablesItem) XXX_DiscardUnknown added in v0.5.0 

func (m *SetVariablesItem) XXX_DiscardUnknown()

func (*SetVariablesItem) XXX_Marshal added in v0.5.0 

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

func (*SetVariablesItem) XXX_Merge added in v0.5.0 

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

func (*SetVariablesItem) XXX_Size added in v0.5.0 

func (m *SetVariablesItem) XXX_Size() int

func (*SetVariablesItem) XXX_Unmarshal added in v0.5.0 

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

type ShowVariables added in v0.5.0 

type ShowVariables struct {
	Global               bool     `protobuf:"varint,1,opt,name=global,proto3" json:"global,omitempty"`
	Where                []*Expr  `protobuf:"bytes,2,rep,name=where,proto3" json:"where,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShowVariables) Descriptor added in v0.5.0 

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

func (*ShowVariables) GetGlobal added in v0.5.0 

func (m *ShowVariables) GetGlobal() bool

func (*ShowVariables) GetWhere added in v0.5.0 

func (m *ShowVariables) GetWhere() []*Expr

func (*ShowVariables) Marshal added in v0.5.0 

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

func (*ShowVariables) MarshalTo added in v0.5.0 

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

func (*ShowVariables) MarshalToSizedBuffer added in v0.5.0 

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

func (*ShowVariables) ProtoMessage added in v0.5.0 

func (*ShowVariables) ProtoMessage()

func (*ShowVariables) ProtoSize added in v0.5.0 

func (m *ShowVariables) ProtoSize() (n int)

func (*ShowVariables) Reset added in v0.5.0 

func (m *ShowVariables) Reset()

func (*ShowVariables) String added in v0.5.0 

func (m *ShowVariables) String() string

func (*ShowVariables) Unmarshal added in v0.5.0 

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

func (*ShowVariables) XXX_DiscardUnknown added in v0.5.0 

func (m *ShowVariables) XXX_DiscardUnknown()

func (*ShowVariables) XXX_Marshal added in v0.5.0 

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

func (*ShowVariables) XXX_Merge added in v0.5.0 

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

func (*ShowVariables) XXX_Size added in v0.5.0 

func (m *ShowVariables) XXX_Size() int

func (*ShowVariables) XXX_Unmarshal added in v0.5.0 

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

type Stats added in v0.7.0 

type Stats struct {
	// for scan, number of blocks to read from S3
	// for other nodes, it's meaningless
	BlockNum int32 `protobuf:"varint,1,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	// for scan, cost of reading from S3, basically the read lines
	// for other nodes, it means the estimated cost of current node
	Cost float64 `protobuf:"fixed64,2,opt,name=cost,proto3" json:"cost,omitempty"`
	// number of output lines
	Outcnt float64 `protobuf:"fixed64,3,opt,name=outcnt,proto3" json:"outcnt,omitempty"`
	// average size of one row, currently not used
	Rowsize float64 `protobuf:"fixed64,4,opt,name=rowsize,proto3" json:"rowsize,omitempty"`
	// hashmap size for nodes which build a hashmap
	// for other nodes, it's meaningless
	HashmapSize float64 `protobuf:"fixed64,5,opt,name=hashmap_size,json=hashmapSize,proto3" json:"hashmap_size,omitempty"`
	// for scan, this means total count of all table, before filtering
	// for other nodes, this is meanlingless
	TableCnt float64 `protobuf:"fixed64,6,opt,name=table_cnt,json=tableCnt,proto3" json:"table_cnt,omitempty"`
	// for scan, selectivity means outcnt divide total count
	// for other node, currently be 0. will change in the future
	Selectivity          float64  `protobuf:"fixed64,7,opt,name=selectivity,proto3" json:"selectivity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Stats) Descriptor added in v0.7.0 

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

func (*Stats) GetBlockNum added in v0.7.0 

func (m *Stats) GetBlockNum() int32

func (*Stats) GetCost added in v0.7.0 

func (m *Stats) GetCost() float64

func (*Stats) GetHashmapSize added in v0.7.0 

func (m *Stats) GetHashmapSize() float64

func (*Stats) GetOutcnt added in v0.7.0 

func (m *Stats) GetOutcnt() float64

func (*Stats) GetRowsize added in v0.7.0 

func (m *Stats) GetRowsize() float64

func (*Stats) GetSelectivity added in v0.7.0 

func (m *Stats) GetSelectivity() float64

func (*Stats) GetTableCnt added in v0.7.0 

func (m *Stats) GetTableCnt() float64

func (*Stats) Marshal added in v0.7.0 

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

func (*Stats) MarshalTo added in v0.7.0 

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

func (*Stats) MarshalToSizedBuffer added in v0.7.0 

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

func (*Stats) ProtoMessage added in v0.7.0 

func (*Stats) ProtoMessage()

func (*Stats) ProtoSize added in v0.7.0 

func (m *Stats) ProtoSize() (n int)

func (*Stats) Reset added in v0.7.0 

func (m *Stats) Reset()

func (*Stats) String added in v0.7.0 

func (m *Stats) String() string

func (*Stats) Unmarshal added in v0.7.0 

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

func (*Stats) XXX_DiscardUnknown added in v0.7.0 

func (m *Stats) XXX_DiscardUnknown()

func (*Stats) XXX_Marshal added in v0.7.0 

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

func (*Stats) XXX_Merge added in v0.7.0 

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

func (*Stats) XXX_Size added in v0.7.0 

func (m *Stats) XXX_Size() int

func (*Stats) XXX_Unmarshal added in v0.7.0 

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

type SubqueryRef added in v0.5.0 

type SubqueryRef struct {
	Typ                  SubqueryRef_Type `protobuf:"varint,1,opt,name=typ,proto3,enum=plan.SubqueryRef_Type" json:"typ,omitempty"`
	NodeId               int32            `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Op                   string           `protobuf:"bytes,3,opt,name=op,proto3" json:"op,omitempty"`
	Child                *Expr            `protobuf:"bytes,4,opt,name=child,proto3" json:"child,omitempty"`
	RowSize              int32            `protobuf:"varint,5,opt,name=row_size,json=rowSize,proto3" json:"row_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Reference a subquery

func (*SubqueryRef) Descriptor added in v0.5.0 

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

func (*SubqueryRef) GetChild added in v0.5.0 

func (m *SubqueryRef) GetChild() *Expr

func (*SubqueryRef) GetNodeId added in v0.5.0 

func (m *SubqueryRef) GetNodeId() int32

func (*SubqueryRef) GetOp added in v0.5.0 

func (m *SubqueryRef) GetOp() string

func (*SubqueryRef) GetRowSize added in v0.6.0 

func (m *SubqueryRef) GetRowSize() int32

func (*SubqueryRef) GetTyp added in v0.5.0 

func (m *SubqueryRef) GetTyp() SubqueryRef_Type

func (*SubqueryRef) Marshal added in v0.5.0 

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

func (*SubqueryRef) MarshalTo added in v0.5.0 

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

func (*SubqueryRef) MarshalToSizedBuffer added in v0.5.0 

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

func (*SubqueryRef) ProtoMessage added in v0.5.0 

func (*SubqueryRef) ProtoMessage()

func (*SubqueryRef) ProtoSize added in v0.5.0 

func (m *SubqueryRef) ProtoSize() (n int)

func (*SubqueryRef) Reset added in v0.5.0 

func (m *SubqueryRef) Reset()

func (*SubqueryRef) String added in v0.5.0 

func (m *SubqueryRef) String() string

func (*SubqueryRef) Unmarshal added in v0.5.0 

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

func (*SubqueryRef) XXX_DiscardUnknown added in v0.5.0 

func (m *SubqueryRef) XXX_DiscardUnknown()

func (*SubqueryRef) XXX_Marshal added in v0.5.0 

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

func (*SubqueryRef) XXX_Merge added in v0.5.0 

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

func (*SubqueryRef) XXX_Size added in v0.5.0 

func (m *SubqueryRef) XXX_Size() int

func (*SubqueryRef) XXX_Unmarshal added in v0.5.0 

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

type SubqueryRef_Type added in v0.5.0 

type SubqueryRef_Type int32
const (
	SubqueryRef_SCALAR     SubqueryRef_Type = 0
	SubqueryRef_EXISTS     SubqueryRef_Type = 1
	SubqueryRef_NOT_EXISTS SubqueryRef_Type = 2
	SubqueryRef_IN         SubqueryRef_Type = 3
	SubqueryRef_NOT_IN     SubqueryRef_Type = 4
	SubqueryRef_ANY        SubqueryRef_Type = 5
	SubqueryRef_ALL        SubqueryRef_Type = 6
)

func (SubqueryRef_Type) EnumDescriptor added in v0.5.0 

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

func (SubqueryRef_Type) String added in v0.5.0 

func (x SubqueryRef_Type) String() string

type TableDef 

type TableDef struct {
	TblId        uint64           `protobuf:"varint,1,opt,name=tbl_id,json=tblId,proto3" json:"tbl_id,omitempty"`
	Name         string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Hidden       bool             `protobuf:"varint,3,opt,name=hidden,proto3" json:"hidden,omitempty"`
	Cols         []*ColDef        `protobuf:"bytes,4,rep,name=cols,proto3" json:"cols,omitempty"`
	TableType    string           `protobuf:"bytes,5,opt,name=table_type,json=tableType,proto3" json:"table_type,omitempty"`
	Createsql    string           `protobuf:"bytes,6,opt,name=createsql,proto3" json:"createsql,omitempty"`
	TblFunc      *TableFunction   `protobuf:"bytes,7,opt,name=tbl_func,json=tblFunc,proto3" json:"tbl_func,omitempty"`
	Pkey         *PrimaryKeyDef   `protobuf:"bytes,11,opt,name=pkey,proto3" json:"pkey,omitempty"`
	Indexes      []*IndexDef      `protobuf:"bytes,12,rep,name=indexes,proto3" json:"indexes,omitempty"`
	Fkeys        []*ForeignKeyDef `protobuf:"bytes,13,rep,name=fkeys,proto3" json:"fkeys,omitempty"`
	RefChildTbls []uint64         `protobuf:"varint,14,rep,packed,name=ref_child_tbls,json=refChildTbls,proto3" json:"ref_child_tbls,omitempty"`
	Checks       []*CheckDef      `protobuf:"bytes,15,rep,name=checks,proto3" json:"checks,omitempty"`
	Partition    *PartitionByDef  `protobuf:"bytes,21,opt,name=partition,proto3" json:"partition,omitempty"`
	ClusterBy    *ClusterByDef    `protobuf:"bytes,22,opt,name=cluster_by,json=clusterBy,proto3" json:"cluster_by,omitempty"`
	Props        []*PropertyDef   `protobuf:"bytes,23,rep,name=props,proto3" json:"props,omitempty"`
	ViewSql      *ViewDef         `protobuf:"bytes,24,opt,name=view_sql,json=viewSql,proto3" json:"view_sql,omitempty"`
	OriginCols   []*ColDef        `protobuf:"bytes,25,rep,name=origin_cols,json=originCols,proto3" json:"origin_cols,omitempty"`
	// XXX: Deprecated and to be removed soon.
	Defs                 []*TableDef_DefType `protobuf:"bytes,31,rep,name=defs,proto3" json:"defs,omitempty"`
	Name2ColIndex        map[string]int32    `` /* 190-byte string literal not displayed */
	CompositePkey        *ColDef             `protobuf:"bytes,33,opt,name=composite_pkey,json=compositePkey,proto3" json:"composite_pkey,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*TableDef) Descriptor 

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

func (*TableDef) GetChecks added in v0.7.0 

func (m *TableDef) GetChecks() []*CheckDef

func (*TableDef) GetClusterBy added in v0.7.0 

func (m *TableDef) GetClusterBy() *ClusterByDef

func (*TableDef) GetCols 

func (m *TableDef) GetCols() []*ColDef

func (*TableDef) GetCompositePkey added in v0.6.0 

func (m *TableDef) GetCompositePkey() *ColDef

func (*TableDef) GetCreatesql added in v0.6.0 

func (m *TableDef) GetCreatesql() string

func (*TableDef) GetDefs added in v0.5.0 

func (m *TableDef) GetDefs() []*TableDef_DefType

func (*TableDef) GetFkeys added in v0.7.0 

func (m *TableDef) GetFkeys() []*ForeignKeyDef

func (*TableDef) GetHidden added in v0.7.0 

func (m *TableDef) GetHidden() bool

func (*TableDef) GetIndexes added in v0.7.0 

func (m *TableDef) GetIndexes() []*IndexDef

func (*TableDef) GetName 

func (m *TableDef) GetName() string

func (*TableDef) GetName2ColIndex added in v0.6.0 

func (m *TableDef) GetName2ColIndex() map[string]int32

func (*TableDef) GetOriginCols added in v0.7.0 

func (m *TableDef) GetOriginCols() []*ColDef

func (*TableDef) GetPartition added in v0.7.0 

func (m *TableDef) GetPartition() *PartitionByDef

func (*TableDef) GetPkey added in v0.7.0 

func (m *TableDef) GetPkey() *PrimaryKeyDef

func (*TableDef) GetProps added in v0.7.0 

func (m *TableDef) GetProps() []*PropertyDef

func (*TableDef) GetRefChildTbls added in v0.7.0 

func (m *TableDef) GetRefChildTbls() []uint64

func (*TableDef) GetTableType added in v0.6.0 

func (m *TableDef) GetTableType() string

func (*TableDef) GetTblFunc added in v0.6.0 

func (m *TableDef) GetTblFunc() *TableFunction

func (*TableDef) GetTblId added in v0.7.0 

func (m *TableDef) GetTblId() uint64

func (*TableDef) GetViewSql added in v0.7.0 

func (m *TableDef) GetViewSql() *ViewDef

func (*TableDef) Marshal added in v0.5.0 

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

func (*TableDef) MarshalTo added in v0.5.0 

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

func (*TableDef) MarshalToSizedBuffer added in v0.5.0 

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

func (*TableDef) ProtoMessage 

func (*TableDef) ProtoMessage()

func (*TableDef) ProtoSize added in v0.5.0 

func (m *TableDef) ProtoSize() (n int)

func (*TableDef) Reset 

func (m *TableDef) Reset()

func (*TableDef) String 

func (m *TableDef) String() string

func (*TableDef) Unmarshal added in v0.5.0 

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

func (*TableDef) XXX_DiscardUnknown added in v0.5.0 

func (m *TableDef) XXX_DiscardUnknown()

func (*TableDef) XXX_Marshal added in v0.5.0 

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

func (*TableDef) XXX_Merge added in v0.5.0 

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

func (*TableDef) XXX_Size added in v0.5.0 

func (m *TableDef) XXX_Size() int

func (*TableDef) XXX_Unmarshal added in v0.5.0 

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

type TableDef_DefType added in v0.5.0 

type TableDef_DefType struct {
	// Types that are valid to be assigned to Def:
	//
	//	*TableDef_DefType_Properties
	Def                  isTableDef_DefType_Def `protobuf_oneof:"def"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

XXX: Deprecated and to be removed soon.

func (*TableDef_DefType) Descriptor added in v0.5.0 

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

func (*TableDef_DefType) GetDef added in v0.5.0 

func (m *TableDef_DefType) GetDef() isTableDef_DefType_Def

func (*TableDef_DefType) GetProperties added in v0.5.0 

func (m *TableDef_DefType) GetProperties() *PropertiesDef

func (*TableDef_DefType) Marshal added in v0.5.0 

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

func (*TableDef_DefType) MarshalTo added in v0.5.0 

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

func (*TableDef_DefType) MarshalToSizedBuffer added in v0.5.0 

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

func (*TableDef_DefType) ProtoMessage added in v0.5.0 

func (*TableDef_DefType) ProtoMessage()

func (*TableDef_DefType) ProtoSize added in v0.5.0 

func (m *TableDef_DefType) ProtoSize() (n int)

func (*TableDef_DefType) Reset added in v0.5.0 

func (m *TableDef_DefType) Reset()

func (*TableDef_DefType) String added in v0.5.0 

func (m *TableDef_DefType) String() string

func (*TableDef_DefType) Unmarshal added in v0.5.0 

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

func (*TableDef_DefType) XXX_DiscardUnknown added in v0.5.0 

func (m *TableDef_DefType) XXX_DiscardUnknown()

func (*TableDef_DefType) XXX_Marshal added in v0.5.0 

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

func (*TableDef_DefType) XXX_Merge added in v0.5.0 

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

func (*TableDef_DefType) XXX_OneofWrappers added in v0.5.0 

func (*TableDef_DefType) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TableDef_DefType) XXX_Size added in v0.5.0 

func (m *TableDef_DefType) XXX_Size() int

func (*TableDef_DefType) XXX_Unmarshal added in v0.5.0 

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

type TableDef_DefType_Properties added in v0.5.0 

type TableDef_DefType_Properties struct {
	Properties *PropertiesDef `protobuf:"bytes,1,opt,name=properties,proto3,oneof" json:"properties,omitempty"`
}

func (*TableDef_DefType_Properties) MarshalTo added in v0.5.0 

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

func (*TableDef_DefType_Properties) MarshalToSizedBuffer added in v0.5.0 

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

func (*TableDef_DefType_Properties) ProtoSize added in v0.5.0 

func (m *TableDef_DefType_Properties) ProtoSize() (n int)

type TableFunction added in v0.6.0 

type TableFunction struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Param                []byte   `protobuf:"bytes,2,opt,name=param,proto3" json:"param,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TableFunction) Descriptor added in v0.6.0 

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

func (*TableFunction) GetName added in v0.6.0 

func (m *TableFunction) GetName() string

func (*TableFunction) GetParam added in v0.6.0 

func (m *TableFunction) GetParam() []byte

func (*TableFunction) Marshal added in v0.6.0 

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

func (*TableFunction) MarshalTo added in v0.6.0 

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

func (*TableFunction) MarshalToSizedBuffer added in v0.6.0 

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

func (*TableFunction) ProtoMessage added in v0.6.0 

func (*TableFunction) ProtoMessage()

func (*TableFunction) ProtoSize added in v0.6.0 

func (m *TableFunction) ProtoSize() (n int)

func (*TableFunction) Reset added in v0.6.0 

func (m *TableFunction) Reset()

func (*TableFunction) String added in v0.6.0 

func (m *TableFunction) String() string

func (*TableFunction) Unmarshal added in v0.6.0 

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

func (*TableFunction) XXX_DiscardUnknown added in v0.6.0 

func (m *TableFunction) XXX_DiscardUnknown()

func (*TableFunction) XXX_Marshal added in v0.6.0 

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

func (*TableFunction) XXX_Merge added in v0.6.0 

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

func (*TableFunction) XXX_Size added in v0.6.0 

func (m *TableFunction) XXX_Size() int

func (*TableFunction) XXX_Unmarshal added in v0.6.0 

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

type TargetType added in v0.5.0 

type TargetType struct {
	Typ                  *Type    `protobuf:"bytes,1,opt,name=typ,proto3" json:"typ,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TargetType used in cast function as target type

func (*TargetType) Descriptor added in v0.5.0 

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

func (*TargetType) GetTyp added in v0.5.0 

func (m *TargetType) GetTyp() *Type

func (*TargetType) Marshal added in v0.5.0 

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

func (*TargetType) MarshalTo added in v0.5.0 

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

func (*TargetType) MarshalToSizedBuffer added in v0.5.0 

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

func (*TargetType) ProtoMessage added in v0.5.0 

func (*TargetType) ProtoMessage()

func (*TargetType) ProtoSize added in v0.5.0 

func (m *TargetType) ProtoSize() (n int)

func (*TargetType) Reset added in v0.5.0 

func (m *TargetType) Reset()

func (*TargetType) String added in v0.5.0 

func (m *TargetType) String() string

func (*TargetType) Unmarshal added in v0.5.0 

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

func (*TargetType) XXX_DiscardUnknown added in v0.5.0 

func (m *TargetType) XXX_DiscardUnknown()

func (*TargetType) XXX_Marshal added in v0.5.0 

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

func (*TargetType) XXX_Merge added in v0.5.0 

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

func (*TargetType) XXX_Size added in v0.5.0 

func (m *TargetType) XXX_Size() int

func (*TargetType) XXX_Unmarshal added in v0.5.0 

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

type TransationBegin added in v0.5.0 

type TransationBegin struct {
	Mode                 TransationBegin_TransationMode `protobuf:"varint,1,opt,name=mode,proto3,enum=plan.TransationBegin_TransationMode" json:"mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*TransationBegin) Descriptor added in v0.5.0 

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

func (*TransationBegin) GetMode added in v0.5.0 

func (m *TransationBegin) GetMode() TransationBegin_TransationMode

func (*TransationBegin) Marshal added in v0.5.0 

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

func (*TransationBegin) MarshalTo added in v0.5.0 

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

func (*TransationBegin) MarshalToSizedBuffer added in v0.5.0 

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

func (*TransationBegin) ProtoMessage added in v0.5.0 

func (*TransationBegin) ProtoMessage()

func (*TransationBegin) ProtoSize added in v0.5.0 

func (m *TransationBegin) ProtoSize() (n int)

func (*TransationBegin) Reset added in v0.5.0 

func (m *TransationBegin) Reset()

func (*TransationBegin) String added in v0.5.0 

func (m *TransationBegin) String() string

func (*TransationBegin) Unmarshal added in v0.5.0 

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

func (*TransationBegin) XXX_DiscardUnknown added in v0.5.0 

func (m *TransationBegin) XXX_DiscardUnknown()

func (*TransationBegin) XXX_Marshal added in v0.5.0 

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

func (*TransationBegin) XXX_Merge added in v0.5.0 

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

func (*TransationBegin) XXX_Size added in v0.5.0 

func (m *TransationBegin) XXX_Size() int

func (*TransationBegin) XXX_Unmarshal added in v0.5.0 

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

type TransationBegin_TransationMode added in v0.5.0 

type TransationBegin_TransationMode int32
const (
	TransationBegin_NONE       TransationBegin_TransationMode = 0
	TransationBegin_READ_ONLY  TransationBegin_TransationMode = 1
	TransationBegin_READ_WRITE TransationBegin_TransationMode = 2
)

func (TransationBegin_TransationMode) EnumDescriptor added in v0.5.0 

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

func (TransationBegin_TransationMode) String added in v0.5.0 

func (x TransationBegin_TransationMode) String() string

type TransationCommit added in v0.5.0 

type TransationCommit struct {
	CompletionType       TransationCompletionType `` /* 139-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*TransationCommit) Descriptor added in v0.5.0 

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

func (*TransationCommit) GetCompletionType added in v0.5.0 

func (m *TransationCommit) GetCompletionType() TransationCompletionType

func (*TransationCommit) Marshal added in v0.5.0 

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

func (*TransationCommit) MarshalTo added in v0.5.0 

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

func (*TransationCommit) MarshalToSizedBuffer added in v0.5.0 

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

func (*TransationCommit) ProtoMessage added in v0.5.0 

func (*TransationCommit) ProtoMessage()

func (*TransationCommit) ProtoSize added in v0.5.0 

func (m *TransationCommit) ProtoSize() (n int)

func (*TransationCommit) Reset added in v0.5.0 

func (m *TransationCommit) Reset()

func (*TransationCommit) String added in v0.5.0 

func (m *TransationCommit) String() string

func (*TransationCommit) Unmarshal added in v0.5.0 

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

func (*TransationCommit) XXX_DiscardUnknown added in v0.5.0 

func (m *TransationCommit) XXX_DiscardUnknown()

func (*TransationCommit) XXX_Marshal added in v0.5.0 

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

func (*TransationCommit) XXX_Merge added in v0.5.0 

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

func (*TransationCommit) XXX_Size added in v0.5.0 

func (m *TransationCommit) XXX_Size() int

func (*TransationCommit) XXX_Unmarshal added in v0.5.0 

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

type TransationCompletionType added in v0.5.0 

type TransationCompletionType int32
const (
	TransationCompletionType_CHAIN    TransationCompletionType = 0
	TransationCompletionType_NO_CHAIN TransationCompletionType = 1
	TransationCompletionType_RELEASE  TransationCompletionType = 2
)

func (TransationCompletionType) EnumDescriptor added in v0.5.0 

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

func (TransationCompletionType) String added in v0.5.0 

func (x TransationCompletionType) String() string

type TransationControl added in v0.5.0 

type TransationControl struct {
	// TransationControl type
	TclType TransationControl_TclType `protobuf:"varint,1,opt,name=tcl_type,json=tclType,proto3,enum=plan.TransationControl_TclType" json:"tcl_type,omitempty"`
	// Types that are valid to be assigned to Action:
	//
	//	*TransationControl_Begin
	//	*TransationControl_Commit
	//	*TransationControl_Rollback
	Action               isTransationControl_Action `protobuf_oneof:"action"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*TransationControl) Descriptor added in v0.5.0 

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

func (*TransationControl) GetAction added in v0.5.0 

func (m *TransationControl) GetAction() isTransationControl_Action

func (*TransationControl) GetBegin added in v0.5.0 

func (m *TransationControl) GetBegin() *TransationBegin

func (*TransationControl) GetCommit added in v0.5.0 

func (m *TransationControl) GetCommit() *TransationCommit

func (*TransationControl) GetRollback added in v0.5.0 

func (m *TransationControl) GetRollback() *TransationRollback

func (*TransationControl) GetTclType added in v0.5.0 

func (m *TransationControl) GetTclType() TransationControl_TclType

func (*TransationControl) Marshal added in v0.5.0 

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

func (*TransationControl) MarshalTo added in v0.5.0 

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

func (*TransationControl) MarshalToSizedBuffer added in v0.5.0 

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

func (*TransationControl) ProtoMessage added in v0.5.0 

func (*TransationControl) ProtoMessage()

func (*TransationControl) ProtoSize added in v0.5.0 

func (m *TransationControl) ProtoSize() (n int)

func (*TransationControl) Reset added in v0.5.0 

func (m *TransationControl) Reset()

func (*TransationControl) String added in v0.5.0 

func (m *TransationControl) String() string

func (*TransationControl) Unmarshal added in v0.5.0 

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

func (*TransationControl) XXX_DiscardUnknown added in v0.5.0 

func (m *TransationControl) XXX_DiscardUnknown()

func (*TransationControl) XXX_Marshal added in v0.5.0 

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

func (*TransationControl) XXX_Merge added in v0.5.0 

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

func (*TransationControl) XXX_OneofWrappers added in v0.5.0 

func (*TransationControl) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TransationControl) XXX_Size added in v0.5.0 

func (m *TransationControl) XXX_Size() int

func (*TransationControl) XXX_Unmarshal added in v0.5.0 

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

type TransationControl_Begin added in v0.5.0 

type TransationControl_Begin struct {
	Begin *TransationBegin `protobuf:"bytes,2,opt,name=begin,proto3,oneof" json:"begin,omitempty"`
}

func (*TransationControl_Begin) MarshalTo added in v0.5.0 

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

func (*TransationControl_Begin) MarshalToSizedBuffer added in v0.5.0 

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

func (*TransationControl_Begin) ProtoSize added in v0.5.0 

func (m *TransationControl_Begin) ProtoSize() (n int)

type TransationControl_Commit added in v0.5.0 

type TransationControl_Commit struct {
	Commit *TransationCommit `protobuf:"bytes,3,opt,name=commit,proto3,oneof" json:"commit,omitempty"`
}

func (*TransationControl_Commit) MarshalTo added in v0.5.0 

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

func (*TransationControl_Commit) MarshalToSizedBuffer added in v0.5.0 

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

func (*TransationControl_Commit) ProtoSize added in v0.5.0 

func (m *TransationControl_Commit) ProtoSize() (n int)

type TransationControl_Rollback added in v0.5.0 

type TransationControl_Rollback struct {
	Rollback *TransationRollback `protobuf:"bytes,4,opt,name=rollback,proto3,oneof" json:"rollback,omitempty"`
}

func (*TransationControl_Rollback) MarshalTo added in v0.5.0 

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

func (*TransationControl_Rollback) MarshalToSizedBuffer added in v0.5.0 

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

func (*TransationControl_Rollback) ProtoSize added in v0.5.0 

func (m *TransationControl_Rollback) ProtoSize() (n int)

type TransationControl_TclType added in v0.5.0 

type TransationControl_TclType int32
const (
	TransationControl_BEGIN    TransationControl_TclType = 0
	TransationControl_COMMIT   TransationControl_TclType = 1
	TransationControl_ROLLBACK TransationControl_TclType = 2
)

func (TransationControl_TclType) EnumDescriptor added in v0.5.0 

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

func (TransationControl_TclType) String added in v0.5.0 

func (x TransationControl_TclType) String() string

type TransationRollback added in v0.5.0 

type TransationRollback struct {
	CompletionType       TransationCompletionType `` /* 139-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*TransationRollback) Descriptor added in v0.5.0 

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

func (*TransationRollback) GetCompletionType added in v0.5.0 

func (m *TransationRollback) GetCompletionType() TransationCompletionType

func (*TransationRollback) Marshal added in v0.5.0 

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

func (*TransationRollback) MarshalTo added in v0.5.0 

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

func (*TransationRollback) MarshalToSizedBuffer added in v0.5.0 

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

func (*TransationRollback) ProtoMessage added in v0.5.0 

func (*TransationRollback) ProtoMessage()

func (*TransationRollback) ProtoSize added in v0.5.0 

func (m *TransationRollback) ProtoSize() (n int)

func (*TransationRollback) Reset added in v0.5.0 

func (m *TransationRollback) Reset()

func (*TransationRollback) String added in v0.5.0 

func (m *TransationRollback) String() string

func (*TransationRollback) Unmarshal added in v0.5.0 

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

func (*TransationRollback) XXX_DiscardUnknown added in v0.5.0 

func (m *TransationRollback) XXX_DiscardUnknown()

func (*TransationRollback) XXX_Marshal added in v0.5.0 

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

func (*TransationRollback) XXX_Merge added in v0.5.0 

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

func (*TransationRollback) XXX_Size added in v0.5.0 

func (m *TransationRollback) XXX_Size() int

func (*TransationRollback) XXX_Unmarshal added in v0.5.0 

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

type TruncateTable added in v0.5.0 

type TruncateTable struct {
	Database             string        `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table                string        `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	IndexTableNames      []string      `protobuf:"bytes,3,rep,name=index_table_names,json=indexTableNames,proto3" json:"index_table_names,omitempty"`
	ClusterTable         *ClusterTable `protobuf:"bytes,4,opt,name=cluster_table,json=clusterTable,proto3" json:"cluster_table,omitempty"`
	TableId              uint64        `protobuf:"varint,5,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	ForeignTbl           []uint64      `protobuf:"varint,6,rep,packed,name=foreign_tbl,json=foreignTbl,proto3" json:"foreign_tbl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*TruncateTable) Descriptor added in v0.5.0 

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

func (*TruncateTable) GetClusterTable added in v0.7.0 

func (m *TruncateTable) GetClusterTable() *ClusterTable

func (*TruncateTable) GetDatabase added in v0.6.0 

func (m *TruncateTable) GetDatabase() string

func (*TruncateTable) GetForeignTbl added in v0.7.0 

func (m *TruncateTable) GetForeignTbl() []uint64

func (*TruncateTable) GetIndexTableNames added in v0.6.0 

func (m *TruncateTable) GetIndexTableNames() []string

func (*TruncateTable) GetTable added in v0.5.0 

func (m *TruncateTable) GetTable() string

func (*TruncateTable) GetTableId added in v0.7.0 

func (m *TruncateTable) GetTableId() uint64

func (*TruncateTable) Marshal added in v0.5.0 

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

func (*TruncateTable) MarshalTo added in v0.5.0 

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

func (*TruncateTable) MarshalToSizedBuffer added in v0.5.0 

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

func (*TruncateTable) ProtoMessage added in v0.5.0 

func (*TruncateTable) ProtoMessage()

func (*TruncateTable) ProtoSize added in v0.5.0 

func (m *TruncateTable) ProtoSize() (n int)

func (*TruncateTable) Reset added in v0.5.0 

func (m *TruncateTable) Reset()

func (*TruncateTable) String added in v0.5.0 

func (m *TruncateTable) String() string

func (*TruncateTable) Unmarshal added in v0.5.0 

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

func (*TruncateTable) XXX_DiscardUnknown added in v0.5.0 

func (m *TruncateTable) XXX_DiscardUnknown()

func (*TruncateTable) XXX_Marshal added in v0.5.0 

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

func (*TruncateTable) XXX_Merge added in v0.5.0 

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

func (*TruncateTable) XXX_Size added in v0.5.0 

func (m *TruncateTable) XXX_Size() int

func (*TruncateTable) XXX_Unmarshal added in v0.5.0 

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

type Type 

type Type struct {
	Id                   int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	NotNullable          bool     `protobuf:"varint,2,opt,name=notNullable,proto3" json:"notNullable,omitempty"`
	AutoIncr             bool     `protobuf:"varint,3,opt,name=auto_incr,json=autoIncr,proto3" json:"auto_incr,omitempty"`
	Width                int32    `protobuf:"varint,4,opt,name=width,proto3" json:"width,omitempty"`
	Precision            int32    `protobuf:"varint,5,opt,name=precision,proto3" json:"precision,omitempty"`
	Size                 int32    `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	Scale                int32    `protobuf:"varint,7,opt,name=scale,proto3" json:"scale,omitempty"`
	Table                string   `protobuf:"bytes,8,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Type) Descriptor 

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

func (*Type) GetAutoIncr added in v0.6.0 

func (m *Type) GetAutoIncr() bool

func (*Type) GetId 

func (m *Type) GetId() int32

func (*Type) GetNotNullable added in v0.7.0 

func (m *Type) GetNotNullable() bool

func (*Type) GetPrecision 

func (m *Type) GetPrecision() int32

func (*Type) GetScale added in v0.5.0 

func (m *Type) GetScale() int32

func (*Type) GetSize added in v0.5.0 

func (m *Type) GetSize() int32

func (*Type) GetTable added in v0.6.0 

func (m *Type) GetTable() string

func (*Type) GetWidth 

func (m *Type) GetWidth() int32

func (*Type) Marshal added in v0.5.0 

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

func (*Type) MarshalTo added in v0.5.0 

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

func (*Type) MarshalToSizedBuffer added in v0.5.0 

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

func (*Type) ProtoMessage 

func (*Type) ProtoMessage()

func (*Type) ProtoSize added in v0.5.0 

func (m *Type) ProtoSize() (n int)

func (*Type) Reset 

func (m *Type) Reset()

func (*Type) String 

func (m *Type) String() string

func (*Type) Unmarshal added in v0.5.0 

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

func (*Type) XXX_DiscardUnknown added in v0.5.0 

func (m *Type) XXX_DiscardUnknown()

func (*Type) XXX_Marshal added in v0.5.0 

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

func (*Type) XXX_Merge added in v0.5.0 

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

func (*Type) XXX_Size added in v0.5.0 

func (m *Type) XXX_Size() int

func (*Type) XXX_Unmarshal added in v0.5.0 

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

type UpdateCtx added in v0.6.0 

type UpdateCtx struct {
	Ref                  []*ObjectRef `protobuf:"bytes,1,rep,name=ref,proto3" json:"ref,omitempty"`
	Idx                  []*IdList    `protobuf:"bytes,2,rep,name=idx,proto3" json:"idx,omitempty"`
	TableDefs            []*TableDef  `protobuf:"bytes,3,rep,name=tableDefs,proto3" json:"tableDefs,omitempty"`
	UpdateCol            []*ColPosMap `protobuf:"bytes,4,rep,name=update_col,json=updateCol,proto3" json:"update_col,omitempty"`
	IdxRef               []*ObjectRef `protobuf:"bytes,5,rep,name=idx_ref,json=idxRef,proto3" json:"idx_ref,omitempty"`
	IdxIdx               []int32      `protobuf:"varint,6,rep,packed,name=idx_idx,json=idxIdx,proto3" json:"idx_idx,omitempty"`
	OnRestrictRef        []*ObjectRef `protobuf:"bytes,7,rep,name=on_restrict_ref,json=onRestrictRef,proto3" json:"on_restrict_ref,omitempty"`
	OnRestrictIdx        []int32      `protobuf:"varint,8,rep,packed,name=on_restrict_idx,json=onRestrictIdx,proto3" json:"on_restrict_idx,omitempty"`
	OnCascadeRef         []*ObjectRef `protobuf:"bytes,9,rep,name=on_cascade_ref,json=onCascadeRef,proto3" json:"on_cascade_ref,omitempty"`
	OnCascadeIdx         []*IdList    `protobuf:"bytes,10,rep,name=on_cascade_idx,json=onCascadeIdx,proto3" json:"on_cascade_idx,omitempty"`
	OnCascadeDef         []*TableDef  `protobuf:"bytes,11,rep,name=on_cascade_def,json=onCascadeDef,proto3" json:"on_cascade_def,omitempty"`
	OnCascadeUpdateCol   []*ColPosMap `protobuf:"bytes,12,rep,name=on_cascade_update_col,json=onCascadeUpdateCol,proto3" json:"on_cascade_update_col,omitempty"`
	OnSetRef             []*ObjectRef `protobuf:"bytes,13,rep,name=on_set_ref,json=onSetRef,proto3" json:"on_set_ref,omitempty"`
	OnSetIdx             []*IdList    `protobuf:"bytes,14,rep,name=on_set_idx,json=onSetIdx,proto3" json:"on_set_idx,omitempty"`
	OnSetDef             []*TableDef  `protobuf:"bytes,15,rep,name=on_set_def,json=onSetDef,proto3" json:"on_set_def,omitempty"`
	OnSetUpdateCol       []*ColPosMap `protobuf:"bytes,16,rep,name=on_set_update_col,json=onSetUpdateCol,proto3" json:"on_set_update_col,omitempty"`
	ParentIdx            []*ColPosMap `protobuf:"bytes,17,rep,name=parent_idx,json=parentIdx,proto3" json:"parent_idx,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*UpdateCtx) Descriptor added in v0.6.0 

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

func (*UpdateCtx) GetIdx added in v0.7.0 

func (m *UpdateCtx) GetIdx() []*IdList

func (*UpdateCtx) GetIdxIdx added in v0.7.0 

func (m *UpdateCtx) GetIdxIdx() []int32

func (*UpdateCtx) GetIdxRef added in v0.7.0 

func (m *UpdateCtx) GetIdxRef() []*ObjectRef

func (*UpdateCtx) GetOnCascadeDef added in v0.7.0 

func (m *UpdateCtx) GetOnCascadeDef() []*TableDef

func (*UpdateCtx) GetOnCascadeIdx added in v0.7.0 

func (m *UpdateCtx) GetOnCascadeIdx() []*IdList

func (*UpdateCtx) GetOnCascadeRef added in v0.7.0 

func (m *UpdateCtx) GetOnCascadeRef() []*ObjectRef

func (*UpdateCtx) GetOnCascadeUpdateCol added in v0.7.0 

func (m *UpdateCtx) GetOnCascadeUpdateCol() []*ColPosMap

func (*UpdateCtx) GetOnRestrictIdx added in v0.7.0 

func (m *UpdateCtx) GetOnRestrictIdx() []int32

func (*UpdateCtx) GetOnRestrictRef added in v0.7.0 

func (m *UpdateCtx) GetOnRestrictRef() []*ObjectRef

func (*UpdateCtx) GetOnSetDef added in v0.7.0 

func (m *UpdateCtx) GetOnSetDef() []*TableDef

func (*UpdateCtx) GetOnSetIdx added in v0.7.0 

func (m *UpdateCtx) GetOnSetIdx() []*IdList

func (*UpdateCtx) GetOnSetRef added in v0.7.0 

func (m *UpdateCtx) GetOnSetRef() []*ObjectRef

func (*UpdateCtx) GetOnSetUpdateCol added in v0.7.0 

func (m *UpdateCtx) GetOnSetUpdateCol() []*ColPosMap

func (*UpdateCtx) GetParentIdx added in v0.7.0 

func (m *UpdateCtx) GetParentIdx() []*ColPosMap

func (*UpdateCtx) GetRef added in v0.7.0 

func (m *UpdateCtx) GetRef() []*ObjectRef

func (*UpdateCtx) GetTableDefs added in v0.7.0 

func (m *UpdateCtx) GetTableDefs() []*TableDef

func (*UpdateCtx) GetUpdateCol added in v0.7.0 

func (m *UpdateCtx) GetUpdateCol() []*ColPosMap

func (*UpdateCtx) Marshal added in v0.6.0 

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

func (*UpdateCtx) MarshalTo added in v0.6.0 

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

func (*UpdateCtx) MarshalToSizedBuffer added in v0.6.0 

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

func (*UpdateCtx) ProtoMessage added in v0.6.0 

func (*UpdateCtx) ProtoMessage()

func (*UpdateCtx) ProtoSize added in v0.6.0 

func (m *UpdateCtx) ProtoSize() (n int)

func (*UpdateCtx) Reset added in v0.6.0 

func (m *UpdateCtx) Reset()

func (*UpdateCtx) String added in v0.6.0 

func (m *UpdateCtx) String() string

func (*UpdateCtx) Unmarshal added in v0.6.0 

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

func (*UpdateCtx) XXX_DiscardUnknown added in v0.6.0 

func (m *UpdateCtx) XXX_DiscardUnknown()

func (*UpdateCtx) XXX_Marshal added in v0.6.0 

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

func (*UpdateCtx) XXX_Merge added in v0.6.0 

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

func (*UpdateCtx) XXX_Size added in v0.6.0 

func (m *UpdateCtx) XXX_Size() int

func (*UpdateCtx) XXX_Unmarshal added in v0.6.0 

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

type VarRef 

type VarRef struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	System               bool     `protobuf:"varint,2,opt,name=system,proto3" json:"system,omitempty"`
	Global               bool     `protobuf:"varint,3,opt,name=global,proto3" json:"global,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Session variable ref, compiler should fold.

func (*VarRef) Descriptor 

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

func (*VarRef) GetGlobal added in v0.6.0 

func (m *VarRef) GetGlobal() bool

func (*VarRef) GetName 

func (m *VarRef) GetName() string

func (*VarRef) GetSystem added in v0.6.0 

func (m *VarRef) GetSystem() bool

func (*VarRef) Marshal added in v0.5.0 

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

func (*VarRef) MarshalTo added in v0.5.0 

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

func (*VarRef) MarshalToSizedBuffer added in v0.5.0 

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

func (*VarRef) ProtoMessage 

func (*VarRef) ProtoMessage()

func (*VarRef) ProtoSize added in v0.5.0 

func (m *VarRef) ProtoSize() (n int)

func (*VarRef) Reset 

func (m *VarRef) Reset()

func (*VarRef) String 

func (m *VarRef) String() string

func (*VarRef) Unmarshal added in v0.5.0 

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

func (*VarRef) XXX_DiscardUnknown added in v0.5.0 

func (m *VarRef) XXX_DiscardUnknown()

func (*VarRef) XXX_Marshal added in v0.5.0 

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

func (*VarRef) XXX_Merge added in v0.5.0 

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

func (*VarRef) XXX_Size added in v0.5.0 

func (m *VarRef) XXX_Size() int

func (*VarRef) XXX_Unmarshal added in v0.5.0 

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

type ViewDef added in v0.6.0 

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

func (*ViewDef) Descriptor added in v0.6.0 

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

func (*ViewDef) GetView added in v0.6.0 

func (m *ViewDef) GetView() string

func (*ViewDef) Marshal added in v0.6.0 

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

func (*ViewDef) MarshalTo added in v0.6.0 

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

func (*ViewDef) MarshalToSizedBuffer added in v0.6.0 

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

func (*ViewDef) ProtoMessage added in v0.6.0 

func (*ViewDef) ProtoMessage()

func (*ViewDef) ProtoSize added in v0.6.0 

func (m *ViewDef) ProtoSize() (n int)

func (*ViewDef) Reset added in v0.6.0 

func (m *ViewDef) Reset()

func (*ViewDef) String added in v0.6.0 

func (m *ViewDef) String() string

func (*ViewDef) Unmarshal added in v0.6.0 

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

func (*ViewDef) XXX_DiscardUnknown added in v0.6.0 

func (m *ViewDef) XXX_DiscardUnknown()

func (*ViewDef) XXX_Marshal added in v0.6.0 

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

func (*ViewDef) XXX_Merge added in v0.6.0 

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

func (*ViewDef) XXX_Size added in v0.6.0 

func (m *ViewDef) XXX_Size() int

func (*ViewDef) XXX_Unmarshal added in v0.6.0 

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

type WindowSpec 

type WindowSpec struct {
	PartitionBy          []*Expr        `protobuf:"bytes,1,rep,name=partition_by,json=partitionBy,proto3" json:"partition_by,omitempty"`
	OrderBy              []*OrderBySpec `protobuf:"bytes,2,rep,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	Lead                 int32          `protobuf:"varint,3,opt,name=lead,proto3" json:"lead,omitempty"`
	Lag                  int32          `protobuf:"varint,4,opt,name=lag,proto3" json:"lag,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*WindowSpec) Descriptor 

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

func (*WindowSpec) GetLag 

func (m *WindowSpec) GetLag() int32

func (*WindowSpec) GetLead 

func (m *WindowSpec) GetLead() int32

func (*WindowSpec) GetOrderBy added in v0.5.0 

func (m *WindowSpec) GetOrderBy() []*OrderBySpec

func (*WindowSpec) GetPartitionBy 

func (m *WindowSpec) GetPartitionBy() []*Expr

func (*WindowSpec) Marshal added in v0.5.0 

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

func (*WindowSpec) MarshalTo added in v0.5.0 

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

func (*WindowSpec) MarshalToSizedBuffer added in v0.5.0 

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

func (*WindowSpec) ProtoMessage 

func (*WindowSpec) ProtoMessage()

func (*WindowSpec) ProtoSize added in v0.5.0 

func (m *WindowSpec) ProtoSize() (n int)

func (*WindowSpec) Reset 

func (m *WindowSpec) Reset()

func (*WindowSpec) String 

func (m *WindowSpec) String() string

func (*WindowSpec) Unmarshal added in v0.5.0 

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

func (*WindowSpec) XXX_DiscardUnknown added in v0.5.0 

func (m *WindowSpec) XXX_DiscardUnknown()

func (*WindowSpec) XXX_Marshal added in v0.5.0 

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

func (*WindowSpec) XXX_Merge added in v0.5.0 

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

func (*WindowSpec) XXX_Size added in v0.5.0 

func (m *WindowSpec) XXX_Size() int

func (*WindowSpec) XXX_Unmarshal added in v0.5.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.