plan

package

Go to main page

Versions in this module

v1

v1.2.4

Sep 20, 2024

v1.2.3

Sep 10, 2024

Changes in this version

type Node

+ IfInsertFromUnique bool

+ func (m *Node) GetIfInsertFromUnique() bool

v1.2.3-hotfix-20241101

Oct 31, 2024

v1.2.3-hotfix-20241016

Oct 16, 2024

v1.2.3-hotfix-20241010

Oct 11, 2024

v1.2.3-hotfix-20240916

Sep 14, 2024

v1.2.2

Jul 11, 2024

v1.2.2-20240715

Jul 15, 2024

v1.2.1

Jun 28, 2024

Changes in this version

+ type CreateView struct

+ Database string

+ IfNotExists bool

+ Replace bool

+ TableDef *TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateView) Descriptor() ([]byte, []int)

+ func (*CreateView) ProtoMessage()

+ func (m *CreateView) GetDatabase() string

+ func (m *CreateView) GetIfNotExists() bool

+ func (m *CreateView) GetReplace() bool

+ func (m *CreateView) GetTableDef() *TableDef

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

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

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

+ func (m *CreateView) ProtoSize() (n int)

+ func (m *CreateView) Reset()

+ func (m *CreateView) String() string

+ func (m *CreateView) Unmarshal(dAtA []byte) error

+ func (m *CreateView) XXX_DiscardUnknown()

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

+ func (m *CreateView) XXX_Merge(src proto.Message)

+ func (m *CreateView) XXX_Size() int

+ func (m *CreateView) XXX_Unmarshal(b []byte) error

type DataDefinition

+ func (m *DataDefinition) GetCreateView() *CreateView

+ type DataDefinition_CreateView struct

+ CreateView *CreateView

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

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

+ func (m *DataDefinition_CreateView) ProtoSize() (n int)

type ReplaceCtx

+ RewriteFromOnDuplicateKey bool

+ func (m *ReplaceCtx) GetRewriteFromOnDuplicateKey() bool

v1.2.1-20240709

Jul 9, 2024

v1.2.0

May 17, 2024

Changes in this version

+ type AlterAddColumn struct

+ Name string

+ Pos int32

+ PreName string

+ Type Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterAddColumn) Descriptor() ([]byte, []int)

+ func (*AlterAddColumn) ProtoMessage()

+ func (m *AlterAddColumn) GetName() string

+ func (m *AlterAddColumn) GetPos() int32

+ func (m *AlterAddColumn) GetPreName() string

+ func (m *AlterAddColumn) GetType() Type

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

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

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

+ func (m *AlterAddColumn) ProtoSize() (n int)

+ func (m *AlterAddColumn) Reset()

+ func (m *AlterAddColumn) String() string

+ func (m *AlterAddColumn) Unmarshal(dAtA []byte) error

+ func (m *AlterAddColumn) XXX_DiscardUnknown()

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

+ func (m *AlterAddColumn) XXX_Merge(src proto.Message)

+ func (m *AlterAddColumn) XXX_Size() int

+ func (m *AlterAddColumn) XXX_Unmarshal(b []byte) error

+ type AlterDropColumn struct

+ Idx uint32

+ Seq uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterDropColumn) Descriptor() ([]byte, []int)

+ func (*AlterDropColumn) ProtoMessage()

+ func (m *AlterDropColumn) GetIdx() uint32

+ func (m *AlterDropColumn) GetSeq() uint32

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

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

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

+ func (m *AlterDropColumn) ProtoSize() (n int)

+ func (m *AlterDropColumn) Reset()

+ func (m *AlterDropColumn) String() string

+ func (m *AlterDropColumn) Unmarshal(dAtA []byte) error

+ func (m *AlterDropColumn) XXX_DiscardUnknown()

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

+ func (m *AlterDropColumn) XXX_Merge(src proto.Message)

+ func (m *AlterDropColumn) XXX_Size() int

+ func (m *AlterDropColumn) XXX_Unmarshal(b []byte) error

+ type AlterTableAddPartition struct

+ Definitions []*PartitionItem

+ PartitionDef *PartitionByDef

+ PartitionTables []*TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableAddPartition) Descriptor() ([]byte, []int)

+ func (*AlterTableAddPartition) ProtoMessage()

+ func (m *AlterTableAddPartition) GetDefinitions() []*PartitionItem

+ func (m *AlterTableAddPartition) GetPartitionDef() *PartitionByDef

+ func (m *AlterTableAddPartition) GetPartitionTables() []*TableDef

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

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

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

+ func (m *AlterTableAddPartition) ProtoSize() (n int)

+ func (m *AlterTableAddPartition) Reset()

+ func (m *AlterTableAddPartition) String() string

+ func (m *AlterTableAddPartition) Unmarshal(dAtA []byte) error

+ func (m *AlterTableAddPartition) XXX_DiscardUnknown()

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

+ func (m *AlterTableAddPartition) XXX_Merge(src proto.Message)

+ func (m *AlterTableAddPartition) XXX_Size() int

+ func (m *AlterTableAddPartition) XXX_Unmarshal(b []byte) error

type AlterTable_Action

+ func (m *AlterTable_Action) GetAddColumn() *AlterAddColumn

+ func (m *AlterTable_Action) GetAddPartition() *AlterTableAddPartition

+ func (m *AlterTable_Action) GetDropColumn() *AlterDropColumn

+ type AlterTable_Action_AddColumn struct

+ AddColumn *AlterAddColumn

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

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

+ func (m *AlterTable_Action_AddColumn) ProtoSize() (n int)

+ type AlterTable_Action_AddPartition struct

+ AddPartition *AlterTableAddPartition

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

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

+ func (m *AlterTable_Action_AddPartition) ProtoSize() (n int)

+ type AlterTable_Action_DropColumn struct

+ DropColumn *AlterDropColumn

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

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

+ func (m *AlterTable_Action_DropColumn) ProtoSize() (n int)

type DataControl

+ func (m *DataControl) GetOther() *OtherDCL

type DataControl_DclType

+ const DataControl_ALTER_ACCOUNT

+ const DataControl_CREATE_ACCOUNT

+ const DataControl_DROP_ACCOUNT

+ type DataControl_Other struct

+ Other *OtherDCL

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

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

+ func (m *DataControl_Other) ProtoSize() (n int)

type DataDefinition_DdlType

+ const DataDefinition_SHOW_UPGRADE

type ExternScan

+ EscapedBy []byte

+ func (m *ExternScan) GetEscapedBy() []byte

+ type MsgHeader struct

+ MsgTag int32

+ MsgType int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MsgHeader) Descriptor() ([]byte, []int)

+ func (*MsgHeader) ProtoMessage()

+ func (m *MsgHeader) GetMsgTag() int32

+ func (m *MsgHeader) GetMsgType() int32

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

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

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

+ func (m *MsgHeader) ProtoSize() (n int)

+ func (m *MsgHeader) Reset()

+ func (m *MsgHeader) String() string

+ func (m *MsgHeader) Unmarshal(dAtA []byte) error

+ func (m *MsgHeader) XXX_DiscardUnknown()

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

+ func (m *MsgHeader) XXX_Merge(src proto.Message)

+ func (m *MsgHeader) XXX_Size() int

+ func (m *MsgHeader) XXX_Unmarshal(b []byte) error

type Node

+ RecvMsgList []*MsgHeader

+ ScanSnapshot *Snapshot

+ SendMsgList []*MsgHeader

+ func (m *Node) GetRecvMsgList() []*MsgHeader

+ func (m *Node) GetScanSnapshot() *Snapshot

+ func (m *Node) GetSendMsgList() []*MsgHeader

type Node_JoinType

+ const Node_INDEX

type OnDuplicateKeyCtx

+ Attrs []string

+ InsertColCount int32

+ TableId uint64

+ TableName string

+ TableVersion uint32

+ UniqueColCheckExpr []*Expr

+ UniqueCols []string

+ func (m *OnDuplicateKeyCtx) GetAttrs() []string

+ func (m *OnDuplicateKeyCtx) GetInsertColCount() int32

+ func (m *OnDuplicateKeyCtx) GetTableId() uint64

+ func (m *OnDuplicateKeyCtx) GetTableName() string

+ func (m *OnDuplicateKeyCtx) GetTableVersion() uint32

+ func (m *OnDuplicateKeyCtx) GetUniqueColCheckExpr() []*Expr

+ func (m *OnDuplicateKeyCtx) GetUniqueCols() []string

+ type OtherDCL struct

+ ParamTypes []int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OtherDCL) Descriptor() ([]byte, []int)

+ func (*OtherDCL) ProtoMessage()

+ func (m *OtherDCL) GetParamTypes() []int32

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

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

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

+ func (m *OtherDCL) ProtoSize() (n int)

+ func (m *OtherDCL) Reset()

+ func (m *OtherDCL) String() string

+ func (m *OtherDCL) Unmarshal(dAtA []byte) error

+ func (m *OtherDCL) XXX_DiscardUnknown()

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

+ func (m *OtherDCL) XXX_Merge(src proto.Message)

+ func (m *OtherDCL) XXX_Size() int

+ func (m *OtherDCL) XXX_Unmarshal(b []byte) error

type RowsetData

+ RowCount int32

+ func (m *RowsetData) GetRowCount() int32

type RuntimeFilterSpec

+ Handled bool

+ MatchPrefix bool

+ UpperLimit int32

+ func (m *RuntimeFilterSpec) GetHandled() bool

+ func (m *RuntimeFilterSpec) GetMatchPrefix() bool

+ func (m *RuntimeFilterSpec) GetUpperLimit() int32

type SampleFuncSpec

+ UsingRow bool

+ func (m *SampleFuncSpec) GetUsingRow() bool

+ type Snapshot struct

+ TS *timestamp.Timestamp

+ Tenant *SnapshotTenant

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Snapshot) Descriptor() ([]byte, []int)

+ func (*Snapshot) ProtoMessage()

+ func (m *Snapshot) GetTS() *timestamp.Timestamp

+ func (m *Snapshot) GetTenant() *SnapshotTenant

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

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

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

+ func (m *Snapshot) ProtoSize() (n int)

+ func (m *Snapshot) Reset()

+ func (m *Snapshot) String() string

+ func (m *Snapshot) Unmarshal(dAtA []byte) error

+ func (m *Snapshot) XXX_DiscardUnknown()

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

+ func (m *Snapshot) XXX_Merge(src proto.Message)

+ func (m *Snapshot) XXX_Size() int

+ func (m *Snapshot) XXX_Unmarshal(b []byte) error

+ type SnapshotTenant struct

+ TenantID uint32

+ TenantName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SnapshotTenant) Descriptor() ([]byte, []int)

+ func (*SnapshotTenant) ProtoMessage()

+ func (m *SnapshotTenant) GetTenantID() uint32

+ func (m *SnapshotTenant) GetTenantName() string

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

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

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

+ func (m *SnapshotTenant) ProtoSize() (n int)

+ func (m *SnapshotTenant) Reset()

+ func (m *SnapshotTenant) String() string

+ func (m *SnapshotTenant) Unmarshal(dAtA []byte) error

+ func (m *SnapshotTenant) XXX_DiscardUnknown()

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

+ func (m *SnapshotTenant) XXX_Merge(src proto.Message)

+ func (m *SnapshotTenant) XXX_Size() int

+ func (m *SnapshotTenant) XXX_Unmarshal(b []byte) error

type Stats

+ ForceOneCN bool

+ func (m *Stats) GetForceOneCN() bool

type Type

+ func (t *Type) IsEmpty() bool

v1.1.3

Apr 15, 2024

v1.1.2

Apr 2, 2024

Changes in this version

type AlterTable

+ DetectSqls []string

+ UpdateFkSqls []string

+ func (m *AlterTable) GetDetectSqls() []string

+ func (m *AlterTable) GetUpdateFkSqls() []string

type ColDef

+ DbName string

+ TblName string

+ func (m *ColDef) GetDbName() string

+ func (m *ColDef) GetTblName() string

type ColRef

+ DbName string

+ TblName string

+ func (m *ColRef) GetDbName() string

+ func (m *ColRef) GetTblName() string

type CreateTable

+ CreateAsSelectSql string

+ FksReferToMe []*ForeignKeyInfo

+ UpdateFkSqls []string

+ func (m *CreateTable) GetCreateAsSelectSql() string

+ func (m *CreateTable) GetFksReferToMe() []*ForeignKeyInfo

+ func (m *CreateTable) GetUpdateFkSqls() []string

type DropDatabase

+ CheckFKSql string

+ UpdateFkSql string

+ func (m *DropDatabase) GetCheckFKSql() string

+ func (m *DropDatabase) GetUpdateFkSql() string

type DropTable

+ FkChildTblsReferToMe []uint64

+ UpdateFkSqls []string

+ func (m *DropTable) GetFkChildTblsReferToMe() []uint64

+ func (m *DropTable) GetUpdateFkSqls() []string

+ type ForeignKeyInfo struct

+ Cols *FkColName

+ ColsReferred *FkColName

+ Db string

+ Def *ForeignKeyDef

+ Table string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ForeignKeyInfo) Descriptor() ([]byte, []int)

+ func (*ForeignKeyInfo) ProtoMessage()

+ func (m *ForeignKeyInfo) GetCols() *FkColName

+ func (m *ForeignKeyInfo) GetColsReferred() *FkColName

+ func (m *ForeignKeyInfo) GetDb() string

+ func (m *ForeignKeyInfo) GetDef() *ForeignKeyDef

+ func (m *ForeignKeyInfo) GetTable() string

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

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

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

+ func (m *ForeignKeyInfo) ProtoSize() (n int)

+ func (m *ForeignKeyInfo) Reset()

+ func (m *ForeignKeyInfo) String() string

+ func (m *ForeignKeyInfo) Unmarshal(dAtA []byte) error

+ func (m *ForeignKeyInfo) XXX_DiscardUnknown()

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

+ func (m *ForeignKeyInfo) XXX_Merge(src proto.Message)

+ func (m *ForeignKeyInfo) XXX_Size() int

+ func (m *ForeignKeyInfo) XXX_Unmarshal(b []byte) error

type Query

+ DetectSqls []string

+ func (m *Query) GetDetectSqls() []string

type TableDef

+ DbName string

+ func (m *TableDef) GetDbName() string

v1.1.1

Feb 2, 2024

Changes in this version

type Node

+ ParentObjRef *ObjectRef

+ func (m *Node) GetParentObjRef() *ObjectRef

type Node_NodeType

+ const Node_FILL

v1.1.0

Dec 29, 2023

Changes in this version

+ var Node_FillType_name = map[int32]string

+ var Node_FillType_value = map[string]int32

+ type AlterTableAlterReIndex struct

+ DbName string

+ IndexAlgoParamList int64

+ IndexName string

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableAlterReIndex) Descriptor() ([]byte, []int)

+ func (*AlterTableAlterReIndex) ProtoMessage()

+ func (m *AlterTableAlterReIndex) GetDbName() string

+ func (m *AlterTableAlterReIndex) GetIndexAlgoParamList() int64

+ func (m *AlterTableAlterReIndex) GetIndexName() string

+ func (m *AlterTableAlterReIndex) GetTableName() string

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

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

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

+ func (m *AlterTableAlterReIndex) ProtoSize() (n int)

+ func (m *AlterTableAlterReIndex) Reset()

+ func (m *AlterTableAlterReIndex) String() string

+ func (m *AlterTableAlterReIndex) Unmarshal(dAtA []byte) error

+ func (m *AlterTableAlterReIndex) XXX_DiscardUnknown()

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

+ func (m *AlterTableAlterReIndex) XXX_Merge(src proto.Message)

+ func (m *AlterTableAlterReIndex) XXX_Size() int

+ func (m *AlterTableAlterReIndex) XXX_Unmarshal(b []byte) error

type AlterTable_Action

+ func (m *AlterTable_Action) GetAlterReindex() *AlterTableAlterReIndex

+ type AlterTable_Action_AlterReindex struct

+ AlterReindex *AlterTableAlterReIndex

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

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

+ func (m *AlterTable_Action_AlterReindex) ProtoSize() (n int)

type AnalyzeInfo

+ TimeConsumedArrayMajor []int64

+ TimeConsumedArrayMinor []int64

+ func (m *AnalyzeInfo) GetTimeConsumedArrayMajor() []int64

+ func (m *AnalyzeInfo) GetTimeConsumedArrayMinor() []int64

type DataDefinition_DdlType

+ const DataDefinition_SHOW_CONNECTORS

type DeleteCtx

+ TableDef *TableDef

+ TruncateTable *TruncateTable

+ func (m *DeleteCtx) GetTableDef() *TableDef

+ func (m *DeleteCtx) GetTruncateTable() *TruncateTable

type Expr

+ func (m *Expr) GetLit() *Literal

+ func (m *Expr) GetVec() *LiteralVec

+ type Expr_Lit struct

+ Lit *Literal

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

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

+ func (m *Expr_Lit) ProtoSize() (n int)

+ type Expr_Vec struct

+ Vec *LiteralVec

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

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

+ func (m *Expr_Vec) ProtoSize() (n int)

type ExternScan

+ JsonType string

+ func (m *ExternScan) GetJsonType() string

type Function_FuncFlag

+ const Function_ZONEMAPPABLE

type HashMapStats

+ Nullcnt int64

+ Ranges []float64

+ func (m *HashMapStats) GetNullcnt() int64

+ func (m *HashMapStats) GetRanges() []float64

type IndexDef

+ IndexAlgo string

+ IndexAlgoParams string

+ IndexAlgoTableType string

+ func (m *IndexDef) GetIndexAlgo() string

+ func (m *IndexDef) GetIndexAlgoParams() string

+ func (m *IndexDef) GetIndexAlgoTableType() string

+ type Literal struct

+ IsBin bool

+ Isnull bool

+ Src *Expr

+ Value isLiteral_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Literal) Descriptor() ([]byte, []int)

+ func (*Literal) ProtoMessage()

+ func (*Literal) XXX_OneofWrappers() []interface{}

+ func (m *Literal) GetBval() bool

+ func (m *Literal) GetDatetimeval() int64

+ func (m *Literal) GetDateval() int32

+ func (m *Literal) GetDecimal128Val() *Decimal128

+ func (m *Literal) GetDecimal64Val() *Decimal64

+ func (m *Literal) GetDefaultval() bool

+ func (m *Literal) GetDval() float64

+ func (m *Literal) GetEnumVal() uint32

+ func (m *Literal) GetFval() float32

+ func (m *Literal) GetI16Val() int32

+ func (m *Literal) GetI32Val() int32

+ func (m *Literal) GetI64Val() int64

+ func (m *Literal) GetI8Val() int32

+ func (m *Literal) GetIsBin() bool

+ func (m *Literal) GetIsnull() bool

+ func (m *Literal) GetJsonval() string

+ func (m *Literal) GetSrc() *Expr

+ func (m *Literal) GetSval() string

+ func (m *Literal) GetTimestampval() int64

+ func (m *Literal) GetTimeval() int64

+ func (m *Literal) GetU16Val() uint32

+ func (m *Literal) GetU32Val() uint32

+ func (m *Literal) GetU64Val() uint64

+ func (m *Literal) GetU8Val() uint32

+ func (m *Literal) GetUpdateVal() bool

+ func (m *Literal) GetValue() isLiteral_Value

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

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

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

+ func (m *Literal) ProtoSize() (n int)

+ func (m *Literal) Reset()

+ func (m *Literal) String() string

+ func (m *Literal) Unmarshal(dAtA []byte) error

+ func (m *Literal) XXX_DiscardUnknown()

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

+ func (m *Literal) XXX_Merge(src proto.Message)

+ func (m *Literal) XXX_Size() int

+ func (m *Literal) XXX_Unmarshal(b []byte) error

+ type LiteralVec struct

+ Data []byte

+ Len int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LiteralVec) Descriptor() ([]byte, []int)

+ func (*LiteralVec) ProtoMessage()

+ func (m *LiteralVec) GetData() []byte

+ func (m *LiteralVec) GetLen() int32

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

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

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

+ func (m *LiteralVec) ProtoSize() (n int)

+ func (m *LiteralVec) Reset()

+ func (m *LiteralVec) String() string

+ func (m *LiteralVec) Unmarshal(dAtA []byte) error

+ func (m *LiteralVec) XXX_DiscardUnknown()

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

+ func (m *LiteralVec) XXX_Merge(src proto.Message)

+ func (m *LiteralVec) XXX_Size() int

+ func (m *LiteralVec) XXX_Unmarshal(b []byte) error

+ type Literal_Bval struct

+ Bval bool

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

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

+ func (m *Literal_Bval) ProtoSize() (n int)

+ type Literal_Datetimeval struct

+ Datetimeval int64

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

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

+ func (m *Literal_Datetimeval) ProtoSize() (n int)

+ type Literal_Dateval struct

+ Dateval int32

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

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

+ func (m *Literal_Dateval) ProtoSize() (n int)

+ type Literal_Decimal128Val struct

+ Decimal128Val *Decimal128

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

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

+ func (m *Literal_Decimal128Val) ProtoSize() (n int)

+ type Literal_Decimal64Val struct

+ Decimal64Val *Decimal64

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

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

+ func (m *Literal_Decimal64Val) ProtoSize() (n int)

+ type Literal_Defaultval struct

+ Defaultval bool

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

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

+ func (m *Literal_Defaultval) ProtoSize() (n int)

+ type Literal_Dval struct

+ Dval float64

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

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

+ func (m *Literal_Dval) ProtoSize() (n int)

+ type Literal_EnumVal struct

+ EnumVal uint32

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

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

+ func (m *Literal_EnumVal) ProtoSize() (n int)

+ type Literal_Fval struct

+ Fval float32

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

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

+ func (m *Literal_Fval) ProtoSize() (n int)

+ type Literal_I16Val struct

+ I16Val int32

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

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

+ func (m *Literal_I16Val) ProtoSize() (n int)

+ type Literal_I32Val struct

+ I32Val int32

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

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

+ func (m *Literal_I32Val) ProtoSize() (n int)

+ type Literal_I64Val struct

+ I64Val int64

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

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

+ func (m *Literal_I64Val) ProtoSize() (n int)

+ type Literal_I8Val struct

+ I8Val int32

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

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

+ func (m *Literal_I8Val) ProtoSize() (n int)

+ type Literal_Jsonval struct

+ Jsonval string

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

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

+ func (m *Literal_Jsonval) ProtoSize() (n int)

+ type Literal_Sval struct

+ Sval string

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

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

+ func (m *Literal_Sval) ProtoSize() (n int)

+ type Literal_Timestampval struct

+ Timestampval int64

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

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

+ func (m *Literal_Timestampval) ProtoSize() (n int)

+ type Literal_Timeval struct

+ Timeval int64

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

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

+ func (m *Literal_Timeval) ProtoSize() (n int)

+ type Literal_U16Val struct

+ U16Val uint32

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

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

+ func (m *Literal_U16Val) ProtoSize() (n int)

+ type Literal_U32Val struct

+ U32Val uint32

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

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

+ func (m *Literal_U32Val) ProtoSize() (n int)

+ type Literal_U64Val struct

+ U64Val uint64

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

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

+ func (m *Literal_U64Val) ProtoSize() (n int)

+ type Literal_U8Val struct

+ U8Val uint32

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

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

+ func (m *Literal_U8Val) ProtoSize() (n int)

+ type Literal_UpdateVal struct

+ UpdateVal bool

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

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

+ func (m *Literal_UpdateVal) ProtoSize() (n int)

type Node

+ FillType Node_FillType

+ FillVal []*Expr

+ Fuzzymessage *OriginTableMessageForFuzzy

+ Interval *Expr

+ OnUpdateExprs []*Expr

+ PreInsertSkCtx *PreInsertUkCtx

+ SampleFunc *SampleFuncSpec

+ Sliding *Expr

+ WindowIdx int32

+ func (m *Node) GetFillType() Node_FillType

+ func (m *Node) GetFillVal() []*Expr

+ func (m *Node) GetFuzzymessage() *OriginTableMessageForFuzzy

+ func (m *Node) GetInterval() *Expr

+ func (m *Node) GetOnUpdateExprs() []*Expr

+ func (m *Node) GetPreInsertSkCtx() *PreInsertUkCtx

+ func (m *Node) GetSampleFunc() *SampleFuncSpec

+ func (m *Node) GetSliding() *Expr

+ func (m *Node) GetWindowIdx() int32

+ type Node_FillType int32

+ const Node_LINEAR

+ const Node_NEXT

+ const Node_NONE

+ const Node_NULL

+ const Node_PREV

+ const Node_VALUE

+ func (Node_FillType) EnumDescriptor() ([]byte, []int)

+ func (x Node_FillType) String() string

type Node_NodeType

+ const Node_FUZZY_FILTER

+ const Node_Fill

+ const Node_PARTITION

+ const Node_PRE_INSERT_SK

+ const Node_SOURCE_SCAN

+ const Node_TIME_WINDOW

type OnDuplicateKeyCtx

+ IsIgnore bool

+ func (m *OnDuplicateKeyCtx) GetIsIgnore() bool

+ type OriginTableMessageForFuzzy struct

+ ParentTableName string

+ ParentUniqueCols []*ColDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OriginTableMessageForFuzzy) Descriptor() ([]byte, []int)

+ func (*OriginTableMessageForFuzzy) ProtoMessage()

+ func (m *OriginTableMessageForFuzzy) GetParentTableName() string

+ func (m *OriginTableMessageForFuzzy) GetParentUniqueCols() []*ColDef

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

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

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

+ func (m *OriginTableMessageForFuzzy) ProtoSize() (n int)

+ func (m *OriginTableMessageForFuzzy) Reset()

+ func (m *OriginTableMessageForFuzzy) String() string

+ func (m *OriginTableMessageForFuzzy) Unmarshal(dAtA []byte) error

+ func (m *OriginTableMessageForFuzzy) XXX_DiscardUnknown()

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

+ func (m *OriginTableMessageForFuzzy) XXX_Merge(src proto.Message)

+ func (m *OriginTableMessageForFuzzy) XXX_Size() int

+ func (m *OriginTableMessageForFuzzy) XXX_Unmarshal(b []byte) error

+ type SampleFuncSpec struct

+ Percent float64

+ Rows int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SampleFuncSpec) Descriptor() ([]byte, []int)

+ func (*SampleFuncSpec) ProtoMessage()

+ func (m *SampleFuncSpec) GetPercent() float64

+ func (m *SampleFuncSpec) GetRows() int32

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

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

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

+ func (m *SampleFuncSpec) ProtoSize() (n int)

+ func (m *SampleFuncSpec) Reset()

+ func (m *SampleFuncSpec) String() string

+ func (m *SampleFuncSpec) Unmarshal(dAtA []byte) error

+ func (m *SampleFuncSpec) XXX_DiscardUnknown()

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

+ func (m *SampleFuncSpec) XXX_Merge(src proto.Message)

+ func (m *SampleFuncSpec) XXX_Size() int

+ func (m *SampleFuncSpec) XXX_Unmarshal(b []byte) error

type TableDef

+ IsDynamic bool

+ func (m *TableDef) GetIsDynamic() bool

type TruncateTable

+ IsDelete bool

+ func (m *TruncateTable) GetIsDelete() bool

v1.0.2

Dec 21, 2023

Changes in this version

type CreateDatabase

+ Sql string

+ func (m *CreateDatabase) GetSql() string

v1.0.1

Dec 15, 2023

v1.0.0

Nov 13, 2023

Changes in this version

+ var AlterTable_AlgorithmType_name = map[int32]string

+ var AlterTable_AlgorithmType_value = map[string]int32

+ var ShuffleMethod_name = map[int32]string

+ var ShuffleMethod_value = map[string]int32

+ var ShuffleTypeForMultiCN_name = map[int32]string

+ var ShuffleTypeForMultiCN_value = map[string]int32

type AlterSequence

+ Database string

+ IfExists bool

+ TableDef *TableDef

+ func (m *AlterSequence) GetDatabase() string

+ func (m *AlterSequence) GetIfExists() bool

+ func (m *AlterSequence) GetTableDef() *TableDef

type AlterTable

+ AlgorithmType AlterTable_AlgorithmType

+ ChangeTblColIdMap map[uint64]*ColDef

+ CopyTableDef *TableDef

+ CreateTableSql string

+ CreateTmpTableSql string

+ InsertDataSql string

+ InsertTmpDataSql string

+ func (m *AlterTable) GetAlgorithmType() AlterTable_AlgorithmType

+ func (m *AlterTable) GetChangeTblColIdMap() map[uint64]*ColDef

+ func (m *AlterTable) GetCopyTableDef() *TableDef

+ func (m *AlterTable) GetCreateTableSql() string

+ func (m *AlterTable) GetCreateTmpTableSql() string

+ func (m *AlterTable) GetInsertDataSql() string

+ func (m *AlterTable) GetInsertTmpDataSql() string

+ type AlterTable_AlgorithmType int32

+ const AlterTable_COPY

+ const AlterTable_DEFAULT

+ const AlterTable_INPLACE

+ const AlterTable_INSTANT

+ func (AlterTable_AlgorithmType) EnumDescriptor() ([]byte, []int)

+ func (x AlterTable_AlgorithmType) String() string

+ type BinaryData struct

+ Data []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BinaryData) Descriptor() ([]byte, []int)

+ func (*BinaryData) ProtoMessage()

+ func (m *BinaryData) GetData() []byte

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

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

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

+ func (m *BinaryData) ProtoSize() (n int)

+ func (m *BinaryData) Reset()

+ func (m *BinaryData) String() string

+ func (m *BinaryData) Unmarshal(dAtA []byte) error

+ func (m *BinaryData) XXX_DiscardUnknown()

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

+ func (m *BinaryData) XXX_Merge(src proto.Message)

+ func (m *BinaryData) XXX_Size() int

+ func (m *BinaryData) XXX_Unmarshal(b []byte) error

type ClusterByDef

+ CompCbkeyCol *ColDef

+ func (m *ClusterByDef) GetCompCbkeyCol() *ColDef

type ColDef

+ Header string

+ Headers bool

+ func (m *ColDef) GetHeader() string

+ func (m *ColDef) GetHeaders() bool

type Const

+ func (m *Const) GetEnumVal() uint32

+ type Const_EnumVal struct

+ EnumVal uint32

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

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

+ func (m *Const_EnumVal) ProtoSize() (n int)

type CreateTable

+ Replace bool

+ func (m *CreateTable) GetReplace() bool

type DeleteCtx

+ PrimaryKeyIdx int32

+ func (m *DeleteCtx) GetPrimaryKeyIdx() int32

type Expr

+ func (m *Expr) GetBin() *BinaryData

+ type Expr_Bin struct

+ Bin *BinaryData

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

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

+ func (m *Expr_Bin) ProtoSize() (n int)

+ type ExternScan struct

+ Data string

+ EnclosedBy []byte

+ Format string

+ IgnoredLines uint64

+ Terminated string

+ Type int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExternScan) Descriptor() ([]byte, []int)

+ func (*ExternScan) ProtoMessage()

+ func (m *ExternScan) GetData() string

+ func (m *ExternScan) GetEnclosedBy() []byte

+ func (m *ExternScan) GetFormat() string

+ func (m *ExternScan) GetIgnoredLines() uint64

+ func (m *ExternScan) GetTerminated() string

+ func (m *ExternScan) GetType() int32

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

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

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

+ func (m *ExternScan) ProtoSize() (n int)

+ func (m *ExternScan) Reset()

+ func (m *ExternScan) String() string

+ func (m *ExternScan) Unmarshal(dAtA []byte) error

+ func (m *ExternScan) XXX_DiscardUnknown()

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

+ func (m *ExternScan) XXX_Merge(src proto.Message)

+ func (m *ExternScan) XXX_Size() int

+ func (m *ExternScan) XXX_Unmarshal(b []byte) error

+ type HashMapStats struct

+ HashOnPK bool

+ HashmapSize float64

+ Shuffle bool

+ ShuffleColIdx int32

+ ShuffleColMax int64

+ ShuffleColMin int64

+ ShuffleMethod ShuffleMethod

+ ShuffleType ShuffleType

+ ShuffleTypeForMultiCN ShuffleTypeForMultiCN

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*HashMapStats) Descriptor() ([]byte, []int)

+ func (*HashMapStats) ProtoMessage()

+ func (m *HashMapStats) GetHashOnPK() bool

+ func (m *HashMapStats) GetHashmapSize() float64

+ func (m *HashMapStats) GetShuffle() bool

+ func (m *HashMapStats) GetShuffleColIdx() int32

+ func (m *HashMapStats) GetShuffleColMax() int64

+ func (m *HashMapStats) GetShuffleColMin() int64

+ func (m *HashMapStats) GetShuffleMethod() ShuffleMethod

+ func (m *HashMapStats) GetShuffleType() ShuffleType

+ func (m *HashMapStats) GetShuffleTypeForMultiCN() ShuffleTypeForMultiCN

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

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

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

+ func (m *HashMapStats) ProtoSize() (n int)

+ func (m *HashMapStats) Reset()

+ func (m *HashMapStats) String() string

+ func (m *HashMapStats) Unmarshal(dAtA []byte) error

+ func (m *HashMapStats) XXX_DiscardUnknown()

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

+ func (m *HashMapStats) XXX_Merge(src proto.Message)

+ func (m *HashMapStats) XXX_Size() int

+ func (m *HashMapStats) XXX_Unmarshal(b []byte) error

type LockTarget

+ Mode lock.LockMode

+ func (m *LockTarget) GetMode() lock.LockMode

type MetadataScanInfo

+ ObjLoc []byte

+ ObjectName string

+ ZoneMap []byte

+ func (m *MetadataScanInfo) GetObjLoc() []byte

+ func (m *MetadataScanInfo) GetObjectName() string

+ func (m *MetadataScanInfo) GetZoneMap() []byte

type MetadataScanInfo_MetadataScanInfoType

+ const MetadataScanInfo_OBJECT_NAME

+ const MetadataScanInfo_OBJ_LOC

+ const MetadataScanInfo_SUM

type Node

+ ExternScan *ExternScan

+ PartitionPrune *PartitionPrune

+ RecursiveSink bool

+ ReplaceCtx *ReplaceCtx

+ func (m *Node) GetExternScan() *ExternScan

+ func (m *Node) GetPartitionPrune() *PartitionPrune

+ func (m *Node) GetRecursiveSink() bool

+ func (m *Node) GetReplaceCtx() *ReplaceCtx

type Node_NodeType

+ const Node_RECURSIVE_SCAN

+ const Node_REPLACE

+ const Node_STREAM_SCAN

type PartitionByDef

+ func (p *PartitionByDef) GenPartitionExprString() string

+ type PartitionPrune struct

+ IsPruned bool

+ SelectedPartitions []*PartitionItem

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PartitionPrune) Descriptor() ([]byte, []int)

+ func (*PartitionPrune) ProtoMessage()

+ func (m *PartitionPrune) GetIsPruned() bool

+ func (m *PartitionPrune) GetSelectedPartitions() []*PartitionItem

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

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

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

+ func (m *PartitionPrune) ProtoSize() (n int)

+ func (m *PartitionPrune) Reset()

+ func (m *PartitionPrune) String() string

+ func (m *PartitionPrune) Unmarshal(dAtA []byte) error

+ func (m *PartitionPrune) XXX_DiscardUnknown()

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

+ func (m *PartitionPrune) XXX_Merge(src proto.Message)

+ func (m *PartitionPrune) XXX_Size() int

+ func (m *PartitionPrune) XXX_Unmarshal(b []byte) error

type Query_StatementType

+ const Query_REPLACE

+ type ReplaceCtx struct

+ AddAffectedRows bool

+ DeleteCond string

+ IsClusterTable bool

+ PartitionIdx int32

+ PartitionTableIds []uint64

+ PartitionTableNames []string

+ Ref *ObjectRef

+ TableDef *TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReplaceCtx) Descriptor() ([]byte, []int)

+ func (*ReplaceCtx) ProtoMessage()

+ func (m *ReplaceCtx) GetAddAffectedRows() bool

+ func (m *ReplaceCtx) GetDeleteCond() string

+ func (m *ReplaceCtx) GetIsClusterTable() bool

+ func (m *ReplaceCtx) GetPartitionIdx() int32

+ func (m *ReplaceCtx) GetPartitionTableIds() []uint64

+ func (m *ReplaceCtx) GetPartitionTableNames() []string

+ func (m *ReplaceCtx) GetRef() *ObjectRef

+ func (m *ReplaceCtx) GetTableDef() *TableDef

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

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

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

+ func (m *ReplaceCtx) ProtoSize() (n int)

+ func (m *ReplaceCtx) Reset()

+ func (m *ReplaceCtx) String() string

+ func (m *ReplaceCtx) Unmarshal(dAtA []byte) error

+ func (m *ReplaceCtx) XXX_DiscardUnknown()

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

+ func (m *ReplaceCtx) XXX_Merge(src proto.Message)

+ func (m *ReplaceCtx) XXX_Size() int

+ func (m *ReplaceCtx) XXX_Unmarshal(b []byte) error

+ type ShuffleMethod int32

+ const ShuffleMethod_Normal

+ const ShuffleMethod_Reshuffle

+ const ShuffleMethod_Reuse

+ func (ShuffleMethod) EnumDescriptor() ([]byte, []int)

+ func (x ShuffleMethod) String() string

+ type ShuffleTypeForMultiCN int32

+ const ShuffleTypeForMultiCN_Hybrid

+ const ShuffleTypeForMultiCN_Simple

+ func (ShuffleTypeForMultiCN) EnumDescriptor() ([]byte, []int)

+ func (x ShuffleTypeForMultiCN) String() string

type Stats

+ HashmapStats *HashMapStats

+ func (m *Stats) GetHashmapStats() *HashMapStats

type TableDef

+ AutoIncrOffset uint64

+ func (m *TableDef) GetAutoIncrOffset() uint64

type Type

+ Enumvalues string

+ func (m *Type) GetEnumvalues() string

v1.0.0-rc2

Oct 24, 2023

v1.0.0-rc1

Aug 24, 2023

v0

v0.8.1

Oct 9, 2023

v0.8.0

Jun 30, 2023

Changes in this version

+ const SystemExternalRel

+ var AlterTableDrop_Typ_name = map[int32]string

+ var AlterTableDrop_Typ_value = map[string]int32

+ var FrameBound_BoundType_name = map[int32]string

+ var FrameBound_BoundType_value = map[string]int32

+ var FrameClause_FrameType_name = map[int32]string

+ var FrameClause_FrameType_value = map[string]int32

+ var MetadataScanInfo_MetadataScanInfoType_name = map[int32]string

+ var MetadataScanInfo_MetadataScanInfoType_value = map[string]int32

+ var Node_JoinType_name = map[int32]string

+ var Node_JoinType_value = map[string]int32

+ var ShuffleType_name = map[int32]string

+ var ShuffleType_value = map[string]int32

+ var TableLockType_name = map[int32]string

+ var TableLockType_value = map[string]int32

+ type AlterAddCol struct

+ Name string

+ Pos int32

+ PreName string

+ Type *Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterAddCol) Descriptor() ([]byte, []int)

+ func (*AlterAddCol) ProtoMessage()

+ func (m *AlterAddCol) GetName() string

+ func (m *AlterAddCol) GetPos() int32

+ func (m *AlterAddCol) GetPreName() string

+ func (m *AlterAddCol) GetType() *Type

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

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

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

+ func (m *AlterAddCol) ProtoSize() (n int)

+ func (m *AlterAddCol) Reset()

+ func (m *AlterAddCol) String() string

+ func (m *AlterAddCol) Unmarshal(dAtA []byte) error

+ func (m *AlterAddCol) XXX_DiscardUnknown()

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

+ func (m *AlterAddCol) XXX_Merge(src proto.Message)

+ func (m *AlterAddCol) XXX_Size() int

+ func (m *AlterAddCol) XXX_Unmarshal(b []byte) error

+ type AlterDropCol struct

+ Idx uint32

+ Seq uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterDropCol) Descriptor() ([]byte, []int)

+ func (*AlterDropCol) ProtoMessage()

+ func (m *AlterDropCol) GetIdx() uint32

+ func (m *AlterDropCol) GetSeq() uint32

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

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

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

+ func (m *AlterDropCol) ProtoSize() (n int)

+ func (m *AlterDropCol) Reset()

+ func (m *AlterDropCol) String() string

+ func (m *AlterDropCol) Unmarshal(dAtA []byte) error

+ func (m *AlterDropCol) XXX_DiscardUnknown()

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

+ func (m *AlterDropCol) XXX_Merge(src proto.Message)

+ func (m *AlterDropCol) XXX_Size() int

+ func (m *AlterDropCol) XXX_Unmarshal(b []byte) error

+ type AlterSequence struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterSequence) Descriptor() ([]byte, []int)

+ func (*AlterSequence) ProtoMessage()

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

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

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

+ func (m *AlterSequence) ProtoSize() (n int)

+ func (m *AlterSequence) Reset()

+ func (m *AlterSequence) String() string

+ func (m *AlterSequence) Unmarshal(dAtA []byte) error

+ func (m *AlterSequence) XXX_DiscardUnknown()

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

+ func (m *AlterSequence) XXX_Merge(src proto.Message)

+ func (m *AlterSequence) XXX_Size() int

+ func (m *AlterSequence) XXX_Unmarshal(b []byte) error

type AlterTable

+ Actions []*AlterTable_Action

+ Database string

+ IsClusterTable bool

+ func (m *AlterTable) GetActions() []*AlterTable_Action

+ func (m *AlterTable) GetDatabase() string

+ func (m *AlterTable) GetIsClusterTable() bool

+ type AlterTableAddFk struct

+ Cols []string

+ DbName string

+ Fkey *ForeignKeyDef

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableAddFk) Descriptor() ([]byte, []int)

+ func (*AlterTableAddFk) ProtoMessage()

+ func (m *AlterTableAddFk) GetCols() []string

+ func (m *AlterTableAddFk) GetDbName() string

+ func (m *AlterTableAddFk) GetFkey() *ForeignKeyDef

+ func (m *AlterTableAddFk) GetTableName() string

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

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

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

+ func (m *AlterTableAddFk) ProtoSize() (n int)

+ func (m *AlterTableAddFk) Reset()

+ func (m *AlterTableAddFk) String() string

+ func (m *AlterTableAddFk) Unmarshal(dAtA []byte) error

+ func (m *AlterTableAddFk) XXX_DiscardUnknown()

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

+ func (m *AlterTableAddFk) XXX_Merge(src proto.Message)

+ func (m *AlterTableAddFk) XXX_Size() int

+ func (m *AlterTableAddFk) XXX_Unmarshal(b []byte) error

+ type AlterTableAddIndex struct

+ DbName string

+ IndexInfo *CreateTable

+ IndexTableExist bool

+ OriginTablePrimaryKey string

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableAddIndex) Descriptor() ([]byte, []int)

+ func (*AlterTableAddIndex) ProtoMessage()

+ func (m *AlterTableAddIndex) GetDbName() string

+ func (m *AlterTableAddIndex) GetIndexInfo() *CreateTable

+ func (m *AlterTableAddIndex) GetIndexTableExist() bool

+ func (m *AlterTableAddIndex) GetOriginTablePrimaryKey() string

+ func (m *AlterTableAddIndex) GetTableName() string

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

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

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

+ func (m *AlterTableAddIndex) ProtoSize() (n int)

+ func (m *AlterTableAddIndex) Reset()

+ func (m *AlterTableAddIndex) String() string

+ func (m *AlterTableAddIndex) Unmarshal(dAtA []byte) error

+ func (m *AlterTableAddIndex) XXX_DiscardUnknown()

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

+ func (m *AlterTableAddIndex) XXX_Merge(src proto.Message)

+ func (m *AlterTableAddIndex) XXX_Size() int

+ func (m *AlterTableAddIndex) XXX_Unmarshal(b []byte) error

+ type AlterTableAlterIndex struct

+ DbName string

+ IndexName string

+ TableName string

+ Visible bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableAlterIndex) Descriptor() ([]byte, []int)

+ func (*AlterTableAlterIndex) ProtoMessage()

+ func (m *AlterTableAlterIndex) GetDbName() string

+ func (m *AlterTableAlterIndex) GetIndexName() string

+ func (m *AlterTableAlterIndex) GetTableName() string

+ func (m *AlterTableAlterIndex) GetVisible() bool

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

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

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

+ func (m *AlterTableAlterIndex) ProtoSize() (n int)

+ func (m *AlterTableAlterIndex) Reset()

+ func (m *AlterTableAlterIndex) String() string

+ func (m *AlterTableAlterIndex) Unmarshal(dAtA []byte) error

+ func (m *AlterTableAlterIndex) XXX_DiscardUnknown()

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

+ func (m *AlterTableAlterIndex) XXX_Merge(src proto.Message)

+ func (m *AlterTableAlterIndex) XXX_Size() int

+ func (m *AlterTableAlterIndex) XXX_Unmarshal(b []byte) error

+ type AlterTableComment struct

+ NewComment string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableComment) Descriptor() ([]byte, []int)

+ func (*AlterTableComment) ProtoMessage()

+ func (m *AlterTableComment) GetNewComment() string

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

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

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

+ func (m *AlterTableComment) ProtoSize() (n int)

+ func (m *AlterTableComment) Reset()

+ func (m *AlterTableComment) String() string

+ func (m *AlterTableComment) Unmarshal(dAtA []byte) error

+ func (m *AlterTableComment) XXX_DiscardUnknown()

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

+ func (m *AlterTableComment) XXX_Merge(src proto.Message)

+ func (m *AlterTableComment) XXX_Size() int

+ func (m *AlterTableComment) XXX_Unmarshal(b []byte) error

+ type AlterTableDrop struct

+ IndexTableName string

+ Name string

+ Typ AlterTableDrop_Typ

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableDrop) Descriptor() ([]byte, []int)

+ func (*AlterTableDrop) ProtoMessage()

+ func (m *AlterTableDrop) GetIndexTableName() string

+ func (m *AlterTableDrop) GetName() string

+ func (m *AlterTableDrop) GetTyp() AlterTableDrop_Typ

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

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

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

+ func (m *AlterTableDrop) ProtoSize() (n int)

+ func (m *AlterTableDrop) Reset()

+ func (m *AlterTableDrop) String() string

+ func (m *AlterTableDrop) Unmarshal(dAtA []byte) error

+ func (m *AlterTableDrop) XXX_DiscardUnknown()

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

+ func (m *AlterTableDrop) XXX_Merge(src proto.Message)

+ func (m *AlterTableDrop) XXX_Size() int

+ func (m *AlterTableDrop) XXX_Unmarshal(b []byte) error

+ type AlterTableDropIndex struct

+ DbName string

+ IndexName string

+ IndexTableName string

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableDropIndex) Descriptor() ([]byte, []int)

+ func (*AlterTableDropIndex) ProtoMessage()

+ func (m *AlterTableDropIndex) GetDbName() string

+ func (m *AlterTableDropIndex) GetIndexName() string

+ func (m *AlterTableDropIndex) GetIndexTableName() string

+ func (m *AlterTableDropIndex) GetTableName() string

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

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

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

+ func (m *AlterTableDropIndex) ProtoSize() (n int)

+ func (m *AlterTableDropIndex) Reset()

+ func (m *AlterTableDropIndex) String() string

+ func (m *AlterTableDropIndex) Unmarshal(dAtA []byte) error

+ func (m *AlterTableDropIndex) XXX_DiscardUnknown()

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

+ func (m *AlterTableDropIndex) XXX_Merge(src proto.Message)

+ func (m *AlterTableDropIndex) XXX_Size() int

+ func (m *AlterTableDropIndex) XXX_Unmarshal(b []byte) error

+ type AlterTableDrop_Typ int32

+ const AlterTableDrop_COLUMN

+ const AlterTableDrop_FOREIGN_KEY

+ const AlterTableDrop_INDEX

+ const AlterTableDrop_KEY

+ const AlterTableDrop_PRIMARY_KEY

+ func (AlterTableDrop_Typ) EnumDescriptor() ([]byte, []int)

+ func (x AlterTableDrop_Typ) String() string

+ type AlterTableName struct

+ NewName string

+ OldName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTableName) Descriptor() ([]byte, []int)

+ func (*AlterTableName) ProtoMessage()

+ func (m *AlterTableName) GetNewName() string

+ func (m *AlterTableName) GetOldName() string

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

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

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

+ func (m *AlterTableName) ProtoSize() (n int)

+ func (m *AlterTableName) Reset()

+ func (m *AlterTableName) String() string

+ func (m *AlterTableName) Unmarshal(dAtA []byte) error

+ func (m *AlterTableName) XXX_DiscardUnknown()

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

+ func (m *AlterTableName) XXX_Merge(src proto.Message)

+ func (m *AlterTableName) XXX_Size() int

+ func (m *AlterTableName) XXX_Unmarshal(b []byte) error

+ type AlterTable_Action struct

+ Action isAlterTable_Action_Action

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AlterTable_Action) Descriptor() ([]byte, []int)

+ func (*AlterTable_Action) ProtoMessage()

+ func (*AlterTable_Action) XXX_OneofWrappers() []interface{}

+ func (m *AlterTable_Action) GetAction() isAlterTable_Action_Action

+ func (m *AlterTable_Action) GetAddCol() *AlterAddCol

+ func (m *AlterTable_Action) GetAddFk() *AlterTableAddFk

+ func (m *AlterTable_Action) GetAddIndex() *AlterTableAddIndex

+ func (m *AlterTable_Action) GetAlterComment() *AlterTableComment

+ func (m *AlterTable_Action) GetAlterIndex() *AlterTableAlterIndex

+ func (m *AlterTable_Action) GetAlterName() *AlterTableName

+ func (m *AlterTable_Action) GetDrop() *AlterTableDrop

+ func (m *AlterTable_Action) GetDropCol() *AlterDropCol

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

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

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

+ func (m *AlterTable_Action) ProtoSize() (n int)

+ func (m *AlterTable_Action) Reset()

+ func (m *AlterTable_Action) String() string

+ func (m *AlterTable_Action) Unmarshal(dAtA []byte) error

+ func (m *AlterTable_Action) XXX_DiscardUnknown()

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

+ func (m *AlterTable_Action) XXX_Merge(src proto.Message)

+ func (m *AlterTable_Action) XXX_Size() int

+ func (m *AlterTable_Action) XXX_Unmarshal(b []byte) error

+ type AlterTable_Action_AddCol struct

+ AddCol *AlterAddCol

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

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

+ func (m *AlterTable_Action_AddCol) ProtoSize() (n int)

+ type AlterTable_Action_AddFk struct

+ AddFk *AlterTableAddFk

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

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

+ func (m *AlterTable_Action_AddFk) ProtoSize() (n int)

+ type AlterTable_Action_AddIndex struct

+ AddIndex *AlterTableAddIndex

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

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

+ func (m *AlterTable_Action_AddIndex) ProtoSize() (n int)

+ type AlterTable_Action_AlterComment struct

+ AlterComment *AlterTableComment

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

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

+ func (m *AlterTable_Action_AlterComment) ProtoSize() (n int)

+ type AlterTable_Action_AlterIndex struct

+ AlterIndex *AlterTableAlterIndex

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

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

+ func (m *AlterTable_Action_AlterIndex) ProtoSize() (n int)

+ type AlterTable_Action_AlterName struct

+ AlterName *AlterTableName

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

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

+ func (m *AlterTable_Action_AlterName) ProtoSize() (n int)

+ type AlterTable_Action_Drop struct

+ Drop *AlterTableDrop

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

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

+ func (m *AlterTable_Action_Drop) ProtoSize() (n int)

+ type AlterTable_Action_DropCol struct

+ DropCol *AlterDropCol

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

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

+ func (m *AlterTable_Action_DropCol) ProtoSize() (n int)

type AnalyzeInfo

+ S3IOInputCount int64

+ S3IOOutputCount int64

+ func (m *AnalyzeInfo) GetS3IOInputCount() int64

+ func (m *AnalyzeInfo) GetS3IOOutputCount() int64

type ColDef

+ Seqnum uint32

+ func (m *ColDef) GetSeqnum() uint32

type CreateDatabase

+ SubscriptionOption *SubscriptionOption

+ func (m *CreateDatabase) GetSubscriptionOption() *SubscriptionOption

type CreateIndex

+ TableDef *TableDef

+ func (m *CreateIndex) GetTableDef() *TableDef

+ type CreateSequence struct

+ Database string

+ IfNotExists bool

+ TableDef *TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateSequence) Descriptor() ([]byte, []int)

+ func (*CreateSequence) ProtoMessage()

+ func (m *CreateSequence) GetDatabase() string

+ func (m *CreateSequence) GetIfNotExists() bool

+ func (m *CreateSequence) GetTableDef() *TableDef

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

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

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

+ func (m *CreateSequence) ProtoSize() (n int)

+ func (m *CreateSequence) Reset()

+ func (m *CreateSequence) String() string

+ func (m *CreateSequence) Unmarshal(dAtA []byte) error

+ func (m *CreateSequence) XXX_DiscardUnknown()

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

+ func (m *CreateSequence) XXX_Merge(src proto.Message)

+ func (m *CreateSequence) XXX_Size() int

+ func (m *CreateSequence) XXX_Unmarshal(b []byte) error

type CreateTable

+ PartitionTables []*TableDef

+ func (m *CreateTable) GetPartitionTables() []*TableDef

+ func (m CreateTable) IsSystemExternalRel() bool

type DataDefinition

+ func (m *DataDefinition) GetAlterSequence() *AlterSequence

+ func (m *DataDefinition) GetCreateSequence() *CreateSequence

+ func (m *DataDefinition) GetDropSequence() *DropSequence

+ func (m *DataDefinition) GetLockTables() *LockTables

+ func (m *DataDefinition) GetUnlockTables() *UnLockTables

+ type DataDefinition_AlterSequence struct

+ AlterSequence *AlterSequence

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

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

+ func (m *DataDefinition_AlterSequence) ProtoSize() (n int)

+ type DataDefinition_CreateSequence struct

+ CreateSequence *CreateSequence

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

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

+ func (m *DataDefinition_CreateSequence) ProtoSize() (n int)

type DataDefinition_DdlType

+ const DataDefinition_ALTER_SEQUENCE

+ const DataDefinition_CREATE_SEQUENCE

+ const DataDefinition_DROP_SEQUENCE

+ const DataDefinition_LOCK_TABLES

+ const DataDefinition_SHOW_SEQUENCES

+ const DataDefinition_UNLOCK_TABLES

+ type DataDefinition_DropSequence struct

+ DropSequence *DropSequence

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

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

+ func (m *DataDefinition_DropSequence) ProtoSize() (n int)

+ type DataDefinition_LockTables struct

+ LockTables *LockTables

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

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

+ func (m *DataDefinition_LockTables) ProtoSize() (n int)

+ type DataDefinition_UnlockTables struct

+ UnlockTables *UnLockTables

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

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

+ func (m *DataDefinition_UnlockTables) ProtoSize() (n int)

type Default

+ func (m *Default) MarshalBinary() ([]byte, error)

+ func (m *Default) UnmarshalBinary(data []byte) error

type DeleteCtx

+ AddAffectedRows bool

+ IsClusterTable bool

+ PartitionIdx int32

+ PartitionTableIds []uint64

+ PartitionTableNames []string

+ RowIdIdx int32

+ func (m *DeleteCtx) GetAddAffectedRows() bool

+ func (m *DeleteCtx) GetIsClusterTable() bool

+ func (m *DeleteCtx) GetPartitionIdx() int32

+ func (m *DeleteCtx) GetPartitionTableIds() []uint64

+ func (m *DeleteCtx) GetPartitionTableNames() []string

+ func (m *DeleteCtx) GetRowIdIdx() int32

type DropDatabase

+ DatabaseId uint64

+ func (m *DropDatabase) GetDatabaseId() uint64

+ type DropSequence struct

+ Database string

+ IfExists bool

+ Table string

+ TableId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DropSequence) Descriptor() ([]byte, []int)

+ func (*DropSequence) ProtoMessage()

+ func (m *DropSequence) GetDatabase() string

+ func (m *DropSequence) GetIfExists() bool

+ func (m *DropSequence) GetTable() string

+ func (m *DropSequence) GetTableId() uint64

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

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

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

+ func (m *DropSequence) ProtoSize() (n int)

+ func (m *DropSequence) Reset()

+ func (m *DropSequence) String() string

+ func (m *DropSequence) Unmarshal(dAtA []byte) error

+ func (m *DropSequence) XXX_DiscardUnknown()

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

+ func (m *DropSequence) XXX_Merge(src proto.Message)

+ func (m *DropSequence) XXX_Size() int

+ func (m *DropSequence) XXX_Unmarshal(b []byte) error

type DropTable

+ IsView bool

+ PartitionTableNames []string

+ TableDef *TableDef

+ func (m *DropTable) GetIsView() bool

+ func (m *DropTable) GetPartitionTableNames() []string

+ func (m *DropTable) GetTableDef() *TableDef

type Expr

+ AuxId int32

+ Ndv float64

+ Selectivity float64

+ func (m *Expr) GetAuxId() int32

+ func (m *Expr) GetNdv() float64

+ func (m *Expr) GetSelectivity() float64

+ func (m *Expr) GetW() *WindowSpec

+ type Expr_W struct

+ W *WindowSpec

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

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

+ func (m *Expr_W) ProtoSize() (n int)

+ type FkColName struct

+ Cols []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FkColName) Descriptor() ([]byte, []int)

+ func (*FkColName) ProtoMessage()

+ func (m *FkColName) GetCols() []string

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

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

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

+ func (m *FkColName) ProtoSize() (n int)

+ func (m *FkColName) Reset()

+ func (m *FkColName) String() string

+ func (m *FkColName) Unmarshal(dAtA []byte) error

+ func (m *FkColName) XXX_DiscardUnknown()

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

+ func (m *FkColName) XXX_Merge(src proto.Message)

+ func (m *FkColName) XXX_Size() int

+ func (m *FkColName) XXX_Unmarshal(b []byte) error

+ type FrameBound struct

+ Type FrameBound_BoundType

+ UnBounded bool

+ Val *Expr

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FrameBound) Descriptor() ([]byte, []int)

+ func (*FrameBound) ProtoMessage()

+ func (m *FrameBound) GetType() FrameBound_BoundType

+ func (m *FrameBound) GetUnBounded() bool

+ func (m *FrameBound) GetVal() *Expr

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

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

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

+ func (m *FrameBound) ProtoSize() (n int)

+ func (m *FrameBound) Reset()

+ func (m *FrameBound) String() string

+ func (m *FrameBound) Unmarshal(dAtA []byte) error

+ func (m *FrameBound) XXX_DiscardUnknown()

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

+ func (m *FrameBound) XXX_Merge(src proto.Message)

+ func (m *FrameBound) XXX_Size() int

+ func (m *FrameBound) XXX_Unmarshal(b []byte) error

+ type FrameBound_BoundType int32

+ const FrameBound_CURRENT_ROW

+ const FrameBound_FOLLOWING

+ const FrameBound_PRECEDING

+ func (FrameBound_BoundType) EnumDescriptor() ([]byte, []int)

+ func (x FrameBound_BoundType) String() string

+ type FrameClause struct

+ End *FrameBound

+ Start *FrameBound

+ Type FrameClause_FrameType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FrameClause) Descriptor() ([]byte, []int)

+ func (*FrameClause) ProtoMessage()

+ func (m *FrameClause) GetEnd() *FrameBound

+ func (m *FrameClause) GetStart() *FrameBound

+ func (m *FrameClause) GetType() FrameClause_FrameType

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

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

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

+ func (m *FrameClause) ProtoSize() (n int)

+ func (m *FrameClause) Reset()

+ func (m *FrameClause) String() string

+ func (m *FrameClause) Unmarshal(dAtA []byte) error

+ func (m *FrameClause) XXX_DiscardUnknown()

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

+ func (m *FrameClause) XXX_Merge(src proto.Message)

+ func (m *FrameClause) XXX_Size() int

+ func (m *FrameClause) XXX_Unmarshal(b []byte) error

+ type FrameClause_FrameType int32

+ const FrameClause_RANGE

+ const FrameClause_ROWS

+ func (FrameClause_FrameType) EnumDescriptor() ([]byte, []int)

+ func (x FrameClause_FrameType) String() string

type Function_FuncFlag

+ const Function_WIN_ORDER

+ const Function_WIN_VALUE

type IndexDef

+ Visible bool

+ func (m *IndexDef) GetVisible() bool

type InsertCtx

+ AddAffectedRows bool

+ IsClusterTable bool

+ PartitionIdx int32

+ PartitionTableIds []uint64

+ PartitionTableNames []string

+ func (m *InsertCtx) GetAddAffectedRows() bool

+ func (m *InsertCtx) GetIsClusterTable() bool

+ func (m *InsertCtx) GetPartitionIdx() int32

+ func (m *InsertCtx) GetPartitionTableIds() []uint64

+ func (m *InsertCtx) GetPartitionTableNames() []string

+ type LockTables struct

+ TableLocks []*TableLockInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LockTables) Descriptor() ([]byte, []int)

+ func (*LockTables) ProtoMessage()

+ func (m *LockTables) GetTableLocks() []*TableLockInfo

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

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

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

+ func (m *LockTables) ProtoSize() (n int)

+ func (m *LockTables) Reset()

+ func (m *LockTables) String() string

+ func (m *LockTables) Unmarshal(dAtA []byte) error

+ func (m *LockTables) XXX_DiscardUnknown()

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

+ func (m *LockTables) XXX_Merge(src proto.Message)

+ func (m *LockTables) XXX_Size() int

+ func (m *LockTables) XXX_Unmarshal(b []byte) error

+ type LockTarget struct

+ Block bool

+ FilterColIdxInBat int32

+ IsPartitionTable bool

+ LockTable bool

+ PartitionTableIds []uint64

+ PrimaryColIdxInBat int32

+ PrimaryColTyp *Type

+ RefreshTsIdxInBat int32

+ TableId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LockTarget) Descriptor() ([]byte, []int)

+ func (*LockTarget) ProtoMessage()

+ func (m *LockTarget) GetBlock() bool

+ func (m *LockTarget) GetFilterColIdxInBat() int32

+ func (m *LockTarget) GetIsPartitionTable() bool

+ func (m *LockTarget) GetLockTable() bool

+ func (m *LockTarget) GetPartitionTableIds() []uint64

+ func (m *LockTarget) GetPrimaryColIdxInBat() int32

+ func (m *LockTarget) GetPrimaryColTyp() *Type

+ func (m *LockTarget) GetRefreshTsIdxInBat() int32

+ func (m *LockTarget) GetTableId() uint64

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

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

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

+ func (m *LockTarget) ProtoSize() (n int)

+ func (m *LockTarget) Reset()

+ func (m *LockTarget) String() string

+ func (m *LockTarget) Unmarshal(dAtA []byte) error

+ func (m *LockTarget) XXX_DiscardUnknown()

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

+ func (m *LockTarget) XXX_Merge(src proto.Message)

+ func (m *LockTarget) XXX_Size() int

+ func (m *LockTarget) XXX_Unmarshal(b []byte) error

+ type MetadataScanInfo struct

+ BlockId []byte

+ ColName string

+ CommitTs []byte

+ CompressSize int64

+ CreateTs []byte

+ DelLoc []byte

+ DeleteTs []byte

+ EntryState bool

+ IsHidden bool

+ Max []byte

+ MetaLoc []byte

+ Min []byte

+ NullCnt int64

+ OriginSize int64

+ RowCnt int64

+ SegId []byte

+ Sorted bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MetadataScanInfo) Descriptor() ([]byte, []int)

+ func (*MetadataScanInfo) ProtoMessage()

+ func (m *MetadataScanInfo) GetBlockId() []byte

+ func (m *MetadataScanInfo) GetColName() string

+ func (m *MetadataScanInfo) GetCommitTs() []byte

+ func (m *MetadataScanInfo) GetCompressSize() int64

+ func (m *MetadataScanInfo) GetCreateTs() []byte

+ func (m *MetadataScanInfo) GetDelLoc() []byte

+ func (m *MetadataScanInfo) GetDeleteTs() []byte

+ func (m *MetadataScanInfo) GetEntryState() bool

+ func (m *MetadataScanInfo) GetIsHidden() bool

+ func (m *MetadataScanInfo) GetMax() []byte

+ func (m *MetadataScanInfo) GetMetaLoc() []byte

+ func (m *MetadataScanInfo) GetMin() []byte

+ func (m *MetadataScanInfo) GetNullCnt() int64

+ func (m *MetadataScanInfo) GetOriginSize() int64

+ func (m *MetadataScanInfo) GetRowCnt() int64

+ func (m *MetadataScanInfo) GetSegId() []byte

+ func (m *MetadataScanInfo) GetSorted() bool

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

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

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

+ func (m *MetadataScanInfo) ProtoSize() (n int)

+ func (m *MetadataScanInfo) Reset()

+ func (m *MetadataScanInfo) String() string

+ func (m *MetadataScanInfo) Unmarshal(dAtA []byte) error

+ func (m *MetadataScanInfo) XXX_DiscardUnknown()

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

+ func (m *MetadataScanInfo) XXX_Merge(src proto.Message)

+ func (m *MetadataScanInfo) XXX_Size() int

+ func (m *MetadataScanInfo) XXX_Unmarshal(b []byte) error

+ type MetadataScanInfo_MetadataScanInfoType int32

+ const MetadataScanInfo_BLOCK_ID

+ const MetadataScanInfo_COL_NAME

+ const MetadataScanInfo_COMMIT_TS

+ const MetadataScanInfo_COMPRESS_SIZE

+ const MetadataScanInfo_CREATE_TS

+ const MetadataScanInfo_DELETE_TS

+ const MetadataScanInfo_DELTA_LOC

+ const MetadataScanInfo_ENTRY_STATE

+ const MetadataScanInfo_IS_HIDDEN

+ const MetadataScanInfo_MAX

+ const MetadataScanInfo_META_LOC

+ const MetadataScanInfo_MIN

+ const MetadataScanInfo_NULL_CNT

+ const MetadataScanInfo_ORIGIN_SIZE

+ const MetadataScanInfo_ROWS_CNT

+ const MetadataScanInfo_SEG_ID

+ const MetadataScanInfo_SORTED

+ func (MetadataScanInfo_MetadataScanInfoType) EnumDescriptor() ([]byte, []int)

+ func (x MetadataScanInfo_MetadataScanInfoType) String() string

type Node

+ BlockFilterList []*Expr

+ BuildOnLeft bool

+ IsEnd bool

+ LockTargets []*LockTarget

+ OnDuplicateKey *OnDuplicateKeyCtx

+ PreDeleteCtx *PreDeleteCtx

+ PreInsertCtx *PreInsertCtx

+ PreInsertUkCtx *PreInsertUkCtx

+ RuntimeFilterBuildList []*RuntimeFilterSpec

+ RuntimeFilterProbeList []*RuntimeFilterSpec

+ SourceStep int32

+ Uuid []byte

+ WinSpecList []*Expr

+ func (m *Node) GetBlockFilterList() []*Expr

+ func (m *Node) GetBuildOnLeft() bool

+ func (m *Node) GetIsEnd() bool

+ func (m *Node) GetLockTargets() []*LockTarget

+ func (m *Node) GetOnDuplicateKey() *OnDuplicateKeyCtx

+ func (m *Node) GetPreDeleteCtx() *PreDeleteCtx

+ func (m *Node) GetPreInsertCtx() *PreInsertCtx

+ func (m *Node) GetPreInsertUkCtx() *PreInsertUkCtx

+ func (m *Node) GetRuntimeFilterBuildList() []*RuntimeFilterSpec

+ func (m *Node) GetRuntimeFilterProbeList() []*RuntimeFilterSpec

+ func (m *Node) GetSourceStep() int32

+ func (m *Node) GetUuid() []byte

+ func (m *Node) GetWinSpecList() []*Expr

+ type Node_JoinType int32

+ func (Node_JoinType) EnumDescriptor() ([]byte, []int)

+ func (x Node_JoinType) String() string

type Node_NodeType

+ const Node_LOCK_OP

+ const Node_ON_DUPLICATE_KEY

+ const Node_PRE_DELETE

+ const Node_PRE_INSERT

+ const Node_PRE_INSERT_UK

type ObjectRef

+ PubInfo *PubInfo

+ SubscriptionName string

+ func (m *ObjectRef) GetPubInfo() *PubInfo

+ func (m *ObjectRef) GetSubscriptionName() string

+ type OnDuplicateKeyCtx struct

+ OnDuplicateExpr map[string]*Expr

+ OnDuplicateIdx []int32

+ TableDef *TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OnDuplicateKeyCtx) Descriptor() ([]byte, []int)

+ func (*OnDuplicateKeyCtx) ProtoMessage()

+ func (m *OnDuplicateKeyCtx) GetOnDuplicateExpr() map[string]*Expr

+ func (m *OnDuplicateKeyCtx) GetOnDuplicateIdx() []int32

+ func (m *OnDuplicateKeyCtx) GetTableDef() *TableDef

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

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

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

+ func (m *OnDuplicateKeyCtx) ProtoSize() (n int)

+ func (m *OnDuplicateKeyCtx) Reset()

+ func (m *OnDuplicateKeyCtx) String() string

+ func (m *OnDuplicateKeyCtx) Unmarshal(dAtA []byte) error

+ func (m *OnDuplicateKeyCtx) XXX_DiscardUnknown()

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

+ func (m *OnDuplicateKeyCtx) XXX_Merge(src proto.Message)

+ func (m *OnDuplicateKeyCtx) XXX_Size() int

+ func (m *OnDuplicateKeyCtx) XXX_Unmarshal(b []byte) error

type OnUpdate

+ func (m *OnUpdate) MarshalBinary() ([]byte, error)

+ func (m *OnUpdate) UnmarshalBinary(data []byte) error

type PartitionByDef

+ PartitionTableNames []string

+ func (m *PartitionByDef) GetPartitionTableNames() []string

type PartitionItem

+ PartitionTableName string

+ func (m *PartitionItem) GetPartitionTableName() string

type Plan

+ IsPrepare bool

+ TryRunTimes int32

+ func (m *Plan) GetIsPrepare() bool

+ func (m *Plan) GetTryRunTimes() int32

+ type PreDeleteCtx struct

+ Idx []int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PreDeleteCtx) Descriptor() ([]byte, []int)

+ func (*PreDeleteCtx) ProtoMessage()

+ func (m *PreDeleteCtx) GetIdx() []int32

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

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

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

+ func (m *PreDeleteCtx) ProtoSize() (n int)

+ func (m *PreDeleteCtx) Reset()

+ func (m *PreDeleteCtx) String() string

+ func (m *PreDeleteCtx) Unmarshal(dAtA []byte) error

+ func (m *PreDeleteCtx) XXX_DiscardUnknown()

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

+ func (m *PreDeleteCtx) XXX_Merge(src proto.Message)

+ func (m *PreDeleteCtx) XXX_Size() int

+ func (m *PreDeleteCtx) XXX_Unmarshal(b []byte) error

+ type PreInsertCtx struct

+ HasAutoCol bool

+ IsUpdate bool

+ Ref *ObjectRef

+ TableDef *TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PreInsertCtx) Descriptor() ([]byte, []int)

+ func (*PreInsertCtx) ProtoMessage()

+ func (m *PreInsertCtx) GetHasAutoCol() bool

+ func (m *PreInsertCtx) GetIsUpdate() bool

+ func (m *PreInsertCtx) GetRef() *ObjectRef

+ func (m *PreInsertCtx) GetTableDef() *TableDef

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

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

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

+ func (m *PreInsertCtx) ProtoSize() (n int)

+ func (m *PreInsertCtx) Reset()

+ func (m *PreInsertCtx) String() string

+ func (m *PreInsertCtx) Unmarshal(dAtA []byte) error

+ func (m *PreInsertCtx) XXX_DiscardUnknown()

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

+ func (m *PreInsertCtx) XXX_Merge(src proto.Message)

+ func (m *PreInsertCtx) XXX_Size() int

+ func (m *PreInsertCtx) XXX_Unmarshal(b []byte) error

+ type PreInsertUkCtx struct

+ Columns []int32

+ PkColumn int32

+ PkType *Type

+ TableDef *TableDef

+ UkType *Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PreInsertUkCtx) Descriptor() ([]byte, []int)

+ func (*PreInsertUkCtx) ProtoMessage()

+ func (m *PreInsertUkCtx) GetColumns() []int32

+ func (m *PreInsertUkCtx) GetPkColumn() int32

+ func (m *PreInsertUkCtx) GetPkType() *Type

+ func (m *PreInsertUkCtx) GetTableDef() *TableDef

+ func (m *PreInsertUkCtx) GetUkType() *Type

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

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

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

+ func (m *PreInsertUkCtx) ProtoSize() (n int)

+ func (m *PreInsertUkCtx) Reset()

+ func (m *PreInsertUkCtx) String() string

+ func (m *PreInsertUkCtx) Unmarshal(dAtA []byte) error

+ func (m *PreInsertUkCtx) XXX_DiscardUnknown()

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

+ func (m *PreInsertUkCtx) XXX_Merge(src proto.Message)

+ func (m *PreInsertUkCtx) XXX_Size() int

+ func (m *PreInsertUkCtx) XXX_Unmarshal(b []byte) error

type PrimaryKeyDef

+ CompPkeyCol *ColDef

+ func (m *PrimaryKeyDef) GetCompPkeyCol() *ColDef

+ type PubInfo struct

+ TenantId int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PubInfo) Descriptor() ([]byte, []int)

+ func (*PubInfo) ProtoMessage()

+ func (m *PubInfo) GetTenantId() int32

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

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

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

+ func (m *PubInfo) ProtoSize() (n int)

+ func (m *PubInfo) Reset()

+ func (m *PubInfo) String() string

+ func (m *PubInfo) Unmarshal(dAtA []byte) error

+ func (m *PubInfo) XXX_DiscardUnknown()

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

+ func (m *PubInfo) XXX_Merge(src proto.Message)

+ func (m *PubInfo) XXX_Size() int

+ func (m *PubInfo) XXX_Unmarshal(b []byte) error

+ type RowsetExpr struct

+ Expr *Expr

+ Pos int32

+ RowPos int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RowsetExpr) Descriptor() ([]byte, []int)

+ func (*RowsetExpr) ProtoMessage()

+ func (m *RowsetExpr) GetExpr() *Expr

+ func (m *RowsetExpr) GetPos() int32

+ func (m *RowsetExpr) GetRowPos() int32

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

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

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

+ func (m *RowsetExpr) ProtoSize() (n int)

+ func (m *RowsetExpr) Reset()

+ func (m *RowsetExpr) String() string

+ func (m *RowsetExpr) Unmarshal(dAtA []byte) error

+ func (m *RowsetExpr) XXX_DiscardUnknown()

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

+ func (m *RowsetExpr) XXX_Merge(src proto.Message)

+ func (m *RowsetExpr) XXX_Size() int

+ func (m *RowsetExpr) XXX_Unmarshal(b []byte) error

+ type RuntimeFilterSpec struct

+ Expr *Expr

+ Tag int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RuntimeFilterSpec) Descriptor() ([]byte, []int)

+ func (*RuntimeFilterSpec) ProtoMessage()

+ func (m *RuntimeFilterSpec) GetExpr() *Expr

+ func (m *RuntimeFilterSpec) GetTag() int32

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

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

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

+ func (m *RuntimeFilterSpec) ProtoSize() (n int)

+ func (m *RuntimeFilterSpec) Reset()

+ func (m *RuntimeFilterSpec) String() string

+ func (m *RuntimeFilterSpec) Unmarshal(dAtA []byte) error

+ func (m *RuntimeFilterSpec) XXX_DiscardUnknown()

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

+ func (m *RuntimeFilterSpec) XXX_Merge(src proto.Message)

+ func (m *RuntimeFilterSpec) XXX_Size() int

+ func (m *RuntimeFilterSpec) XXX_Unmarshal(b []byte) error

+ type ShuffleType int32

+ const ShuffleType_Hash

+ const ShuffleType_Range

+ func (ShuffleType) EnumDescriptor() ([]byte, []int)

+ func (x ShuffleType) String() string

type Stats

+ Parallelism int32

+ Shuffle bool

+ ShuffleColIdx int32

+ ShuffleColMax int64

+ ShuffleColMin int64

+ ShuffleType ShuffleType

+ func (m *Stats) GetParallelism() int32

+ func (m *Stats) GetShuffle() bool

+ func (m *Stats) GetShuffleColIdx() int32

+ func (m *Stats) GetShuffleColMax() int64

+ func (m *Stats) GetShuffleColMin() int64

+ func (m *Stats) GetShuffleType() ShuffleType

+ type SubscriptionMeta struct

+ AccountId int32

+ AccountName string

+ DbName string

+ Name string

+ SubName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubscriptionMeta) Descriptor() ([]byte, []int)

+ func (*SubscriptionMeta) ProtoMessage()

+ func (m *SubscriptionMeta) GetAccountId() int32

+ func (m *SubscriptionMeta) GetAccountName() string

+ func (m *SubscriptionMeta) GetDbName() string

+ func (m *SubscriptionMeta) GetName() string

+ func (m *SubscriptionMeta) GetSubName() string

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

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

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

+ func (m *SubscriptionMeta) ProtoSize() (n int)

+ func (m *SubscriptionMeta) Reset()

+ func (m *SubscriptionMeta) String() string

+ func (m *SubscriptionMeta) Unmarshal(dAtA []byte) error

+ func (m *SubscriptionMeta) XXX_DiscardUnknown()

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

+ func (m *SubscriptionMeta) XXX_Merge(src proto.Message)

+ func (m *SubscriptionMeta) XXX_Size() int

+ func (m *SubscriptionMeta) XXX_Unmarshal(b []byte) error

+ type SubscriptionOption struct

+ From string

+ Publication string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubscriptionOption) Descriptor() ([]byte, []int)

+ func (*SubscriptionOption) ProtoMessage()

+ func (m *SubscriptionOption) GetFrom() string

+ func (m *SubscriptionOption) GetPublication() string

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

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

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

+ func (m *SubscriptionOption) ProtoSize() (n int)

+ func (m *SubscriptionOption) Reset()

+ func (m *SubscriptionOption) String() string

+ func (m *SubscriptionOption) Unmarshal(dAtA []byte) error

+ func (m *SubscriptionOption) XXX_DiscardUnknown()

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

+ func (m *SubscriptionOption) XXX_Merge(src proto.Message)

+ func (m *SubscriptionOption) XXX_Size() int

+ func (m *SubscriptionOption) XXX_Unmarshal(b []byte) error

type TableDef

+ IsLocked bool

+ IsTemporary bool

+ TableLockType TableLockType

+ Version uint32

+ func (m *TableDef) GetIsLocked() bool

+ func (m *TableDef) GetIsTemporary() bool

+ func (m *TableDef) GetTableLockType() TableLockType

+ func (m *TableDef) GetVersion() uint32

+ type TableLockInfo struct

+ LockType TableLockType

+ TableDef *TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TableLockInfo) Descriptor() ([]byte, []int)

+ func (*TableLockInfo) ProtoMessage()

+ func (m *TableLockInfo) GetLockType() TableLockType

+ func (m *TableLockInfo) GetTableDef() *TableDef

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

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

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

+ func (m *TableLockInfo) ProtoSize() (n int)

+ func (m *TableLockInfo) Reset()

+ func (m *TableLockInfo) String() string

+ func (m *TableLockInfo) Unmarshal(dAtA []byte) error

+ func (m *TableLockInfo) XXX_DiscardUnknown()

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

+ func (m *TableLockInfo) XXX_Merge(src proto.Message)

+ func (m *TableLockInfo) XXX_Size() int

+ func (m *TableLockInfo) XXX_Unmarshal(b []byte) error

+ type TableLockType int32

+ const TableLockType_TableLockLowPriorityWrite

+ const TableLockType_TableLockNone

+ const TableLockType_TableLockRead

+ const TableLockType_TableLockReadLocal

+ const TableLockType_TableLockWrite

+ func (TableLockType) EnumDescriptor() ([]byte, []int)

+ func (x TableLockType) String() string

type TruncateTable

+ PartitionTableNames []string

+ func (m *TruncateTable) GetPartitionTableNames() []string

+ type UnLockTables struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UnLockTables) Descriptor() ([]byte, []int)

+ func (*UnLockTables) ProtoMessage()

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

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

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

+ func (m *UnLockTables) ProtoSize() (n int)

+ func (m *UnLockTables) Reset()

+ func (m *UnLockTables) String() string

+ func (m *UnLockTables) Unmarshal(dAtA []byte) error

+ func (m *UnLockTables) XXX_DiscardUnknown()

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

+ func (m *UnLockTables) XXX_Merge(src proto.Message)

+ func (m *UnLockTables) XXX_Size() int

+ func (m *UnLockTables) XXX_Unmarshal(b []byte) error

type WindowSpec

+ Frame *FrameClause

+ Name string

+ WindowFunc *Expr

+ func (m *WindowSpec) GetFrame() *FrameClause

+ func (m *WindowSpec) GetName() string

+ func (m *WindowSpec) GetWindowFunc() *Expr

v0.7.0

Feb 18, 2023

Changes in this version

+ var ForeignKeyDef_RefAction_name = map[int32]string

+ var ForeignKeyDef_RefAction_value = map[string]int32

+ type AlterView struct

+ Database string

+ IfExists bool

+ IndexTables []*TableDef

+ Table string

+ TableDef *TableDef

+ Temporary bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlterView) ProtoMessage()

+ func (m *AlterView) GetDatabase() string

+ func (m *AlterView) GetIfExists() bool

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

+ func (m *AlterView) GetTable() string

+ func (m *AlterView) GetTableDef() *TableDef

+ func (m *AlterView) GetTemporary() bool

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

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

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

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

+ func (m *AlterView) Reset()

+ func (m *AlterView) String() string

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

+ func (m *AlterView) XXX_DiscardUnknown()

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

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

+ func (m *AlterView) XXX_Size() int

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

type AnalyzeInfo

+ DiskIO int64

+ InsertTime int64

+ NetworkIO int64

+ S3IOByte int64

+ S3IOCount int64

+ ScanTime int64

+ WaitTimeConsumed int64

+ func (m *AnalyzeInfo) GetDiskIO() int64

+ func (m *AnalyzeInfo) GetInsertTime() int64

+ func (m *AnalyzeInfo) GetNetworkIO() int64

+ func (m *AnalyzeInfo) GetS3IOByte() int64

+ func (m *AnalyzeInfo) GetS3IOCount() int64

+ func (m *AnalyzeInfo) GetScanTime() int64

+ func (m *AnalyzeInfo) GetWaitTimeConsumed() int64

+ type CheckDef struct

+ Check *Expr

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CheckDef) ProtoMessage()

+ func (m *CheckDef) GetCheck() *Expr

+ func (m *CheckDef) GetName() string

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

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

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

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

+ func (m *CheckDef) Reset()

+ func (m *CheckDef) String() string

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

+ func (m *CheckDef) XXX_DiscardUnknown()

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

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

+ func (m *CheckDef) XXX_Size() int

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

+ type ClusterByDef struct

+ Name string

+ Parts []*Expr

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ClusterByDef) ProtoMessage()

+ func (m *ClusterByDef) GetName() string

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

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

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

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

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

+ func (m *ClusterByDef) Reset()

+ func (m *ClusterByDef) String() string

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

+ func (m *ClusterByDef) XXX_DiscardUnknown()

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

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

+ func (m *ClusterByDef) XXX_Size() int

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

+ type ClusterTable struct

+ AccountIDs []uint32

+ ColumnIndexOfAccountId int32

+ IsClusterTable bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ClusterTable) ProtoMessage()

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

+ func (m *ClusterTable) GetColumnIndexOfAccountId() int32

+ func (m *ClusterTable) GetIsClusterTable() bool

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

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

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

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

+ func (m *ClusterTable) Reset()

+ func (m *ClusterTable) String() string

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

+ func (m *ClusterTable) XXX_DiscardUnknown()

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

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

+ func (m *ClusterTable) XXX_Size() int

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

type ColData

+ Data []*Expr

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

type ColDef

+ ClusterBy bool

+ ColId uint64

+ Hidden bool

+ LowCard bool

+ NotNull bool

+ func (m *ColDef) GetClusterBy() bool

+ func (m *ColDef) GetColId() uint64

+ func (m *ColDef) GetHidden() bool

+ func (m *ColDef) GetLowCard() bool

+ func (m *ColDef) GetNotNull() bool

+ type ColPosMap struct

+ Map map[string]int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ColPosMap) ProtoMessage()

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

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

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

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

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

+ func (m *ColPosMap) Reset()

+ func (m *ColPosMap) String() string

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

+ func (m *ColPosMap) XXX_DiscardUnknown()

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

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

+ func (m *ColPosMap) XXX_Size() int

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

type Const

+ Src *Expr

+ func (m *Const) GetSrc() *Expr

type CreateIndex

+ Database string

+ OriginTablePrimaryKey string

+ Table string

+ TableExist bool

+ func (m *CreateIndex) GetDatabase() string

+ func (m *CreateIndex) GetOriginTablePrimaryKey() string

+ func (m *CreateIndex) GetTable() string

+ func (m *CreateIndex) GetTableExist() bool

type CreateTable

+ FkCols []*CreateTable_FkColName

+ FkDbs []string

+ FkTables []string

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

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

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

+ type CreateTable_FkColName struct

+ Cols []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateTable_FkColName) ProtoMessage()

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

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

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

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

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

+ func (m *CreateTable_FkColName) Reset()

+ func (m *CreateTable_FkColName) String() string

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

+ func (m *CreateTable_FkColName) XXX_DiscardUnknown()

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

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

+ func (m *CreateTable_FkColName) XXX_Size() int

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

type DataDefinition

+ func (m *DataDefinition) GetAlterView() *AlterView

+ type DataDefinition_AlterView struct

+ AlterView *AlterView

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

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

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

+ type DeleteCtx struct

+ CanTruncate bool

+ IdxIdx []int32

+ IdxRef []*ObjectRef

+ OnCascadeIdx []int32

+ OnCascadeRef []*ObjectRef

+ OnRestrictIdx []int32

+ OnRestrictRef []*ObjectRef

+ OnSetDef []*TableDef

+ OnSetIdx []*IdList

+ OnSetRef []*ObjectRef

+ OnSetUpdateCol []*ColPosMap

+ Ref []*ObjectRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteCtx) ProtoMessage()

+ func (m *DeleteCtx) GetCanTruncate() bool

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (m *DeleteCtx) Reset()

+ func (m *DeleteCtx) String() string

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

+ func (m *DeleteCtx) XXX_DiscardUnknown()

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

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

+ func (m *DeleteCtx) XXX_Size() int

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

type DropIndex

+ Database string

+ IndexName string

+ IndexTableName string

+ Table string

+ func (m *DropIndex) GetDatabase() string

+ func (m *DropIndex) GetIndexName() string

+ func (m *DropIndex) GetIndexTableName() string

+ func (m *DropIndex) GetTable() string

type DropTable

+ ClusterTable *ClusterTable

+ ForeignTbl []uint64

+ TableId uint64

+ func (m *DropTable) GetClusterTable() *ClusterTable

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

+ func (m *DropTable) GetTableId() uint64

type Expr

+ func (m *Expr) GetRaw() *RawColRef

+ type Expr_Raw struct

+ Raw *RawColRef

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

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

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

+ type ForeignKeyDef struct

+ Cols []uint64

+ ForeignCols []uint64

+ ForeignTbl uint64

+ Name string

+ OnDelete ForeignKeyDef_RefAction

+ OnUpdate ForeignKeyDef_RefAction

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ForeignKeyDef) ProtoMessage()

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

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

+ func (m *ForeignKeyDef) GetForeignTbl() uint64

+ func (m *ForeignKeyDef) GetName() string

+ func (m *ForeignKeyDef) GetOnDelete() ForeignKeyDef_RefAction

+ func (m *ForeignKeyDef) GetOnUpdate() ForeignKeyDef_RefAction

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

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

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

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

+ func (m *ForeignKeyDef) Reset()

+ func (m *ForeignKeyDef) String() string

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

+ func (m *ForeignKeyDef) XXX_DiscardUnknown()

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

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

+ func (m *ForeignKeyDef) XXX_Size() int

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

+ type ForeignKeyDef_RefAction int32

+ const ForeignKeyDef_CASCADE

+ const ForeignKeyDef_NO_ACTION

+ const ForeignKeyDef_RESTRICT

+ const ForeignKeyDef_SET_DEFAULT

+ const ForeignKeyDef_SET_NULL

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

+ func (x ForeignKeyDef_RefAction) String() string

+ type IdList struct

+ List []int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IdList) ProtoMessage()

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

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

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

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

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

+ func (m *IdList) Reset()

+ func (m *IdList) String() string

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

+ func (m *IdList) XXX_DiscardUnknown()

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

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

+ func (m *IdList) XXX_Size() int

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

type IndexDef

+ Comment string

+ IdxId string

+ IndexName string

+ IndexTableName string

+ Option *IndexOption

+ Parts []string

+ TableExist bool

+ Unique bool

+ func (m *IndexDef) GetComment() string

+ func (m *IndexDef) GetIdxId() string

+ func (m *IndexDef) GetIndexName() string

+ func (m *IndexDef) GetIndexTableName() string

+ func (m *IndexDef) GetOption() *IndexOption

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

+ func (m *IndexDef) GetTableExist() bool

+ func (m *IndexDef) GetUnique() bool

+ type IndexOption struct

+ CreateExtraTable bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IndexOption) ProtoMessage()

+ func (m *IndexOption) GetCreateExtraTable() bool

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

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

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

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

+ func (m *IndexOption) Reset()

+ func (m *IndexOption) String() string

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

+ func (m *IndexOption) XXX_DiscardUnknown()

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

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

+ func (m *IndexOption) XXX_Size() int

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

+ type InsertCtx struct

+ ClusterTable *ClusterTable

+ Idx []int32

+ ParentIdx map[string]int32

+ Ref *ObjectRef

+ TableDef *TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*InsertCtx) ProtoMessage()

+ func (m *InsertCtx) GetClusterTable() *ClusterTable

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

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

+ func (m *InsertCtx) GetRef() *ObjectRef

+ func (m *InsertCtx) GetTableDef() *TableDef

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

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

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

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

+ func (m *InsertCtx) Reset()

+ func (m *InsertCtx) String() string

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

+ func (m *InsertCtx) XXX_DiscardUnknown()

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

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

+ func (m *InsertCtx) XXX_Size() int

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

type Node

+ ClusterTable *ClusterTable

+ DeleteCtx *DeleteCtx

+ InsertCtx *InsertCtx

+ NotCacheable bool

+ Parallelism int32

+ Stats *Stats

+ UpdateCtx *UpdateCtx

+ func (m *Node) GetClusterTable() *ClusterTable

+ func (m *Node) GetDeleteCtx() *DeleteCtx

+ func (m *Node) GetInsertCtx() *InsertCtx

+ func (m *Node) GetNotCacheable() bool

+ func (m *Node) GetParallelism() int32

+ func (m *Node) GetStats() *Stats

+ func (m *Node) GetUpdateCtx() *UpdateCtx

+ type PartitionByDef struct

+ Algorithm int64

+ IsSubPartition bool

+ PartitionColumns *PartitionColumns

+ PartitionExpr *PartitionExpr

+ PartitionExpression *Expr

+ PartitionMsg string

+ PartitionNum uint64

+ Partitions []*PartitionItem

+ Type PartitionType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PartitionByDef) ProtoMessage()

+ func (m *PartitionByDef) GetAlgorithm() int64

+ func (m *PartitionByDef) GetIsSubPartition() bool

+ func (m *PartitionByDef) GetPartitionColumns() *PartitionColumns

+ func (m *PartitionByDef) GetPartitionExpr() *PartitionExpr

+ func (m *PartitionByDef) GetPartitionExpression() *Expr

+ func (m *PartitionByDef) GetPartitionMsg() string

+ func (m *PartitionByDef) GetPartitionNum() uint64

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

+ func (m *PartitionByDef) GetType() PartitionType

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

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

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

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

+ func (m *PartitionByDef) Reset()

+ func (m *PartitionByDef) String() string

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

+ func (m *PartitionByDef) XXX_DiscardUnknown()

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

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

+ func (m *PartitionByDef) XXX_Size() int

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

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

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

+ type PartitionColumns struct

+ Columns []*Expr

+ PartitionColumns []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PartitionColumns) ProtoMessage()

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

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

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

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

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

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

+ func (m *PartitionColumns) Reset()

+ func (m *PartitionColumns) String() string

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

+ func (m *PartitionColumns) XXX_DiscardUnknown()

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

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

+ func (m *PartitionColumns) XXX_Size() int

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

+ type PartitionExpr struct

+ Expr *Expr

+ ExprStr string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PartitionExpr) ProtoMessage()

+ func (m *PartitionExpr) GetExpr() *Expr

+ func (m *PartitionExpr) GetExprStr() string

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

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

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

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

+ func (m *PartitionExpr) Reset()

+ func (m *PartitionExpr) String() string

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

+ func (m *PartitionExpr) XXX_DiscardUnknown()

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

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

+ func (m *PartitionExpr) XXX_Size() int

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

type PrimaryKeyDef

+ Cols []uint64

+ Option *IndexOption

+ PkeyColId uint64

+ PkeyColName string

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

+ func (m *PrimaryKeyDef) GetOption() *IndexOption

+ func (m *PrimaryKeyDef) GetPkeyColId() uint64

+ func (m *PrimaryKeyDef) GetPkeyColName() string

+ type PropertyDef struct

+ Key string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PropertyDef) Descriptor() ([]byte, []int)

+ func (*PropertyDef) ProtoMessage()

+ func (m *PropertyDef) GetKey() string

+ func (m *PropertyDef) GetValue() string

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

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

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

+ func (m *PropertyDef) ProtoSize() (n int)

+ func (m *PropertyDef) Reset()

+ func (m *PropertyDef) String() string

+ func (m *PropertyDef) Unmarshal(dAtA []byte) error

+ func (m *PropertyDef) XXX_DiscardUnknown()

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

+ func (m *PropertyDef) XXX_Merge(src proto.Message)

+ func (m *PropertyDef) XXX_Size() int

+ func (m *PropertyDef) XXX_Unmarshal(b []byte) error

+ type RawColRef struct

+ ColId uint64

+ TblId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RawColRef) Descriptor() ([]byte, []int)

+ func (*RawColRef) ProtoMessage()

+ func (m *RawColRef) GetColId() uint64

+ func (m *RawColRef) GetTblId() uint64

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

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

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

+ func (m *RawColRef) ProtoSize() (n int)

+ func (m *RawColRef) Reset()

+ func (m *RawColRef) String() string

+ func (m *RawColRef) Unmarshal(dAtA []byte) error

+ func (m *RawColRef) XXX_DiscardUnknown()

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

+ func (m *RawColRef) XXX_Merge(src proto.Message)

+ func (m *RawColRef) XXX_Size() int

+ func (m *RawColRef) XXX_Unmarshal(b []byte) error

+ type ResultColDef struct

+ ResultCols []*ColDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ResultColDef) Descriptor() ([]byte, []int)

+ func (*ResultColDef) ProtoMessage()

+ func (m *ResultColDef) GetResultCols() []*ColDef

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

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

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

+ func (m *ResultColDef) ProtoSize() (n int)

+ func (m *ResultColDef) Reset()

+ func (m *ResultColDef) String() string

+ func (m *ResultColDef) Unmarshal(dAtA []byte) error

+ func (m *ResultColDef) XXX_DiscardUnknown()

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

+ func (m *ResultColDef) XXX_Merge(src proto.Message)

+ func (m *ResultColDef) XXX_Size() int

+ func (m *ResultColDef) XXX_Unmarshal(b []byte) error

+ type Stats struct

+ BlockNum int32

+ Cost float64

+ HashmapSize float64

+ Outcnt float64

+ Rowsize float64

+ Selectivity float64

+ TableCnt float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Stats) Descriptor() ([]byte, []int)

+ func (*Stats) ProtoMessage()

+ func (m *Stats) GetBlockNum() int32

+ func (m *Stats) GetCost() float64

+ func (m *Stats) GetHashmapSize() float64

+ func (m *Stats) GetOutcnt() float64

+ func (m *Stats) GetRowsize() float64

+ func (m *Stats) GetSelectivity() float64

+ func (m *Stats) GetTableCnt() float64

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

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

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

+ func (m *Stats) ProtoSize() (n int)

+ func (m *Stats) Reset()

+ func (m *Stats) String() string

+ func (m *Stats) Unmarshal(dAtA []byte) error

+ func (m *Stats) XXX_DiscardUnknown()

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

+ func (m *Stats) XXX_Merge(src proto.Message)

+ func (m *Stats) XXX_Size() int

+ func (m *Stats) XXX_Unmarshal(b []byte) error

type TableDef

+ Checks []*CheckDef

+ ClusterBy *ClusterByDef

+ Fkeys []*ForeignKeyDef

+ Hidden bool

+ Indexes []*IndexDef

+ OriginCols []*ColDef

+ Partition *PartitionByDef

+ Pkey *PrimaryKeyDef

+ Props []*PropertyDef

+ RefChildTbls []uint64

+ TblId uint64

+ ViewSql *ViewDef

+ func (m *TableDef) GetChecks() []*CheckDef

+ func (m *TableDef) GetClusterBy() *ClusterByDef

+ func (m *TableDef) GetFkeys() []*ForeignKeyDef

+ func (m *TableDef) GetHidden() bool

+ func (m *TableDef) GetIndexes() []*IndexDef

+ func (m *TableDef) GetOriginCols() []*ColDef

+ func (m *TableDef) GetPartition() *PartitionByDef

+ func (m *TableDef) GetPkey() *PrimaryKeyDef

+ func (m *TableDef) GetProps() []*PropertyDef

+ func (m *TableDef) GetRefChildTbls() []uint64

+ func (m *TableDef) GetTblId() uint64

+ func (m *TableDef) GetViewSql() *ViewDef

type TruncateTable

+ ClusterTable *ClusterTable

+ ForeignTbl []uint64

+ TableId uint64

+ func (m *TruncateTable) GetClusterTable() *ClusterTable

+ func (m *TruncateTable) GetForeignTbl() []uint64

+ func (m *TruncateTable) GetTableId() uint64

type Type

+ NotNullable bool

+ func (m *Type) GetNotNullable() bool

type UpdateCtx

+ Idx []*IdList

+ IdxIdx []int32

+ IdxRef []*ObjectRef

+ OnCascadeDef []*TableDef

+ OnCascadeIdx []*IdList

+ OnCascadeRef []*ObjectRef

+ OnCascadeUpdateCol []*ColPosMap

+ OnRestrictIdx []int32

+ OnRestrictRef []*ObjectRef

+ OnSetDef []*TableDef

+ OnSetIdx []*IdList

+ OnSetRef []*ObjectRef

+ OnSetUpdateCol []*ColPosMap

+ ParentIdx []*ColPosMap

+ Ref []*ObjectRef

+ TableDefs []*TableDef

+ UpdateCol []*ColPosMap

+ func (m *UpdateCtx) GetIdx() []*IdList

+ func (m *UpdateCtx) GetIdxIdx() []int32

+ func (m *UpdateCtx) GetIdxRef() []*ObjectRef

+ func (m *UpdateCtx) GetOnCascadeDef() []*TableDef

+ func (m *UpdateCtx) GetOnCascadeIdx() []*IdList

+ func (m *UpdateCtx) GetOnCascadeRef() []*ObjectRef

+ func (m *UpdateCtx) GetOnCascadeUpdateCol() []*ColPosMap

+ func (m *UpdateCtx) GetOnRestrictIdx() []int32

+ func (m *UpdateCtx) GetOnRestrictRef() []*ObjectRef

+ func (m *UpdateCtx) GetOnSetDef() []*TableDef

+ func (m *UpdateCtx) GetOnSetIdx() []*IdList

+ func (m *UpdateCtx) GetOnSetRef() []*ObjectRef

+ func (m *UpdateCtx) GetOnSetUpdateCol() []*ColPosMap

+ func (m *UpdateCtx) GetParentIdx() []*ColPosMap

+ func (m *UpdateCtx) GetRef() []*ObjectRef

+ func (m *UpdateCtx) GetTableDefs() []*TableDef

+ func (m *UpdateCtx) GetUpdateCol() []*ColPosMap

v0.6.0

Nov 29, 2022

Changes in this version

+ var PartitionType_name = map[int32]string

+ var PartitionType_value = map[string]int32

+ type AnalyzeInfo struct

+ InputRows int64

+ InputSize int64

+ MemorySize int64

+ OutputRows int64

+ OutputSize int64

+ TimeConsumed int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AnalyzeInfo) ProtoMessage()

+ func (m *AnalyzeInfo) GetInputRows() int64

+ func (m *AnalyzeInfo) GetInputSize() int64

+ func (m *AnalyzeInfo) GetMemorySize() int64

+ func (m *AnalyzeInfo) GetOutputRows() int64

+ func (m *AnalyzeInfo) GetOutputSize() int64

+ func (m *AnalyzeInfo) GetTimeConsumed() int64

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

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

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

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

+ func (m *AnalyzeInfo) Reset()

+ func (m *AnalyzeInfo) String() string

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

+ func (m *AnalyzeInfo) XXX_DiscardUnknown()

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

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

+ func (m *AnalyzeInfo) XXX_Size() int

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

type ColDef

+ Comment string

+ IsCPkey bool

+ LowCardinality bool

+ OnUpdate *OnUpdate

+ func (m *ColDef) GetComment() string

+ func (m *ColDef) GetIsCPkey() bool

+ func (m *ColDef) GetLowCardinality() bool

+ func (m *ColDef) GetOnUpdate() *OnUpdate

+ type Column struct

+ Column []*Expr

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Column) ProtoMessage()

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

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

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

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

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

+ func (m *Column) Reset()

+ func (m *Column) String() string

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

+ func (m *Column) XXX_DiscardUnknown()

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

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

+ func (m *Column) XXX_Size() int

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

type Const

+ IsBin bool

+ func (m *Const) GetDefaultval() bool

+ func (m *Const) GetI16Val() int32

+ func (m *Const) GetI32Val() int32

+ func (m *Const) GetI64Val() int64

+ func (m *Const) GetI8Val() int32

+ func (m *Const) GetIsBin() bool

+ func (m *Const) GetJsonval() string

+ func (m *Const) GetTimeval() int64

+ func (m *Const) GetU16Val() uint32

+ func (m *Const) GetU32Val() uint32

+ func (m *Const) GetU64Val() uint64

+ func (m *Const) GetU8Val() uint32

+ func (m *Const) GetUpdateVal() bool

+ type Const_Defaultval struct

+ Defaultval bool

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

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

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

+ type Const_I16Val struct

+ I16Val int32

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

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

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

+ type Const_I32Val struct

+ I32Val int32

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

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

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

+ type Const_I64Val struct

+ I64Val int64

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

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

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

+ type Const_I8Val struct

+ I8Val int32

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

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

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

+ type Const_Jsonval struct

+ Jsonval string

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

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

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

+ type Const_Timeval struct

+ Timeval int64

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

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

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

+ type Const_U16Val struct

+ U16Val uint32

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

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

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

+ type Const_U32Val struct

+ U32Val uint32

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

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

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

+ type Const_U64Val struct

+ U64Val uint64

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

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

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

+ type Const_U8Val struct

+ U8Val uint32

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

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

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

+ type Const_UpdateVal struct

+ UpdateVal bool

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

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

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

type CreateTable

+ IndexTables []*TableDef

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

type DataDefinition_DdlType

+ const DataDefinition_ALTER_VIEW

+ const DataDefinition_CREATE_VIEW

+ const DataDefinition_DROP_VIEW

+ const DataDefinition_SHOW_COLLATION

+ const DataDefinition_SHOW_TABLE_STATUS

+ const DataDefinition_SHOW_TARGET

type Decimal128

+ A int64

+ B int64

+ func (m *Decimal128) GetA() int64

+ func (m *Decimal128) GetB() int64

+ type Decimal64 struct

+ A int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Decimal64) ProtoMessage()

+ func (m *Decimal64) GetA() int64

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

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

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

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

+ func (m *Decimal64) Reset()

+ func (m *Decimal64) String() string

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

+ func (m *Decimal64) XXX_DiscardUnknown()

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

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

+ func (m *Decimal64) XXX_Size() int

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

+ type Default struct

+ Expr *Expr

+ NullAbility bool

+ OriginString string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Default) ProtoMessage()

+ func (m *Default) GetExpr() *Expr

+ func (m *Default) GetNullAbility() bool

+ func (m *Default) GetOriginString() string

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

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

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

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

+ func (m *Default) Reset()

+ func (m *Default) String() string

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

+ func (m *Default) XXX_DiscardUnknown()

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

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

+ func (m *Default) XXX_Size() int

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

type DeleteTableCtx

+ ColIndex int32

+ IndexAttrs []string

+ IndexInfos []*IndexInfo

+ func (m *DeleteTableCtx) GetColIndex() int32

+ func (m *DeleteTableCtx) GetIndexAttrs() []string

+ func (m *DeleteTableCtx) GetIndexInfos() []*IndexInfo

type DropTable

+ IndexTableNames []string

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

type Expr

+ func (m *Expr) GetMax() *MaxValue

+ type Expr_Max struct

+ Max *MaxValue

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

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

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

+ type Field struct

+ ColNames []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Field) Descriptor() ([]byte, []int)

+ func (*Field) ProtoMessage()

+ func (m *Field) GetColNames() []string

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

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

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

+ func (m *Field) ProtoSize() (n int)

+ func (m *Field) Reset()

+ func (m *Field) String() string

+ func (m *Field) Unmarshal(dAtA []byte) error

+ func (m *Field) XXX_DiscardUnknown()

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

+ func (m *Field) XXX_Merge(src proto.Message)

+ func (m *Field) XXX_Size() int

+ func (m *Field) XXX_Unmarshal(b []byte) error

type Function_FuncFlag

+ const Function_MONOTONIC

type IndexDef

+ Fields []*Field

+ IndexNames []string

+ TableNames []string

+ Uniques []bool

+ func (m *IndexDef) GetFields() []*Field

+ func (m *IndexDef) GetIndexNames() []string

+ func (m *IndexDef) GetTableNames() []string

+ func (m *IndexDef) GetUniques() []bool

+ type IndexInfo struct

+ ColNames []string

+ Cols []*ColDef

+ Field *Field

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IndexInfo) ProtoMessage()

+ func (m *IndexInfo) GetColNames() []string

+ func (m *IndexInfo) GetCols() []*ColDef

+ func (m *IndexInfo) GetField() *Field

+ func (m *IndexInfo) GetTableName() string

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

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

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

+ func (m *IndexInfo) ProtoSize() (n int)

+ func (m *IndexInfo) Reset()

+ func (m *IndexInfo) String() string

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

+ func (m *IndexInfo) XXX_DiscardUnknown()

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

+ func (m *IndexInfo) XXX_Merge(src proto.Message)

+ func (m *IndexInfo) XXX_Size() int

+ func (m *IndexInfo) XXX_Unmarshal(b []byte) error

+ type InsertValues struct

+ Columns []*Column

+ CompositePkey *ColDef

+ DbName string

+ ExplicitCols []*ColDef

+ IndexInfos []*IndexInfo

+ OrderAttrs []string

+ OtherCols []*ColDef

+ TblName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*InsertValues) Descriptor() ([]byte, []int)

+ func (*InsertValues) ProtoMessage()

+ func (m *InsertValues) GetColumns() []*Column

+ func (m *InsertValues) GetCompositePkey() *ColDef

+ func (m *InsertValues) GetDbName() string

+ func (m *InsertValues) GetExplicitCols() []*ColDef

+ func (m *InsertValues) GetIndexInfos() []*IndexInfo

+ func (m *InsertValues) GetOrderAttrs() []string

+ func (m *InsertValues) GetOtherCols() []*ColDef

+ func (m *InsertValues) GetTblName() string

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

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

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

+ func (m *InsertValues) ProtoSize() (n int)

+ func (m *InsertValues) Reset()

+ func (m *InsertValues) String() string

+ func (m *InsertValues) Unmarshal(dAtA []byte) error

+ func (m *InsertValues) XXX_DiscardUnknown()

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

+ func (m *InsertValues) XXX_Merge(src proto.Message)

+ func (m *InsertValues) XXX_Size() int

+ func (m *InsertValues) XXX_Unmarshal(b []byte) error

+ type MaxValue struct

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MaxValue) ProtoMessage()

+ func (m *MaxValue) GetValue() string

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

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

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

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

+ func (m *MaxValue) Reset()

+ func (m *MaxValue) String() string

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

+ func (m *MaxValue) XXX_DiscardUnknown()

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

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

+ func (m *MaxValue) XXX_Size() int

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

type Node

+ AnalyzeInfo *AnalyzeInfo

+ TableDefVec []*TableDef

+ TblFuncExprList []*Expr

+ UpdateCtxs []*UpdateCtx

+ func (m *Node) GetAnalyzeInfo() *AnalyzeInfo

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

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

+ func (m *Node) GetUpdateCtxs() []*UpdateCtx

type Node_NodeType

+ const Node_INTERSECT

+ const Node_INTERSECT_ALL

+ const Node_MINUS

+ const Node_MINUS_ALL

+ const Node_TABLE_FUNCTION

+ type OnUpdate struct

+ Expr *Expr

+ OriginString string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*OnUpdate) ProtoMessage()

+ func (m *OnUpdate) GetExpr() *Expr

+ func (m *OnUpdate) GetOriginString() string

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

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

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

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

+ func (m *OnUpdate) Reset()

+ func (m *OnUpdate) String() string

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

+ func (m *OnUpdate) XXX_DiscardUnknown()

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

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

+ func (m *OnUpdate) XXX_Size() int

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

+ type PartitionInfo struct

+ Algorithm int64

+ Columns []*Expr

+ Expr *Expr

+ IsSubPartition bool

+ PartitionColumns []string

+ PartitionExpression *Expr

+ PartitionMsg string

+ PartitionNum uint64

+ Partitions []*PartitionItem

+ Type PartitionType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PartitionInfo) Descriptor() ([]byte, []int)

+ func (*PartitionInfo) ProtoMessage()

+ func (m *PartitionInfo) GetAlgorithm() int64

+ func (m *PartitionInfo) GetColumns() []*Expr

+ func (m *PartitionInfo) GetExpr() *Expr

+ func (m *PartitionInfo) GetIsSubPartition() bool

+ func (m *PartitionInfo) GetPartitionColumns() []string

+ func (m *PartitionInfo) GetPartitionExpression() *Expr

+ func (m *PartitionInfo) GetPartitionMsg() string

+ func (m *PartitionInfo) GetPartitionNum() uint64

+ func (m *PartitionInfo) GetPartitions() []*PartitionItem

+ func (m *PartitionInfo) GetType() PartitionType

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

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

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

+ func (m *PartitionInfo) ProtoSize() (n int)

+ func (m *PartitionInfo) Reset()

+ func (m *PartitionInfo) String() string

+ func (m *PartitionInfo) Unmarshal(dAtA []byte) error

+ func (m *PartitionInfo) XXX_DiscardUnknown()

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

+ func (m *PartitionInfo) XXX_Merge(src proto.Message)

+ func (m *PartitionInfo) XXX_Size() int

+ func (m *PartitionInfo) XXX_Unmarshal(b []byte) error

+ func (p *PartitionInfo) MarshalPartitionInfo() ([]byte, error)

+ func (p *PartitionInfo) UnMarshalPartitionInfo(data []byte) error

+ type PartitionItem struct

+ Comment string

+ Description string

+ InValues []*Expr

+ LessThan []*Expr

+ OrdinalPosition uint32

+ PartitionName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PartitionItem) ProtoMessage()

+ func (m *PartitionItem) GetComment() string

+ func (m *PartitionItem) GetDescription() string

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

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

+ func (m *PartitionItem) GetOrdinalPosition() uint32

+ func (m *PartitionItem) GetPartitionName() string

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

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

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

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

+ func (m *PartitionItem) Reset()

+ func (m *PartitionItem) String() string

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

+ func (m *PartitionItem) XXX_DiscardUnknown()

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

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

+ func (m *PartitionItem) XXX_Size() int

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

+ type PartitionType int32

+ const PartitionType_HASH

+ const PartitionType_KEY

+ const PartitionType_LINEAR_HASH

+ const PartitionType_LINEAR_KEY

+ const PartitionType_LIST

+ const PartitionType_LIST_COLUMNS

+ const PartitionType_RANGE

+ const PartitionType_RANGE_COLUMNS

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

+ func (x PartitionType) String() string

type Plan

+ func (m *Plan) GetIns() *InsertValues

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

+ func (p *Plan) NeedImplicitTxn() bool

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

+ type Plan_Ins struct

+ Ins *InsertValues

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

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

+ func (m *Plan_Ins) ProtoSize() (n int)

type Prepare

+ ParamTypes []int32

+ Schemas []*ObjectRef

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

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

type Query

+ LoadTag bool

+ func (m *Query) GetLoadTag() bool

type SubqueryRef

+ RowSize int32

+ func (m *SubqueryRef) GetRowSize() int32

type TableDef

+ CompositePkey *ColDef

+ Createsql string

+ IndexInfos []*IndexInfo

+ Name2ColIndex map[string]int32

+ TableType string

+ TblFunc *TableFunction

+ func (m *TableDef) GetCompositePkey() *ColDef

+ func (m *TableDef) GetCreatesql() string

+ func (m *TableDef) GetIndexInfos() []*IndexInfo

+ func (m *TableDef) GetName2ColIndex() map[string]int32

+ func (m *TableDef) GetTableType() string

+ func (m *TableDef) GetTblFunc() *TableFunction

type TableDef_DefType

+ func (m *TableDef_DefType) GetPartition() *PartitionInfo

+ func (m *TableDef_DefType) GetView() *ViewDef

+ type TableDef_DefType_Partition struct

+ Partition *PartitionInfo

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

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

+ func (m *TableDef_DefType_Partition) ProtoSize() (n int)

+ type TableDef_DefType_View struct

+ View *ViewDef

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

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

+ func (m *TableDef_DefType_View) ProtoSize() (n int)

+ type TableFunction struct

+ Name string

+ Param []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TableFunction) Descriptor() ([]byte, []int)

+ func (*TableFunction) ProtoMessage()

+ func (m *TableFunction) GetName() string

+ func (m *TableFunction) GetParam() []byte

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

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

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

+ func (m *TableFunction) ProtoSize() (n int)

+ func (m *TableFunction) Reset()

+ func (m *TableFunction) String() string

+ func (m *TableFunction) Unmarshal(dAtA []byte) error

+ func (m *TableFunction) XXX_DiscardUnknown()

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

+ func (m *TableFunction) XXX_Merge(src proto.Message)

+ func (m *TableFunction) XXX_Size() int

+ func (m *TableFunction) XXX_Unmarshal(b []byte) error

type TruncateTable

+ Database string

+ IndexTableNames []string

+ func (m *TruncateTable) GetDatabase() string

+ func (m *TruncateTable) GetIndexTableNames() []string

type Type

+ AutoIncr bool

+ Table string

+ func (m *Type) GetAutoIncr() bool

+ func (m *Type) GetTable() string

+ type UpdateCtx struct

+ CompositePkey *ColDef

+ DbName string

+ HideKey string

+ HideKeyIdx int32

+ IndexAttrs []string

+ OrderAttrs []string

+ OtherAttrs []string

+ PriKey string

+ PriKeyIdx int32

+ TblName string

+ UpdateCols []*ColDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdateCtx) Descriptor() ([]byte, []int)

+ func (*UpdateCtx) ProtoMessage()

+ func (m *UpdateCtx) GetCompositePkey() *ColDef

+ func (m *UpdateCtx) GetDbName() string

+ func (m *UpdateCtx) GetHideKey() string

+ func (m *UpdateCtx) GetHideKeyIdx() int32

+ func (m *UpdateCtx) GetIndexAttrs() []string

+ func (m *UpdateCtx) GetOrderAttrs() []string

+ func (m *UpdateCtx) GetOtherAttrs() []string

+ func (m *UpdateCtx) GetPriKey() string

+ func (m *UpdateCtx) GetPriKeyIdx() int32

+ func (m *UpdateCtx) GetTblName() string

+ func (m *UpdateCtx) GetUpdateCols() []*ColDef

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

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

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

+ func (m *UpdateCtx) ProtoSize() (n int)

+ func (m *UpdateCtx) Reset()

+ func (m *UpdateCtx) String() string

+ func (m *UpdateCtx) Unmarshal(dAtA []byte) error

+ func (m *UpdateCtx) XXX_DiscardUnknown()

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

+ func (m *UpdateCtx) XXX_Merge(src proto.Message)

+ func (m *UpdateCtx) XXX_Size() int

+ func (m *UpdateCtx) XXX_Unmarshal(b []byte) error

type VarRef

+ Global bool

+ System bool

+ func (m *VarRef) GetGlobal() bool

+ func (m *VarRef) GetSystem() bool

+ type ViewDef struct

+ View string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ViewDef) Descriptor() ([]byte, []int)

+ func (*ViewDef) ProtoMessage()

+ func (m *ViewDef) GetView() string

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

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

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

+ func (m *ViewDef) ProtoSize() (n int)

+ func (m *ViewDef) Reset()

+ func (m *ViewDef) String() string

+ func (m *ViewDef) Unmarshal(dAtA []byte) error

+ func (m *ViewDef) XXX_DiscardUnknown()

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

+ func (m *ViewDef) XXX_Merge(src proto.Message)

+ func (m *ViewDef) XXX_Size() int

+ func (m *ViewDef) XXX_Unmarshal(b []byte) error

v0.5.1

Aug 17, 2022

Changes in this version

type DataControl

+ func (m *DataControl) GetDeallocate() *Deallocate

+ func (m *DataControl) GetExecute() *Execute

+ func (m *DataControl) GetPrepare() *Prepare

type DataControl_DclType

+ const DataControl_DEALLOCATE

+ const DataControl_EXECUTE

+ const DataControl_PREPARE

+ type DataControl_Deallocate struct

+ Deallocate *Deallocate

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

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

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

+ type DataControl_Execute struct

+ Execute *Execute

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

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

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

+ type DataControl_Prepare struct

+ Prepare *Prepare

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

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

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

+ type Deallocate struct

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Deallocate) ProtoMessage()

+ func (m *Deallocate) GetName() string

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

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

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

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

+ func (m *Deallocate) Reset()

+ func (m *Deallocate) String() string

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

+ func (m *Deallocate) XXX_DiscardUnknown()

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

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

+ func (m *Deallocate) XXX_Size() int

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

+ type DeleteTableCtx struct

+ CanTruncate bool

+ DbName string

+ TblName string

+ UseDeleteKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteTableCtx) Descriptor() ([]byte, []int)

+ func (*DeleteTableCtx) ProtoMessage()

+ func (m *DeleteTableCtx) GetCanTruncate() bool

+ func (m *DeleteTableCtx) GetDbName() string

+ func (m *DeleteTableCtx) GetTblName() string

+ func (m *DeleteTableCtx) GetUseDeleteKey() string

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

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

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

+ func (m *DeleteTableCtx) ProtoSize() (n int)

+ func (m *DeleteTableCtx) Reset()

+ func (m *DeleteTableCtx) String() string

+ func (m *DeleteTableCtx) Unmarshal(dAtA []byte) error

+ func (m *DeleteTableCtx) XXX_DiscardUnknown()

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

+ func (m *DeleteTableCtx) XXX_Merge(src proto.Message)

+ func (m *DeleteTableCtx) XXX_Size() int

+ func (m *DeleteTableCtx) XXX_Unmarshal(b []byte) error

+ type Execute struct

+ Args []*Expr

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Execute) ProtoMessage()

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

+ func (m *Execute) GetName() string

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

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

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

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

+ func (m *Execute) Reset()

+ func (m *Execute) String() string

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

+ func (m *Execute) XXX_DiscardUnknown()

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

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

+ func (m *Execute) XXX_Size() int

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

type Node

+ DeleteTablesCtx []*DeleteTableCtx

+ func (m *Node) GetDeleteTablesCtx() []*DeleteTableCtx

+ type Prepare struct

+ Name string

+ Plan *Plan

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Prepare) ProtoMessage()

+ func (m *Prepare) GetName() string

+ func (m *Prepare) GetPlan() *Plan

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

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

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

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

+ func (m *Prepare) Reset()

+ func (m *Prepare) String() string

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

+ func (m *Prepare) XXX_DiscardUnknown()

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

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

+ func (m *Prepare) XXX_Size() int

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

v0.5.0

Jul 14, 2022

Changes in this version

+ var CompressType_name = map[int32]string

+ var CompressType_value = map[string]int32

+ var DataControl_DclType_name = map[int32]string

+ var DataControl_DclType_value = map[string]int32

+ var DataDefinition_DdlType_name = map[int32]string

+ var DataDefinition_DdlType_value = map[string]int32

+ var ErrIntOverflowPlan = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPlan = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupPlan = fmt.Errorf("proto: unexpected end of group")

+ var IndexDef_IndexType_name = map[int32]string

+ var IndexDef_IndexType_value = map[string]int32

+ var SubqueryRef_Type_name = map[int32]string

+ var SubqueryRef_Type_value = map[string]int32

+ var TransationBegin_TransationMode_name = map[int32]string

+ var TransationBegin_TransationMode_value = map[string]int32

+ var TransationCompletionType_name = map[int32]string

+ var TransationCompletionType_value = map[string]int32

+ var TransationControl_TclType_name = map[int32]string

+ var TransationControl_TclType_value = map[string]int32

+ type AlterDatabase struct

+ Database string

+ IfExists bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlterDatabase) ProtoMessage()

+ func (m *AlterDatabase) GetDatabase() string

+ func (m *AlterDatabase) GetIfExists() bool

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

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

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

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

+ func (m *AlterDatabase) Reset()

+ func (m *AlterDatabase) String() string

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

+ func (m *AlterDatabase) XXX_DiscardUnknown()

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

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

+ func (m *AlterDatabase) XXX_Size() int

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

+ type AlterIndex struct

+ Index string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlterIndex) ProtoMessage()

+ func (m *AlterIndex) GetIndex() string

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

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

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

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

+ func (m *AlterIndex) Reset()

+ func (m *AlterIndex) String() string

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

+ func (m *AlterIndex) XXX_DiscardUnknown()

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

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

+ func (m *AlterIndex) XXX_Size() int

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

+ type AlterTable struct

+ Table string

+ TableDef *TableDef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AlterTable) ProtoMessage()

+ func (m *AlterTable) GetTable() string

+ func (m *AlterTable) GetTableDef() *TableDef

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

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

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

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

+ func (m *AlterTable) Reset()

+ func (m *AlterTable) String() string

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

+ func (m *AlterTable) XXX_DiscardUnknown()

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

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

+ func (m *AlterTable) XXX_Size() int

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

type ColData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

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

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

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

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

+ func (m *ColData) XXX_DiscardUnknown()

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

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

+ func (m *ColData) XXX_Size() int

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

type ColDef

+ Alg CompressType

+ Default *DefaultExpr

+ Primary bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ColDef) GetAlg() CompressType

+ func (m *ColDef) GetDefault() *DefaultExpr

+ func (m *ColDef) GetPrimary() bool

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

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

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

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

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

+ func (m *ColDef) XXX_DiscardUnknown()

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

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

+ func (m *ColDef) XXX_Size() int

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

type ColRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

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

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

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

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

+ func (m *ColRef) XXX_DiscardUnknown()

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

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

+ func (m *ColRef) XXX_Size() int

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

+ type CompressType int32

+ const CompressType_Lz4

+ const CompressType_None

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

+ func (x CompressType) String() string

type Const

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (m *Const) GetBval() bool

+ func (m *Const) GetDatetimeval() int64

+ func (m *Const) GetDateval() int32

+ func (m *Const) GetDecimal128Val() *Decimal128

+ func (m *Const) GetDecimal64Val() int64

+ func (m *Const) GetFval() float32

+ func (m *Const) GetTimestampval() int64

+ func (m *Const) GetUval() uint64

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

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

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

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

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

+ func (m *Const) XXX_DiscardUnknown()

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

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

+ func (m *Const) XXX_Size() int

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

+ type Const_Bval struct

+ Bval bool

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

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

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

+ type Const_Datetimeval struct

+ Datetimeval int64

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

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

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

+ type Const_Dateval struct

+ Dateval int32

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

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

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

+ type Const_Decimal128Val struct

+ Decimal128Val *Decimal128

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

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

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

+ type Const_Decimal64Val struct

+ Decimal64Val int64

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

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

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

type Const_Dval

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

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

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

+ type Const_Fval struct

+ Fval float32

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

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

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

type Const_Ival

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

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

+ func (m *Const_Ival) ProtoSize() (n int)

type Const_Sval

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

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

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

+ type Const_Timestampval struct

+ Timestampval int64

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

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

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

+ type Const_Uval struct

+ Uval uint64

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

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

+ func (m *Const_Uval) ProtoSize() (n int)

+ type ConstantValue struct

+ ConstantValue isConstantValue_ConstantValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConstantValue) Descriptor() ([]byte, []int)

+ func (*ConstantValue) ProtoMessage()

+ func (*ConstantValue) XXX_OneofWrappers() []interface{}

+ func (m *ConstantValue) GetBoolV() bool

+ func (m *ConstantValue) GetConstantValue() isConstantValue_ConstantValue

+ func (m *ConstantValue) GetDateTimeV() int64

+ func (m *ConstantValue) GetDateV() int32

+ func (m *ConstantValue) GetDecimal128V() *Decimal128

+ func (m *ConstantValue) GetDecimal64V() int64

+ func (m *ConstantValue) GetFloat32V() float32

+ func (m *ConstantValue) GetFloat64V() float64

+ func (m *ConstantValue) GetInt64V() int64

+ func (m *ConstantValue) GetStringV() string

+ func (m *ConstantValue) GetTimeStampV() int64

+ func (m *ConstantValue) GetUint64V() uint64

+ func (m *ConstantValue) GetUnknownV() int32

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

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

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

+ func (m *ConstantValue) ProtoSize() (n int)

+ func (m *ConstantValue) Reset()

+ func (m *ConstantValue) String() string

+ func (m *ConstantValue) Unmarshal(dAtA []byte) error

+ func (m *ConstantValue) XXX_DiscardUnknown()

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

+ func (m *ConstantValue) XXX_Merge(src proto.Message)

+ func (m *ConstantValue) XXX_Size() int

+ func (m *ConstantValue) XXX_Unmarshal(b []byte) error

+ type ConstantValue_BoolV struct

+ BoolV bool

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

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

+ func (m *ConstantValue_BoolV) ProtoSize() (n int)

+ type ConstantValue_DateTimeV struct

+ DateTimeV int64

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

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

+ func (m *ConstantValue_DateTimeV) ProtoSize() (n int)

+ type ConstantValue_DateV struct

+ DateV int32

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

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

+ func (m *ConstantValue_DateV) ProtoSize() (n int)

+ type ConstantValue_Decimal128V struct

+ Decimal128V *Decimal128

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

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

+ func (m *ConstantValue_Decimal128V) ProtoSize() (n int)

+ type ConstantValue_Decimal64V struct

+ Decimal64V int64

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

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

+ func (m *ConstantValue_Decimal64V) ProtoSize() (n int)

+ type ConstantValue_Float32V struct

+ Float32V float32

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

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

+ func (m *ConstantValue_Float32V) ProtoSize() (n int)

+ type ConstantValue_Float64V struct

+ Float64V float64

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

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

+ func (m *ConstantValue_Float64V) ProtoSize() (n int)

+ type ConstantValue_Int64V struct

+ Int64V int64

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

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

+ func (m *ConstantValue_Int64V) ProtoSize() (n int)

+ type ConstantValue_StringV struct

+ StringV string

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

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

+ func (m *ConstantValue_StringV) ProtoSize() (n int)

+ type ConstantValue_TimeStampV struct

+ TimeStampV int64

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

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

+ func (m *ConstantValue_TimeStampV) ProtoSize() (n int)

+ type ConstantValue_Uint64V struct

+ Uint64V uint64

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

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

+ func (m *ConstantValue_Uint64V) ProtoSize() (n int)

+ type ConstantValue_UnknownV struct

+ UnknownV int32

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

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

+ func (m *ConstantValue_UnknownV) ProtoSize() (n int)

type CorrColRef

+ Depth int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *CorrColRef) GetDepth() int32

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

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

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

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

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

+ func (m *CorrColRef) XXX_DiscardUnknown()

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

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

+ func (m *CorrColRef) XXX_Size() int

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

type Cost

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

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

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

+ func (m *Cost) ProtoSize() (n int)

+ func (m *Cost) Unmarshal(dAtA []byte) error

+ func (m *Cost) XXX_DiscardUnknown()

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

+ func (m *Cost) XXX_Merge(src proto.Message)

+ func (m *Cost) XXX_Size() int

+ func (m *Cost) XXX_Unmarshal(b []byte) error

+ type CreateDatabase struct

+ Database string

+ IfNotExists bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateDatabase) ProtoMessage()

+ func (m *CreateDatabase) GetDatabase() string

+ func (m *CreateDatabase) GetIfNotExists() bool

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

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

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

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

+ func (m *CreateDatabase) Reset()

+ func (m *CreateDatabase) String() string

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

+ func (m *CreateDatabase) XXX_DiscardUnknown()

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

+ func (m *CreateDatabase) XXX_Merge(src proto.Message)

+ func (m *CreateDatabase) XXX_Size() int

+ func (m *CreateDatabase) XXX_Unmarshal(b []byte) error

+ type CreateIndex struct

+ IfNotExists bool

+ Index string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateIndex) Descriptor() ([]byte, []int)

+ func (*CreateIndex) ProtoMessage()

+ func (m *CreateIndex) GetIfNotExists() bool

+ func (m *CreateIndex) GetIndex() string

+ func (m *CreateIndex) Marshal() (dAtA []byte, err error)

+ func (m *CreateIndex) MarshalTo(dAtA []byte) (int, error)

+ func (m *CreateIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CreateIndex) ProtoSize() (n int)

+ func (m *CreateIndex) Reset()

+ func (m *CreateIndex) String() string

+ func (m *CreateIndex) Unmarshal(dAtA []byte) error

+ func (m *CreateIndex) XXX_DiscardUnknown()

+ func (m *CreateIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CreateIndex) XXX_Merge(src proto.Message)

+ func (m *CreateIndex) XXX_Size() int

+ func (m *CreateIndex) XXX_Unmarshal(b []byte) error

+ type CreateTable struct

+ Database string

+ IfNotExists bool

+ TableDef *TableDef

+ Temporary bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateTable) Descriptor() ([]byte, []int)

+ func (*CreateTable) ProtoMessage()

+ func (m *CreateTable) GetDatabase() string

+ func (m *CreateTable) GetIfNotExists() bool

+ func (m *CreateTable) GetTableDef() *TableDef

+ func (m *CreateTable) GetTemporary() bool

+ func (m *CreateTable) Marshal() (dAtA []byte, err error)

+ func (m *CreateTable) MarshalTo(dAtA []byte) (int, error)

+ func (m *CreateTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CreateTable) ProtoSize() (n int)

+ func (m *CreateTable) Reset()

+ func (m *CreateTable) String() string

+ func (m *CreateTable) Unmarshal(dAtA []byte) error

+ func (m *CreateTable) XXX_DiscardUnknown()

+ func (m *CreateTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CreateTable) XXX_Merge(src proto.Message)

+ func (m *CreateTable) XXX_Size() int

+ func (m *CreateTable) XXX_Unmarshal(b []byte) error

+ type DataControl struct

+ Control isDataControl_Control

+ DclType DataControl_DclType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DataControl) Descriptor() ([]byte, []int)

+ func (*DataControl) ProtoMessage()

+ func (*DataControl) XXX_OneofWrappers() []interface{}

+ func (m *DataControl) GetControl() isDataControl_Control

+ func (m *DataControl) GetDclType() DataControl_DclType

+ func (m *DataControl) GetSetVariables() *SetVariables

+ func (m *DataControl) Marshal() (dAtA []byte, err error)

+ func (m *DataControl) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataControl) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataControl) ProtoSize() (n int)

+ func (m *DataControl) Reset()

+ func (m *DataControl) String() string

+ func (m *DataControl) Unmarshal(dAtA []byte) error

+ func (m *DataControl) XXX_DiscardUnknown()

+ func (m *DataControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DataControl) XXX_Merge(src proto.Message)

+ func (m *DataControl) XXX_Size() int

+ func (m *DataControl) XXX_Unmarshal(b []byte) error

+ type DataControl_DclType int32

+ const DataControl_DENY

+ const DataControl_GRANT

+ const DataControl_REVOKE

+ const DataControl_SET_VARIABLES

+ func (DataControl_DclType) EnumDescriptor() ([]byte, []int)

+ func (x DataControl_DclType) String() string

+ type DataControl_SetVariables struct

+ SetVariables *SetVariables

+ func (m *DataControl_SetVariables) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataControl_SetVariables) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataControl_SetVariables) ProtoSize() (n int)

+ type DataDefinition struct

+ DdlType DataDefinition_DdlType

+ Definition isDataDefinition_Definition

+ Query *Query

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DataDefinition) Descriptor() ([]byte, []int)

+ func (*DataDefinition) ProtoMessage()

+ func (*DataDefinition) XXX_OneofWrappers() []interface{}

+ func (m *DataDefinition) GetAlterDatabase() *AlterDatabase

+ func (m *DataDefinition) GetAlterIndex() *AlterIndex

+ func (m *DataDefinition) GetAlterTable() *AlterTable

+ func (m *DataDefinition) GetCreateDatabase() *CreateDatabase

+ func (m *DataDefinition) GetCreateIndex() *CreateIndex

+ func (m *DataDefinition) GetCreateTable() *CreateTable

+ func (m *DataDefinition) GetDdlType() DataDefinition_DdlType

+ func (m *DataDefinition) GetDefinition() isDataDefinition_Definition

+ func (m *DataDefinition) GetDropDatabase() *DropDatabase

+ func (m *DataDefinition) GetDropIndex() *DropIndex

+ func (m *DataDefinition) GetDropTable() *DropTable

+ func (m *DataDefinition) GetQuery() *Query

+ func (m *DataDefinition) GetShowVariables() *ShowVariables

+ func (m *DataDefinition) GetTruncateTable() *TruncateTable

+ func (m *DataDefinition) Marshal() (dAtA []byte, err error)

+ func (m *DataDefinition) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition) ProtoSize() (n int)

+ func (m *DataDefinition) Reset()

+ func (m *DataDefinition) String() string

+ func (m *DataDefinition) Unmarshal(dAtA []byte) error

+ func (m *DataDefinition) XXX_DiscardUnknown()

+ func (m *DataDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DataDefinition) XXX_Merge(src proto.Message)

+ func (m *DataDefinition) XXX_Size() int

+ func (m *DataDefinition) XXX_Unmarshal(b []byte) error

+ type DataDefinition_AlterDatabase struct

+ AlterDatabase *AlterDatabase

+ func (m *DataDefinition_AlterDatabase) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_AlterDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_AlterDatabase) ProtoSize() (n int)

+ type DataDefinition_AlterIndex struct

+ AlterIndex *AlterIndex

+ func (m *DataDefinition_AlterIndex) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_AlterIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_AlterIndex) ProtoSize() (n int)

+ type DataDefinition_AlterTable struct

+ AlterTable *AlterTable

+ func (m *DataDefinition_AlterTable) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_AlterTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_AlterTable) ProtoSize() (n int)

+ type DataDefinition_CreateDatabase struct

+ CreateDatabase *CreateDatabase

+ func (m *DataDefinition_CreateDatabase) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_CreateDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_CreateDatabase) ProtoSize() (n int)

+ type DataDefinition_CreateIndex struct

+ CreateIndex *CreateIndex

+ func (m *DataDefinition_CreateIndex) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_CreateIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_CreateIndex) ProtoSize() (n int)

+ type DataDefinition_CreateTable struct

+ CreateTable *CreateTable

+ func (m *DataDefinition_CreateTable) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_CreateTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_CreateTable) ProtoSize() (n int)

+ type DataDefinition_DdlType int32

+ const DataDefinition_ALTER_DATABASE

+ const DataDefinition_ALTER_INDEX

+ const DataDefinition_ALTER_TABLE

+ const DataDefinition_CREATE_DATABASE

+ const DataDefinition_CREATE_INDEX

+ const DataDefinition_CREATE_TABLE

+ const DataDefinition_DROP_DATABASE

+ const DataDefinition_DROP_INDEX

+ const DataDefinition_DROP_TABLE

+ const DataDefinition_SHOW_COLUMNS

+ const DataDefinition_SHOW_CREATEDATABASE

+ const DataDefinition_SHOW_CREATETABLE

+ const DataDefinition_SHOW_DATABASES

+ const DataDefinition_SHOW_ERRORS

+ const DataDefinition_SHOW_INDEX

+ const DataDefinition_SHOW_PROCESSLIST

+ const DataDefinition_SHOW_STATUS

+ const DataDefinition_SHOW_TABLES

+ const DataDefinition_SHOW_VARIABLES

+ const DataDefinition_SHOW_WARNINGS

+ const DataDefinition_TRUNCATE_TABLE

+ func (DataDefinition_DdlType) EnumDescriptor() ([]byte, []int)

+ func (x DataDefinition_DdlType) String() string

+ type DataDefinition_DropDatabase struct

+ DropDatabase *DropDatabase

+ func (m *DataDefinition_DropDatabase) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_DropDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_DropDatabase) ProtoSize() (n int)

+ type DataDefinition_DropIndex struct

+ DropIndex *DropIndex

+ func (m *DataDefinition_DropIndex) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_DropIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_DropIndex) ProtoSize() (n int)

+ type DataDefinition_DropTable struct

+ DropTable *DropTable

+ func (m *DataDefinition_DropTable) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_DropTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_DropTable) ProtoSize() (n int)

+ type DataDefinition_ShowVariables struct

+ ShowVariables *ShowVariables

+ func (m *DataDefinition_ShowVariables) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_ShowVariables) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_ShowVariables) ProtoSize() (n int)

+ type DataDefinition_TruncateTable struct

+ TruncateTable *TruncateTable

+ func (m *DataDefinition_TruncateTable) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataDefinition_TruncateTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataDefinition_TruncateTable) ProtoSize() (n int)

+ type Decimal128 struct

+ Hi int64

+ Lo int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Decimal128) Descriptor() ([]byte, []int)

+ func (*Decimal128) ProtoMessage()

+ func (m *Decimal128) GetHi() int64

+ func (m *Decimal128) GetLo() int64

+ func (m *Decimal128) Marshal() (dAtA []byte, err error)

+ func (m *Decimal128) MarshalTo(dAtA []byte) (int, error)

+ func (m *Decimal128) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Decimal128) ProtoSize() (n int)

+ func (m *Decimal128) Reset()

+ func (m *Decimal128) String() string

+ func (m *Decimal128) Unmarshal(dAtA []byte) error

+ func (m *Decimal128) XXX_DiscardUnknown()

+ func (m *Decimal128) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Decimal128) XXX_Merge(src proto.Message)

+ func (m *Decimal128) XXX_Size() int

+ func (m *Decimal128) XXX_Unmarshal(b []byte) error

+ type DefaultExpr struct

+ Exist bool

+ IsNull bool

+ Value *ConstantValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DefaultExpr) Descriptor() ([]byte, []int)

+ func (*DefaultExpr) ProtoMessage()

+ func (m *DefaultExpr) GetExist() bool

+ func (m *DefaultExpr) GetIsNull() bool

+ func (m *DefaultExpr) GetValue() *ConstantValue

+ func (m *DefaultExpr) Marshal() (dAtA []byte, err error)

+ func (m *DefaultExpr) MarshalTo(dAtA []byte) (int, error)

+ func (m *DefaultExpr) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DefaultExpr) ProtoSize() (n int)

+ func (m *DefaultExpr) Reset()

+ func (m *DefaultExpr) String() string

+ func (m *DefaultExpr) Unmarshal(dAtA []byte) error

+ func (m *DefaultExpr) XXX_DiscardUnknown()

+ func (m *DefaultExpr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DefaultExpr) XXX_Merge(src proto.Message)

+ func (m *DefaultExpr) XXX_Size() int

+ func (m *DefaultExpr) XXX_Unmarshal(b []byte) error

+ type DeleteInfo struct

+ CanTruncate bool

+ UseDeleteKey string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeleteInfo) Descriptor() ([]byte, []int)

+ func (*DeleteInfo) ProtoMessage()

+ func (m *DeleteInfo) GetCanTruncate() bool

+ func (m *DeleteInfo) GetUseDeleteKey() string

+ func (m *DeleteInfo) Marshal() (dAtA []byte, err error)

+ func (m *DeleteInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeleteInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeleteInfo) ProtoSize() (n int)

+ func (m *DeleteInfo) Reset()

+ func (m *DeleteInfo) String() string

+ func (m *DeleteInfo) Unmarshal(dAtA []byte) error

+ func (m *DeleteInfo) XXX_DiscardUnknown()

+ func (m *DeleteInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeleteInfo) XXX_Merge(src proto.Message)

+ func (m *DeleteInfo) XXX_Size() int

+ func (m *DeleteInfo) XXX_Unmarshal(b []byte) error

+ type DropDatabase struct

+ Database string

+ IfExists bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DropDatabase) Descriptor() ([]byte, []int)

+ func (*DropDatabase) ProtoMessage()

+ func (m *DropDatabase) GetDatabase() string

+ func (m *DropDatabase) GetIfExists() bool

+ func (m *DropDatabase) Marshal() (dAtA []byte, err error)

+ func (m *DropDatabase) MarshalTo(dAtA []byte) (int, error)

+ func (m *DropDatabase) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DropDatabase) ProtoSize() (n int)

+ func (m *DropDatabase) Reset()

+ func (m *DropDatabase) String() string

+ func (m *DropDatabase) Unmarshal(dAtA []byte) error

+ func (m *DropDatabase) XXX_DiscardUnknown()

+ func (m *DropDatabase) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DropDatabase) XXX_Merge(src proto.Message)

+ func (m *DropDatabase) XXX_Size() int

+ func (m *DropDatabase) XXX_Unmarshal(b []byte) error

+ type DropIndex struct

+ IfExists bool

+ Index string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DropIndex) Descriptor() ([]byte, []int)

+ func (*DropIndex) ProtoMessage()

+ func (m *DropIndex) GetIfExists() bool

+ func (m *DropIndex) GetIndex() string

+ func (m *DropIndex) Marshal() (dAtA []byte, err error)

+ func (m *DropIndex) MarshalTo(dAtA []byte) (int, error)

+ func (m *DropIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DropIndex) ProtoSize() (n int)

+ func (m *DropIndex) Reset()

+ func (m *DropIndex) String() string

+ func (m *DropIndex) Unmarshal(dAtA []byte) error

+ func (m *DropIndex) XXX_DiscardUnknown()

+ func (m *DropIndex) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DropIndex) XXX_Merge(src proto.Message)

+ func (m *DropIndex) XXX_Size() int

+ func (m *DropIndex) XXX_Unmarshal(b []byte) error

+ type DropTable struct

+ Database string

+ IfExists bool

+ Table string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DropTable) Descriptor() ([]byte, []int)

+ func (*DropTable) ProtoMessage()

+ func (m *DropTable) GetDatabase() string

+ func (m *DropTable) GetIfExists() bool

+ func (m *DropTable) GetTable() string

+ func (m *DropTable) Marshal() (dAtA []byte, err error)

+ func (m *DropTable) MarshalTo(dAtA []byte) (int, error)

+ func (m *DropTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DropTable) ProtoSize() (n int)

+ func (m *DropTable) Reset()

+ func (m *DropTable) String() string

+ func (m *DropTable) Unmarshal(dAtA []byte) error

+ func (m *DropTable) XXX_DiscardUnknown()

+ func (m *DropTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DropTable) XXX_Merge(src proto.Message)

+ func (m *DropTable) XXX_Size() int

+ func (m *DropTable) XXX_Unmarshal(b []byte) error

type Expr

+ ColName string

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Expr) XXX_OneofWrappers() []interface{}

+ func (m *Expr) GetColName() string

+ func (m *Expr) GetT() *TargetType

+ func (m *Expr) GetTableName() string

+ func (m *Expr) Marshal() (dAtA []byte, err error)

+ func (m *Expr) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr) ProtoSize() (n int)

+ func (m *Expr) Unmarshal(dAtA []byte) error

+ func (m *Expr) XXX_DiscardUnknown()

+ func (m *Expr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Expr) XXX_Merge(src proto.Message)

+ func (m *Expr) XXX_Size() int

+ func (m *Expr) XXX_Unmarshal(b []byte) error

type ExprList

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ExprList) Marshal() (dAtA []byte, err error)

+ func (m *ExprList) MarshalTo(dAtA []byte) (int, error)

+ func (m *ExprList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ExprList) ProtoSize() (n int)

+ func (m *ExprList) Unmarshal(dAtA []byte) error

+ func (m *ExprList) XXX_DiscardUnknown()

+ func (m *ExprList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExprList) XXX_Merge(src proto.Message)

+ func (m *ExprList) XXX_Size() int

+ func (m *ExprList) XXX_Unmarshal(b []byte) error

type Expr_C

+ func (m *Expr_C) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_C) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_C) ProtoSize() (n int)

type Expr_Col

+ func (m *Expr_Col) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_Col) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_Col) ProtoSize() (n int)

type Expr_Corr

+ func (m *Expr_Corr) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_Corr) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_Corr) ProtoSize() (n int)

type Expr_F

+ func (m *Expr_F) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_F) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_F) ProtoSize() (n int)

type Expr_List

+ func (m *Expr_List) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_List) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_List) ProtoSize() (n int)

type Expr_P

+ func (m *Expr_P) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_P) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_P) ProtoSize() (n int)

type Expr_Sub

+ func (m *Expr_Sub) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_Sub) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_Sub) ProtoSize() (n int)

+ type Expr_T struct

+ T *TargetType

+ func (m *Expr_T) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_T) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_T) ProtoSize() (n int)

type Expr_V

+ func (m *Expr_V) MarshalTo(dAtA []byte) (int, error)

+ func (m *Expr_V) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Expr_V) ProtoSize() (n int)

type Function

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Function) Marshal() (dAtA []byte, err error)

+ func (m *Function) MarshalTo(dAtA []byte) (int, error)

+ func (m *Function) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Function) ProtoSize() (n int)

+ func (m *Function) Unmarshal(dAtA []byte) error

+ func (m *Function) XXX_DiscardUnknown()

+ func (m *Function) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Function) XXX_Merge(src proto.Message)

+ func (m *Function) XXX_Size() int

+ func (m *Function) XXX_Unmarshal(b []byte) error

+ type IndexDef struct

+ ColNames []string

+ Name string

+ Typ IndexDef_IndexType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IndexDef) Descriptor() ([]byte, []int)

+ func (*IndexDef) ProtoMessage()

+ func (m *IndexDef) GetColNames() []string

+ func (m *IndexDef) GetName() string

+ func (m *IndexDef) GetTyp() IndexDef_IndexType

+ func (m *IndexDef) Marshal() (dAtA []byte, err error)

+ func (m *IndexDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *IndexDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *IndexDef) ProtoSize() (n int)

+ func (m *IndexDef) Reset()

+ func (m *IndexDef) String() string

+ func (m *IndexDef) Unmarshal(dAtA []byte) error

+ func (m *IndexDef) XXX_DiscardUnknown()

+ func (m *IndexDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IndexDef) XXX_Merge(src proto.Message)

+ func (m *IndexDef) XXX_Size() int

+ func (m *IndexDef) XXX_Unmarshal(b []byte) error

+ type IndexDef_IndexType int32

+ const IndexDef_BSI

+ const IndexDef_INVAILD

+ const IndexDef_ZONEMAP

+ func (IndexDef_IndexType) EnumDescriptor() ([]byte, []int)

+ func (x IndexDef_IndexType) String() string

type Node

+ AggList []*Expr

+ BindingTags []int32

+ DeleteInfo *DeleteInfo

+ FilterList []*Expr

+ UpdateInfo *UpdateInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Node) GetAggList() []*Expr

+ func (m *Node) GetBindingTags() []int32

+ func (m *Node) GetDeleteInfo() *DeleteInfo

+ func (m *Node) GetFilterList() []*Expr

+ func (m *Node) GetUpdateInfo() *UpdateInfo

+ func (m *Node) Marshal() (dAtA []byte, err error)

+ func (m *Node) MarshalTo(dAtA []byte) (int, error)

+ func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Node) ProtoSize() (n int)

+ func (m *Node) Unmarshal(dAtA []byte) error

+ func (m *Node) XXX_DiscardUnknown()

+ func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Node) XXX_Merge(src proto.Message)

+ func (m *Node) XXX_Size() int

+ func (m *Node) XXX_Unmarshal(b []byte) error

type Node_JoinFlag

+ const Node_LEFT

+ const Node_RIGHT

type Node_NodeType

+ const Node_DELETE

+ const Node_DISTINCT

+ const Node_FILTER

+ const Node_MATERIAL_SCAN

type ObjectRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ObjectRef) Marshal() (dAtA []byte, err error)

+ func (m *ObjectRef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ObjectRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ObjectRef) ProtoSize() (n int)

+ func (m *ObjectRef) Unmarshal(dAtA []byte) error

+ func (m *ObjectRef) XXX_DiscardUnknown()

+ func (m *ObjectRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ObjectRef) XXX_Merge(src proto.Message)

+ func (m *ObjectRef) XXX_Size() int

+ func (m *ObjectRef) XXX_Unmarshal(b []byte) error

type OrderBySpec

+ Collation string

+ Expr *Expr

+ Flag OrderBySpec_OrderByFlag

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *OrderBySpec) GetCollation() string

+ func (m *OrderBySpec) GetExpr() *Expr

+ func (m *OrderBySpec) GetFlag() OrderBySpec_OrderByFlag

+ func (m *OrderBySpec) Marshal() (dAtA []byte, err error)

+ func (m *OrderBySpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *OrderBySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OrderBySpec) ProtoSize() (n int)

+ func (m *OrderBySpec) Unmarshal(dAtA []byte) error

+ func (m *OrderBySpec) XXX_DiscardUnknown()

+ func (m *OrderBySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OrderBySpec) XXX_Merge(src proto.Message)

+ func (m *OrderBySpec) XXX_Size() int

+ func (m *OrderBySpec) XXX_Unmarshal(b []byte) error

type ParamRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *ParamRef) Marshal() (dAtA []byte, err error)

+ func (m *ParamRef) MarshalTo(dAtA []byte) (int, error)

+ func (m *ParamRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ParamRef) ProtoSize() (n int)

+ func (m *ParamRef) Unmarshal(dAtA []byte) error

+ func (m *ParamRef) XXX_DiscardUnknown()

+ func (m *ParamRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ParamRef) XXX_Merge(src proto.Message)

+ func (m *ParamRef) XXX_Size() int

+ func (m *ParamRef) XXX_Unmarshal(b []byte) error

+ type Plan struct

+ Plan isPlan_Plan

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Plan) Descriptor() ([]byte, []int)

+ func (*Plan) ProtoMessage()

+ func (*Plan) XXX_OneofWrappers() []interface{}

+ func (m *Plan) GetDcl() *DataControl

+ func (m *Plan) GetDdl() *DataDefinition

+ func (m *Plan) GetPlan() isPlan_Plan

+ func (m *Plan) GetQuery() *Query

+ func (m *Plan) GetTcl() *TransationControl

+ func (m *Plan) Marshal() (dAtA []byte, err error)

+ func (m *Plan) MarshalTo(dAtA []byte) (int, error)

+ func (m *Plan) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Plan) ProtoSize() (n int)

+ func (m *Plan) Reset()

+ func (m *Plan) String() string

+ func (m *Plan) Unmarshal(dAtA []byte) error

+ func (m *Plan) XXX_DiscardUnknown()

+ func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Plan) XXX_Merge(src proto.Message)

+ func (m *Plan) XXX_Size() int

+ func (m *Plan) XXX_Unmarshal(b []byte) error

+ type Plan_Dcl struct

+ Dcl *DataControl

+ func (m *Plan_Dcl) MarshalTo(dAtA []byte) (int, error)

+ func (m *Plan_Dcl) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Plan_Dcl) ProtoSize() (n int)

+ type Plan_Ddl struct

+ Ddl *DataDefinition

+ func (m *Plan_Ddl) MarshalTo(dAtA []byte) (int, error)

+ func (m *Plan_Ddl) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Plan_Ddl) ProtoSize() (n int)

+ type Plan_Query struct

+ Query *Query

+ func (m *Plan_Query) MarshalTo(dAtA []byte) (int, error)

+ func (m *Plan_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Plan_Query) ProtoSize() (n int)

+ type Plan_Tcl struct

+ Tcl *TransationControl

+ func (m *Plan_Tcl) MarshalTo(dAtA []byte) (int, error)

+ func (m *Plan_Tcl) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Plan_Tcl) ProtoSize() (n int)

+ type PrimaryKeyDef struct

+ Names []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PrimaryKeyDef) Descriptor() ([]byte, []int)

+ func (*PrimaryKeyDef) ProtoMessage()

+ func (m *PrimaryKeyDef) GetNames() []string

+ func (m *PrimaryKeyDef) Marshal() (dAtA []byte, err error)

+ func (m *PrimaryKeyDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *PrimaryKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PrimaryKeyDef) ProtoSize() (n int)

+ func (m *PrimaryKeyDef) Reset()

+ func (m *PrimaryKeyDef) String() string

+ func (m *PrimaryKeyDef) Unmarshal(dAtA []byte) error

+ func (m *PrimaryKeyDef) XXX_DiscardUnknown()

+ func (m *PrimaryKeyDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrimaryKeyDef) XXX_Merge(src proto.Message)

+ func (m *PrimaryKeyDef) XXX_Size() int

+ func (m *PrimaryKeyDef) XXX_Unmarshal(b []byte) error

+ type PropertiesDef struct

+ Properties []*Property

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PropertiesDef) Descriptor() ([]byte, []int)

+ func (*PropertiesDef) ProtoMessage()

+ func (m *PropertiesDef) GetProperties() []*Property

+ func (m *PropertiesDef) Marshal() (dAtA []byte, err error)

+ func (m *PropertiesDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *PropertiesDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PropertiesDef) ProtoSize() (n int)

+ func (m *PropertiesDef) Reset()

+ func (m *PropertiesDef) String() string

+ func (m *PropertiesDef) Unmarshal(dAtA []byte) error

+ func (m *PropertiesDef) XXX_DiscardUnknown()

+ func (m *PropertiesDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PropertiesDef) XXX_Merge(src proto.Message)

+ func (m *PropertiesDef) XXX_Size() int

+ func (m *PropertiesDef) XXX_Unmarshal(b []byte) error

+ type Property struct

+ Key string

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Property) Descriptor() ([]byte, []int)

+ func (*Property) ProtoMessage()

+ func (m *Property) GetKey() string

+ func (m *Property) GetValue() string

+ func (m *Property) Marshal() (dAtA []byte, err error)

+ func (m *Property) MarshalTo(dAtA []byte) (int, error)

+ func (m *Property) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Property) ProtoSize() (n int)

+ func (m *Property) Reset()

+ func (m *Property) String() string

+ func (m *Property) Unmarshal(dAtA []byte) error

+ func (m *Property) XXX_DiscardUnknown()

+ func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Property) XXX_Merge(src proto.Message)

+ func (m *Property) XXX_Size() int

+ func (m *Property) XXX_Unmarshal(b []byte) error

type Query

+ Headings []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Query) GetHeadings() []string

+ func (m *Query) Marshal() (dAtA []byte, err error)

+ func (m *Query) MarshalTo(dAtA []byte) (int, error)

+ func (m *Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Query) ProtoSize() (n int)

+ func (m *Query) Unmarshal(dAtA []byte) error

+ func (m *Query) XXX_DiscardUnknown()

+ func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Query) XXX_Merge(src proto.Message)

+ func (m *Query) XXX_Size() int

+ func (m *Query) XXX_Unmarshal(b []byte) error

type RowsetData

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *RowsetData) Marshal() (dAtA []byte, err error)

+ func (m *RowsetData) MarshalTo(dAtA []byte) (int, error)

+ func (m *RowsetData) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RowsetData) ProtoSize() (n int)

+ func (m *RowsetData) Unmarshal(dAtA []byte) error

+ func (m *RowsetData) XXX_DiscardUnknown()

+ func (m *RowsetData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RowsetData) XXX_Merge(src proto.Message)

+ func (m *RowsetData) XXX_Size() int

+ func (m *RowsetData) XXX_Unmarshal(b []byte) error

+ type SetVariables struct

+ Items []*SetVariablesItem

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetVariables) Descriptor() ([]byte, []int)

+ func (*SetVariables) ProtoMessage()

+ func (m *SetVariables) GetItems() []*SetVariablesItem

+ func (m *SetVariables) Marshal() (dAtA []byte, err error)

+ func (m *SetVariables) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetVariables) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetVariables) ProtoSize() (n int)

+ func (m *SetVariables) Reset()

+ func (m *SetVariables) String() string

+ func (m *SetVariables) Unmarshal(dAtA []byte) error

+ func (m *SetVariables) XXX_DiscardUnknown()

+ func (m *SetVariables) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetVariables) XXX_Merge(src proto.Message)

+ func (m *SetVariables) XXX_Size() int

+ func (m *SetVariables) XXX_Unmarshal(b []byte) error

+ type SetVariablesItem struct

+ Global bool

+ Name string

+ Reserved *Expr

+ System bool

+ Value *Expr

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetVariablesItem) Descriptor() ([]byte, []int)

+ func (*SetVariablesItem) ProtoMessage()

+ func (m *SetVariablesItem) GetGlobal() bool

+ func (m *SetVariablesItem) GetName() string

+ func (m *SetVariablesItem) GetReserved() *Expr

+ func (m *SetVariablesItem) GetSystem() bool

+ func (m *SetVariablesItem) GetValue() *Expr

+ func (m *SetVariablesItem) Marshal() (dAtA []byte, err error)

+ func (m *SetVariablesItem) MarshalTo(dAtA []byte) (int, error)

+ func (m *SetVariablesItem) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SetVariablesItem) ProtoSize() (n int)

+ func (m *SetVariablesItem) Reset()

+ func (m *SetVariablesItem) String() string

+ func (m *SetVariablesItem) Unmarshal(dAtA []byte) error

+ func (m *SetVariablesItem) XXX_DiscardUnknown()

+ func (m *SetVariablesItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetVariablesItem) XXX_Merge(src proto.Message)

+ func (m *SetVariablesItem) XXX_Size() int

+ func (m *SetVariablesItem) XXX_Unmarshal(b []byte) error

+ type ShowVariables struct

+ Global bool

+ Where []*Expr

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ShowVariables) Descriptor() ([]byte, []int)

+ func (*ShowVariables) ProtoMessage()

+ func (m *ShowVariables) GetGlobal() bool

+ func (m *ShowVariables) GetWhere() []*Expr

+ func (m *ShowVariables) Marshal() (dAtA []byte, err error)

+ func (m *ShowVariables) MarshalTo(dAtA []byte) (int, error)

+ func (m *ShowVariables) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ShowVariables) ProtoSize() (n int)

+ func (m *ShowVariables) Reset()

+ func (m *ShowVariables) String() string

+ func (m *ShowVariables) Unmarshal(dAtA []byte) error

+ func (m *ShowVariables) XXX_DiscardUnknown()

+ func (m *ShowVariables) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ShowVariables) XXX_Merge(src proto.Message)

+ func (m *ShowVariables) XXX_Size() int

+ func (m *ShowVariables) XXX_Unmarshal(b []byte) error

+ type SubqueryRef struct

+ Child *Expr

+ NodeId int32

+ Op string

+ Typ SubqueryRef_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubqueryRef) Descriptor() ([]byte, []int)

+ func (*SubqueryRef) ProtoMessage()

+ func (m *SubqueryRef) GetChild() *Expr

+ func (m *SubqueryRef) GetNodeId() int32

+ func (m *SubqueryRef) GetOp() string

+ func (m *SubqueryRef) GetTyp() SubqueryRef_Type

+ func (m *SubqueryRef) Marshal() (dAtA []byte, err error)

+ func (m *SubqueryRef) MarshalTo(dAtA []byte) (int, error)

+ func (m *SubqueryRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubqueryRef) ProtoSize() (n int)

+ func (m *SubqueryRef) Reset()

+ func (m *SubqueryRef) String() string

+ func (m *SubqueryRef) Unmarshal(dAtA []byte) error

+ func (m *SubqueryRef) XXX_DiscardUnknown()

+ func (m *SubqueryRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubqueryRef) XXX_Merge(src proto.Message)

+ func (m *SubqueryRef) XXX_Size() int

+ func (m *SubqueryRef) XXX_Unmarshal(b []byte) error

+ type SubqueryRef_Type int32

+ const SubqueryRef_ALL

+ const SubqueryRef_ANY

+ const SubqueryRef_EXISTS

+ const SubqueryRef_IN

+ const SubqueryRef_NOT_EXISTS

+ const SubqueryRef_NOT_IN

+ const SubqueryRef_SCALAR

+ func (SubqueryRef_Type) EnumDescriptor() ([]byte, []int)

+ func (x SubqueryRef_Type) String() string

type TableDef

+ Defs []*TableDef_DefType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *TableDef) GetDefs() []*TableDef_DefType

+ func (m *TableDef) Marshal() (dAtA []byte, err error)

+ func (m *TableDef) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDef) ProtoSize() (n int)

+ func (m *TableDef) Unmarshal(dAtA []byte) error

+ func (m *TableDef) XXX_DiscardUnknown()

+ func (m *TableDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TableDef) XXX_Merge(src proto.Message)

+ func (m *TableDef) XXX_Size() int

+ func (m *TableDef) XXX_Unmarshal(b []byte) error

+ type TableDef_DefType struct

+ Def isTableDef_DefType_Def

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TableDef_DefType) Descriptor() ([]byte, []int)

+ func (*TableDef_DefType) ProtoMessage()

+ func (*TableDef_DefType) XXX_OneofWrappers() []interface{}

+ func (m *TableDef_DefType) GetDef() isTableDef_DefType_Def

+ func (m *TableDef_DefType) GetIdx() *IndexDef

+ func (m *TableDef_DefType) GetPk() *PrimaryKeyDef

+ func (m *TableDef_DefType) GetProperties() *PropertiesDef

+ func (m *TableDef_DefType) Marshal() (dAtA []byte, err error)

+ func (m *TableDef_DefType) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDef_DefType) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDef_DefType) ProtoSize() (n int)

+ func (m *TableDef_DefType) Reset()

+ func (m *TableDef_DefType) String() string

+ func (m *TableDef_DefType) Unmarshal(dAtA []byte) error

+ func (m *TableDef_DefType) XXX_DiscardUnknown()

+ func (m *TableDef_DefType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TableDef_DefType) XXX_Merge(src proto.Message)

+ func (m *TableDef_DefType) XXX_Size() int

+ func (m *TableDef_DefType) XXX_Unmarshal(b []byte) error

+ type TableDef_DefType_Idx struct

+ Idx *IndexDef

+ func (m *TableDef_DefType_Idx) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDef_DefType_Idx) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDef_DefType_Idx) ProtoSize() (n int)

+ type TableDef_DefType_Pk struct

+ Pk *PrimaryKeyDef

+ func (m *TableDef_DefType_Pk) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDef_DefType_Pk) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDef_DefType_Pk) ProtoSize() (n int)

+ type TableDef_DefType_Properties struct

+ Properties *PropertiesDef

+ func (m *TableDef_DefType_Properties) MarshalTo(dAtA []byte) (int, error)

+ func (m *TableDef_DefType_Properties) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TableDef_DefType_Properties) ProtoSize() (n int)

+ type TargetType struct

+ Typ *Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TargetType) Descriptor() ([]byte, []int)

+ func (*TargetType) ProtoMessage()

+ func (m *TargetType) GetTyp() *Type

+ func (m *TargetType) Marshal() (dAtA []byte, err error)

+ func (m *TargetType) MarshalTo(dAtA []byte) (int, error)

+ func (m *TargetType) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TargetType) ProtoSize() (n int)

+ func (m *TargetType) Reset()

+ func (m *TargetType) String() string

+ func (m *TargetType) Unmarshal(dAtA []byte) error

+ func (m *TargetType) XXX_DiscardUnknown()

+ func (m *TargetType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TargetType) XXX_Merge(src proto.Message)

+ func (m *TargetType) XXX_Size() int

+ func (m *TargetType) XXX_Unmarshal(b []byte) error

+ type TransationBegin struct

+ Mode TransationBegin_TransationMode

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransationBegin) Descriptor() ([]byte, []int)

+ func (*TransationBegin) ProtoMessage()

+ func (m *TransationBegin) GetMode() TransationBegin_TransationMode

+ func (m *TransationBegin) Marshal() (dAtA []byte, err error)

+ func (m *TransationBegin) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransationBegin) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransationBegin) ProtoSize() (n int)

+ func (m *TransationBegin) Reset()

+ func (m *TransationBegin) String() string

+ func (m *TransationBegin) Unmarshal(dAtA []byte) error

+ func (m *TransationBegin) XXX_DiscardUnknown()

+ func (m *TransationBegin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TransationBegin) XXX_Merge(src proto.Message)

+ func (m *TransationBegin) XXX_Size() int

+ func (m *TransationBegin) XXX_Unmarshal(b []byte) error

+ type TransationBegin_TransationMode int32

+ const TransationBegin_NONE

+ const TransationBegin_READ_ONLY

+ const TransationBegin_READ_WRITE

+ func (TransationBegin_TransationMode) EnumDescriptor() ([]byte, []int)

+ func (x TransationBegin_TransationMode) String() string

+ type TransationCommit struct

+ CompletionType TransationCompletionType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransationCommit) Descriptor() ([]byte, []int)

+ func (*TransationCommit) ProtoMessage()

+ func (m *TransationCommit) GetCompletionType() TransationCompletionType

+ func (m *TransationCommit) Marshal() (dAtA []byte, err error)

+ func (m *TransationCommit) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransationCommit) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransationCommit) ProtoSize() (n int)

+ func (m *TransationCommit) Reset()

+ func (m *TransationCommit) String() string

+ func (m *TransationCommit) Unmarshal(dAtA []byte) error

+ func (m *TransationCommit) XXX_DiscardUnknown()

+ func (m *TransationCommit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TransationCommit) XXX_Merge(src proto.Message)

+ func (m *TransationCommit) XXX_Size() int

+ func (m *TransationCommit) XXX_Unmarshal(b []byte) error

+ type TransationCompletionType int32

+ const TransationCompletionType_CHAIN

+ const TransationCompletionType_NO_CHAIN

+ const TransationCompletionType_RELEASE

+ func (TransationCompletionType) EnumDescriptor() ([]byte, []int)

+ func (x TransationCompletionType) String() string

+ type TransationControl struct

+ Action isTransationControl_Action

+ TclType TransationControl_TclType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransationControl) Descriptor() ([]byte, []int)

+ func (*TransationControl) ProtoMessage()

+ func (*TransationControl) XXX_OneofWrappers() []interface{}

+ func (m *TransationControl) GetAction() isTransationControl_Action

+ func (m *TransationControl) GetBegin() *TransationBegin

+ func (m *TransationControl) GetCommit() *TransationCommit

+ func (m *TransationControl) GetRollback() *TransationRollback

+ func (m *TransationControl) GetTclType() TransationControl_TclType

+ func (m *TransationControl) Marshal() (dAtA []byte, err error)

+ func (m *TransationControl) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransationControl) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransationControl) ProtoSize() (n int)

+ func (m *TransationControl) Reset()

+ func (m *TransationControl) String() string

+ func (m *TransationControl) Unmarshal(dAtA []byte) error

+ func (m *TransationControl) XXX_DiscardUnknown()

+ func (m *TransationControl) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TransationControl) XXX_Merge(src proto.Message)

+ func (m *TransationControl) XXX_Size() int

+ func (m *TransationControl) XXX_Unmarshal(b []byte) error

+ type TransationControl_Begin struct

+ Begin *TransationBegin

+ func (m *TransationControl_Begin) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransationControl_Begin) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransationControl_Begin) ProtoSize() (n int)

+ type TransationControl_Commit struct

+ Commit *TransationCommit

+ func (m *TransationControl_Commit) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransationControl_Commit) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransationControl_Commit) ProtoSize() (n int)

+ type TransationControl_Rollback struct

+ Rollback *TransationRollback

+ func (m *TransationControl_Rollback) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransationControl_Rollback) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransationControl_Rollback) ProtoSize() (n int)

+ type TransationControl_TclType int32

+ const TransationControl_BEGIN

+ const TransationControl_COMMIT

+ const TransationControl_ROLLBACK

+ func (TransationControl_TclType) EnumDescriptor() ([]byte, []int)

+ func (x TransationControl_TclType) String() string

+ type TransationRollback struct

+ CompletionType TransationCompletionType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransationRollback) Descriptor() ([]byte, []int)

+ func (*TransationRollback) ProtoMessage()

+ func (m *TransationRollback) GetCompletionType() TransationCompletionType

+ func (m *TransationRollback) Marshal() (dAtA []byte, err error)

+ func (m *TransationRollback) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransationRollback) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransationRollback) ProtoSize() (n int)

+ func (m *TransationRollback) Reset()

+ func (m *TransationRollback) String() string

+ func (m *TransationRollback) Unmarshal(dAtA []byte) error

+ func (m *TransationRollback) XXX_DiscardUnknown()

+ func (m *TransationRollback) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TransationRollback) XXX_Merge(src proto.Message)

+ func (m *TransationRollback) XXX_Size() int

+ func (m *TransationRollback) XXX_Unmarshal(b []byte) error

+ type TruncateTable struct

+ Table string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TruncateTable) Descriptor() ([]byte, []int)

+ func (*TruncateTable) ProtoMessage()

+ func (m *TruncateTable) GetTable() string

+ func (m *TruncateTable) Marshal() (dAtA []byte, err error)

+ func (m *TruncateTable) MarshalTo(dAtA []byte) (int, error)

+ func (m *TruncateTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TruncateTable) ProtoSize() (n int)

+ func (m *TruncateTable) Reset()

+ func (m *TruncateTable) String() string

+ func (m *TruncateTable) Unmarshal(dAtA []byte) error

+ func (m *TruncateTable) XXX_DiscardUnknown()

+ func (m *TruncateTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TruncateTable) XXX_Merge(src proto.Message)

+ func (m *TruncateTable) XXX_Size() int

+ func (m *TruncateTable) XXX_Unmarshal(b []byte) error

type Type

+ Scale int32

+ Size int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Type) GetScale() int32

+ func (m *Type) GetSize() int32

+ func (m *Type) Marshal() (dAtA []byte, err error)

+ func (m *Type) MarshalTo(dAtA []byte) (int, error)

+ func (m *Type) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Type) ProtoSize() (n int)

+ func (m *Type) Unmarshal(dAtA []byte) error

+ func (m *Type) XXX_DiscardUnknown()

+ func (m *Type) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Type) XXX_Merge(src proto.Message)

+ func (m *Type) XXX_Size() int

+ func (m *Type) XXX_Unmarshal(b []byte) error

+ type UpdateInfo struct

+ AttrOrders []string

+ HideKey string

+ OtherAttrs []string

+ PriKey string

+ PriKeyIdx int32

+ UpdateAttrs []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpdateInfo) Descriptor() ([]byte, []int)

+ func (*UpdateInfo) ProtoMessage()

+ func (m *UpdateInfo) GetAttrOrders() []string

+ func (m *UpdateInfo) GetHideKey() string

+ func (m *UpdateInfo) GetOtherAttrs() []string

+ func (m *UpdateInfo) GetPriKey() string

+ func (m *UpdateInfo) GetPriKeyIdx() int32

+ func (m *UpdateInfo) GetUpdateAttrs() []string

+ func (m *UpdateInfo) Marshal() (dAtA []byte, err error)

+ func (m *UpdateInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpdateInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpdateInfo) ProtoSize() (n int)

+ func (m *UpdateInfo) Reset()

+ func (m *UpdateInfo) String() string

+ func (m *UpdateInfo) Unmarshal(dAtA []byte) error

+ func (m *UpdateInfo) XXX_DiscardUnknown()

+ func (m *UpdateInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpdateInfo) XXX_Merge(src proto.Message)

+ func (m *UpdateInfo) XXX_Size() int

+ func (m *UpdateInfo) XXX_Unmarshal(b []byte) error

type VarRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *VarRef) Marshal() (dAtA []byte, err error)

+ func (m *VarRef) MarshalTo(dAtA []byte) (int, error)

+ func (m *VarRef) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VarRef) ProtoSize() (n int)

+ func (m *VarRef) Unmarshal(dAtA []byte) error

+ func (m *VarRef) XXX_DiscardUnknown()

+ func (m *VarRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VarRef) XXX_Merge(src proto.Message)

+ func (m *VarRef) XXX_Size() int

+ func (m *VarRef) XXX_Unmarshal(b []byte) error

type WindowSpec

+ OrderBy []*OrderBySpec

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *WindowSpec) GetOrderBy() []*OrderBySpec

+ func (m *WindowSpec) Marshal() (dAtA []byte, err error)

+ func (m *WindowSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *WindowSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WindowSpec) ProtoSize() (n int)

+ func (m *WindowSpec) Unmarshal(dAtA []byte) error

+ func (m *WindowSpec) XXX_DiscardUnknown()

+ func (m *WindowSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WindowSpec) XXX_Merge(src proto.Message)

+ func (m *WindowSpec) XXX_Size() int

+ func (m *WindowSpec) XXX_Unmarshal(b []byte) error

v0.4.0

May 5, 2022

Changes in this version

+ var File_plan_proto protoreflect.FileDescriptor

+ var Function_FuncFlag_name = map[int32]string

+ var Function_FuncFlag_value = map[string]int32

+ var Node_AggMode_name = map[int32]string

+ var Node_AggMode_value = map[string]int32

+ var Node_JoinFlag_name = map[int32]string

+ var Node_JoinFlag_value = map[string]int32

+ var Node_NodeType_name = map[int32]string

+ var Node_NodeType_value = map[string]int32

+ var OrderBySpec_OrderByFlag_name = map[int32]string

+ var OrderBySpec_OrderByFlag_value = map[string]int32

+ var Query_StatementType_name = map[int32]string

+ var Query_StatementType_value = map[string]int32

+ var StatementType_name = map[int32]string

+ var StatementType_value = map[string]int32

+ var Type_TypeId_name = map[int32]string

+ var Type_TypeId_value = map[string]int32

+ type ColData struct

+ F32 []float32

+ F64 []float64

+ I32 []int32

+ I64 []int64

+ NullCount int32

+ Nulls []bool

+ RowCount int32

+ S []string

+ func (*ColData) Descriptor() ([]byte, []int)

+ func (*ColData) ProtoMessage()

+ func (x *ColData) GetF32() []float32

+ func (x *ColData) GetF64() []float64

+ func (x *ColData) GetI32() []int32

+ func (x *ColData) GetI64() []int64

+ func (x *ColData) GetNullCount() int32

+ func (x *ColData) GetNulls() []bool

+ func (x *ColData) GetRowCount() int32

+ func (x *ColData) GetS() []string

+ func (x *ColData) ProtoReflect() protoreflect.Message

+ func (x *ColData) Reset()

+ func (x *ColData) String() string

+ type ColDef struct

+ Name string

+ Pkidx int32

+ Typ *Type

+ func (*ColDef) Descriptor() ([]byte, []int)

+ func (*ColDef) ProtoMessage()

+ func (x *ColDef) GetName() string

+ func (x *ColDef) GetPkidx() int32

+ func (x *ColDef) GetTyp() *Type

+ func (x *ColDef) ProtoReflect() protoreflect.Message

+ func (x *ColDef) Reset()

+ func (x *ColDef) String() string

+ type ColRef struct

+ ColPos int32

+ Name string

+ RelPos int32

+ func (*ColRef) Descriptor() ([]byte, []int)

+ func (*ColRef) ProtoMessage()

+ func (x *ColRef) GetColPos() int32

+ func (x *ColRef) GetName() string

+ func (x *ColRef) GetRelPos() int32

+ func (x *ColRef) ProtoReflect() protoreflect.Message

+ func (x *ColRef) Reset()

+ func (x *ColRef) String() string

+ type Const struct

+ Isnull bool

+ Value isConst_Value

+ func (*Const) Descriptor() ([]byte, []int)

+ func (*Const) ProtoMessage()

+ func (m *Const) GetValue() isConst_Value

+ func (x *Const) GetDval() float64

+ func (x *Const) GetIsnull() bool

+ func (x *Const) GetIval() int64

+ func (x *Const) GetSval() string

+ func (x *Const) ProtoReflect() protoreflect.Message

+ func (x *Const) Reset()

+ func (x *Const) String() string

+ type Const_Dval struct

+ Dval float64

+ type Const_Ival struct

+ Ival int64

+ type Const_Sval struct

+ Sval string

+ type CorrColRef struct

+ ColPos int32

+ Name string

+ NodeId int32

+ RelPos int32

+ func (*CorrColRef) Descriptor() ([]byte, []int)

+ func (*CorrColRef) ProtoMessage()

+ func (x *CorrColRef) GetColPos() int32

+ func (x *CorrColRef) GetName() string

+ func (x *CorrColRef) GetNodeId() int32

+ func (x *CorrColRef) GetRelPos() int32

+ func (x *CorrColRef) ProtoReflect() protoreflect.Message

+ func (x *CorrColRef) Reset()

+ func (x *CorrColRef) String() string

+ type Cost struct

+ Card float64

+ Ndv float64

+ Rowsize float64

+ Start float64

+ Total float64

+ func (*Cost) Descriptor() ([]byte, []int)

+ func (*Cost) ProtoMessage()

+ func (x *Cost) GetCard() float64

+ func (x *Cost) GetNdv() float64

+ func (x *Cost) GetRowsize() float64

+ func (x *Cost) GetStart() float64

+ func (x *Cost) GetTotal() float64

+ func (x *Cost) ProtoReflect() protoreflect.Message

+ func (x *Cost) Reset()

+ func (x *Cost) String() string

+ type Expr struct

+ Alias string

+ Expr isExpr_Expr

+ Typ *Type

+ func (*Expr) Descriptor() ([]byte, []int)

+ func (*Expr) ProtoMessage()

+ func (m *Expr) GetExpr() isExpr_Expr

+ func (x *Expr) GetAlias() string

+ func (x *Expr) GetC() *Const

+ func (x *Expr) GetCol() *ColRef

+ func (x *Expr) GetCorr() *CorrColRef

+ func (x *Expr) GetF() *Function

+ func (x *Expr) GetList() *ExprList

+ func (x *Expr) GetP() *ParamRef

+ func (x *Expr) GetSub() *SubQuery

+ func (x *Expr) GetTyp() *Type

+ func (x *Expr) GetV() *VarRef

+ func (x *Expr) ProtoReflect() protoreflect.Message

+ func (x *Expr) Reset()

+ func (x *Expr) String() string

+ type ExprList struct

+ List []*Expr

+ func (*ExprList) Descriptor() ([]byte, []int)

+ func (*ExprList) ProtoMessage()

+ func (x *ExprList) GetList() []*Expr

+ func (x *ExprList) ProtoReflect() protoreflect.Message

+ func (x *ExprList) Reset()

+ func (x *ExprList) String() string

+ type Expr_C struct

+ C *Const

+ type Expr_Col struct

+ Col *ColRef

+ type Expr_Corr struct

+ Corr *CorrColRef

+ type Expr_F struct

+ F *Function

+ type Expr_List struct

+ List *ExprList

+ type Expr_P struct

+ P *ParamRef

+ type Expr_Sub struct

+ Sub *SubQuery

+ type Expr_V struct

+ V *VarRef

+ type Function struct

+ Args []*Expr

+ Func *ObjectRef

+ func (*Function) Descriptor() ([]byte, []int)

+ func (*Function) ProtoMessage()

+ func (x *Function) GetArgs() []*Expr

+ func (x *Function) GetFunc() *ObjectRef

+ func (x *Function) ProtoReflect() protoreflect.Message

+ func (x *Function) Reset()

+ func (x *Function) String() string

+ type Function_FuncFlag int32

+ const Function_AGG

+ const Function_INTERNAL

+ const Function_NONE

+ const Function_PRODUCE_NO_NULL

+ const Function_PRODUCE_NULL

+ const Function_STABLE

+ const Function_STRICT

+ const Function_VARARG

+ const Function_VOLATILE

+ const Function_WIN

+ func (Function_FuncFlag) Descriptor() protoreflect.EnumDescriptor

+ func (Function_FuncFlag) EnumDescriptor() ([]byte, []int)

+ func (Function_FuncFlag) Type() protoreflect.EnumType

+ func (x Function_FuncFlag) Enum() *Function_FuncFlag

+ func (x Function_FuncFlag) Number() protoreflect.EnumNumber

+ func (x Function_FuncFlag) String() string

+ type Node struct

+ Children []int32

+ Cost *Cost

+ ExtraOptions string

+ GroupBy []*Expr

+ GroupingSet []*Expr

+ JoinType Node_JoinFlag

+ Limit *Expr

+ NodeId int32

+ NodeType Node_NodeType

+ ObjRef *ObjectRef

+ Offset *Expr

+ OnList []*Expr

+ OrderBy []*OrderBySpec

+ ProjectList []*Expr

+ RowsetData *RowsetData

+ TableDef *TableDef

+ UpdateList *UpdateList

+ WhereList []*Expr

+ WinSpec *WindowSpec

+ func (*Node) Descriptor() ([]byte, []int)

+ func (*Node) ProtoMessage()

+ func (x *Node) GetChildren() []int32

+ func (x *Node) GetCost() *Cost

+ func (x *Node) GetExtraOptions() string

+ func (x *Node) GetGroupBy() []*Expr

+ func (x *Node) GetGroupingSet() []*Expr

+ func (x *Node) GetJoinType() Node_JoinFlag

+ func (x *Node) GetLimit() *Expr

+ func (x *Node) GetNodeId() int32

+ func (x *Node) GetNodeType() Node_NodeType

+ func (x *Node) GetObjRef() *ObjectRef

+ func (x *Node) GetOffset() *Expr

+ func (x *Node) GetOnList() []*Expr

+ func (x *Node) GetOrderBy() []*OrderBySpec

+ func (x *Node) GetProjectList() []*Expr

+ func (x *Node) GetRowsetData() *RowsetData

+ func (x *Node) GetTableDef() *TableDef

+ func (x *Node) GetUpdateList() *UpdateList

+ func (x *Node) GetWhereList() []*Expr

+ func (x *Node) GetWinSpec() *WindowSpec

+ func (x *Node) ProtoReflect() protoreflect.Message

+ func (x *Node) Reset()

+ func (x *Node) String() string

+ type Node_AggMode int32

+ const Node_BOTTOM

+ const Node_FULL

+ const Node_TOP

+ func (Node_AggMode) Descriptor() protoreflect.EnumDescriptor

+ func (Node_AggMode) EnumDescriptor() ([]byte, []int)

+ func (Node_AggMode) Type() protoreflect.EnumType

+ func (x Node_AggMode) Enum() *Node_AggMode

+ func (x Node_AggMode) Number() protoreflect.EnumNumber

+ func (x Node_AggMode) String() string

+ type Node_JoinFlag int32

+ const Node_ANTI

+ const Node_APPLY

+ const Node_INNER

+ const Node_MARK

+ const Node_OUTER

+ const Node_SEMI

+ const Node_SINGLE

+ func (Node_JoinFlag) Descriptor() protoreflect.EnumDescriptor

+ func (Node_JoinFlag) EnumDescriptor() ([]byte, []int)

+ func (Node_JoinFlag) Type() protoreflect.EnumType

+ func (x Node_JoinFlag) Enum() *Node_JoinFlag

+ func (x Node_JoinFlag) Number() protoreflect.EnumNumber

+ func (x Node_JoinFlag) String() string

+ type Node_NodeType int32

+ const Node_AGG

+ const Node_ASSERT

+ const Node_BROADCAST

+ const Node_EXTERNAL_FUNCTION

+ const Node_EXTERNAL_SCAN

+ const Node_FUNCTION_SCAN

+ const Node_GATHER

+ const Node_INSERT

+ const Node_JOIN

+ const Node_MATERIAL

+ const Node_PROJECT

+ const Node_RECURSIVE_CTE

+ const Node_SAMPLE

+ const Node_SINK

+ const Node_SINK_SCAN

+ const Node_SORT

+ const Node_SPLIT

+ const Node_TABLE_SCAN

+ const Node_UNION

+ const Node_UNION_ALL

+ const Node_UNIQUE

+ const Node_UNKNOWN

+ const Node_UPDATE

+ const Node_VALUE_SCAN

+ const Node_WINDOW

+ func (Node_NodeType) Descriptor() protoreflect.EnumDescriptor

+ func (Node_NodeType) EnumDescriptor() ([]byte, []int)

+ func (Node_NodeType) Type() protoreflect.EnumType

+ func (x Node_NodeType) Enum() *Node_NodeType

+ func (x Node_NodeType) Number() protoreflect.EnumNumber

+ func (x Node_NodeType) String() string

+ type ObjectRef struct

+ Db int64

+ DbName string

+ Obj int64

+ ObjName string

+ Schema int64

+ SchemaName string

+ Server int64

+ ServerName string

+ func (*ObjectRef) Descriptor() ([]byte, []int)

+ func (*ObjectRef) ProtoMessage()

+ func (x *ObjectRef) GetDb() int64

+ func (x *ObjectRef) GetDbName() string

+ func (x *ObjectRef) GetObj() int64

+ func (x *ObjectRef) GetObjName() string

+ func (x *ObjectRef) GetSchema() int64

+ func (x *ObjectRef) GetSchemaName() string

+ func (x *ObjectRef) GetServer() int64

+ func (x *ObjectRef) GetServerName() string

+ func (x *ObjectRef) ProtoReflect() protoreflect.Message

+ func (x *ObjectRef) Reset()

+ func (x *ObjectRef) String() string

+ type OrderBySpec struct

+ OrderBy *Expr

+ OrderByCollations string

+ OrderByFlags OrderBySpec_OrderByFlag

+ func (*OrderBySpec) Descriptor() ([]byte, []int)

+ func (*OrderBySpec) ProtoMessage()

+ func (x *OrderBySpec) GetOrderBy() *Expr

+ func (x *OrderBySpec) GetOrderByCollations() string

+ func (x *OrderBySpec) GetOrderByFlags() OrderBySpec_OrderByFlag

+ func (x *OrderBySpec) ProtoReflect() protoreflect.Message

+ func (x *OrderBySpec) Reset()

+ func (x *OrderBySpec) String() string

+ type OrderBySpec_OrderByFlag int32

+ const OrderBySpec_ASC

+ const OrderBySpec_DESC

+ const OrderBySpec_INTERNAL

+ const OrderBySpec_NULLS_FIRST

+ const OrderBySpec_NULLS_LAST

+ const OrderBySpec_UNIQUE

+ func (OrderBySpec_OrderByFlag) Descriptor() protoreflect.EnumDescriptor

+ func (OrderBySpec_OrderByFlag) EnumDescriptor() ([]byte, []int)

+ func (OrderBySpec_OrderByFlag) Type() protoreflect.EnumType

+ func (x OrderBySpec_OrderByFlag) Enum() *OrderBySpec_OrderByFlag

+ func (x OrderBySpec_OrderByFlag) Number() protoreflect.EnumNumber

+ func (x OrderBySpec_OrderByFlag) String() string

+ type ParamRef struct

+ Pos int32

+ func (*ParamRef) Descriptor() ([]byte, []int)

+ func (*ParamRef) ProtoMessage()

+ func (x *ParamRef) GetPos() int32

+ func (x *ParamRef) ProtoReflect() protoreflect.Message

+ func (x *ParamRef) Reset()

+ func (x *ParamRef) String() string

+ type Query struct

+ Nodes []*Node

+ Params []*Expr

+ Steps []int32

+ StmtType Query_StatementType

+ func (*Query) Descriptor() ([]byte, []int)

+ func (*Query) ProtoMessage()

+ func (x *Query) GetNodes() []*Node

+ func (x *Query) GetParams() []*Expr

+ func (x *Query) GetSteps() []int32

+ func (x *Query) GetStmtType() Query_StatementType

+ func (x *Query) ProtoReflect() protoreflect.Message

+ func (x *Query) Reset()

+ func (x *Query) String() string

+ type Query_StatementType int32

+ const Query_DELETE

+ const Query_INSERT

+ const Query_MERGE

+ const Query_SELECT

+ const Query_UNKNOWN

+ const Query_UPDATE

+ func (Query_StatementType) Descriptor() protoreflect.EnumDescriptor

+ func (Query_StatementType) EnumDescriptor() ([]byte, []int)

+ func (Query_StatementType) Type() protoreflect.EnumType

+ func (x Query_StatementType) Enum() *Query_StatementType

+ func (x Query_StatementType) Number() protoreflect.EnumNumber

+ func (x Query_StatementType) String() string

+ type RowsetData struct

+ Cols []*ColData

+ Schema *TableDef

+ func (*RowsetData) Descriptor() ([]byte, []int)

+ func (*RowsetData) ProtoMessage()

+ func (x *RowsetData) GetCols() []*ColData

+ func (x *RowsetData) GetSchema() *TableDef

+ func (x *RowsetData) ProtoReflect() protoreflect.Message

+ func (x *RowsetData) Reset()

+ func (x *RowsetData) String() string

+ type StatementType int32

+ const StatementType_DELETE

+ const StatementType_INSERT

+ const StatementType_MERGE

+ const StatementType_SELECT

+ const StatementType_UNKNOW

+ const StatementType_UPDATE

+ func (StatementType) Descriptor() protoreflect.EnumDescriptor

+ func (StatementType) EnumDescriptor() ([]byte, []int)

+ func (StatementType) Type() protoreflect.EnumType

+ func (x StatementType) Enum() *StatementType

+ func (x StatementType) Number() protoreflect.EnumNumber

+ func (x StatementType) String() string

+ type SubQuery struct

+ IsCorrelated bool

+ IsScalar bool

+ NodeId int32

+ func (*SubQuery) Descriptor() ([]byte, []int)

+ func (*SubQuery) ProtoMessage()

+ func (x *SubQuery) GetIsCorrelated() bool

+ func (x *SubQuery) GetIsScalar() bool

+ func (x *SubQuery) GetNodeId() int32

+ func (x *SubQuery) ProtoReflect() protoreflect.Message

+ func (x *SubQuery) Reset()

+ func (x *SubQuery) String() string

+ type TableDef struct

+ Cols []*ColDef

+ Name string

+ func (*TableDef) Descriptor() ([]byte, []int)

+ func (*TableDef) ProtoMessage()

+ func (x *TableDef) GetCols() []*ColDef

+ func (x *TableDef) GetName() string

+ func (x *TableDef) ProtoReflect() protoreflect.Message

+ func (x *TableDef) Reset()

+ func (x *TableDef) String() string

+ type Type struct

+ Id Type_TypeId

+ Nullable bool

+ Precision int32

+ Width int32

+ func (*Type) Descriptor() ([]byte, []int)

+ func (*Type) ProtoMessage()

+ func (x *Type) GetId() Type_TypeId

+ func (x *Type) GetNullable() bool

+ func (x *Type) GetPrecision() int32

+ func (x *Type) GetWidth() int32

+ func (x *Type) ProtoReflect() protoreflect.Message

+ func (x *Type) Reset()

+ func (x *Type) String() string

+ type Type_TypeId int32

+ const Type_ANY

+ const Type_ANYFLOAT

+ const Type_ANYINT

+ const Type_ANYNUMBER

+ const Type_ANYTIME

+ const Type_ARRAY

+ const Type_BINARY

+ const Type_BOOL

+ const Type_BYTEA

+ const Type_BYTEA16

+ const Type_BYTEA8

+ const Type_CHAR

+ const Type_DATE

+ const Type_DATETIME

+ const Type_DECIMAL

+ const Type_DECIMAL128

+ const Type_DECIMAL64

+ const Type_FLEXBUFFER

+ const Type_FLOAT32

+ const Type_FLOAT64

+ const Type_INT128

+ const Type_INT16

+ const Type_INT32

+ const Type_INT64

+ const Type_INT8

+ const Type_INTERVAL

+ const Type_JSON

+ const Type_SEL

+ const Type_STAR

+ const Type_TIME

+ const Type_TIMESTAMP

+ const Type_TUPLE

+ const Type_UB160

+ const Type_UB184

+ const Type_UB192

+ const Type_UB224

+ const Type_UB256

+ const Type_UINT128

+ const Type_UINT16

+ const Type_UINT32

+ const Type_UINT64

+ const Type_UINT8

+ const Type_UUID

+ const Type_VARBINARY

+ const Type_VARCHAR

+ func (Type_TypeId) Descriptor() protoreflect.EnumDescriptor

+ func (Type_TypeId) EnumDescriptor() ([]byte, []int)

+ func (Type_TypeId) Type() protoreflect.EnumType

+ func (x Type_TypeId) Enum() *Type_TypeId

+ func (x Type_TypeId) Number() protoreflect.EnumNumber

+ func (x Type_TypeId) String() string

+ type UpdateList struct

+ Columns []*Expr

+ Values []*Expr

+ func (*UpdateList) Descriptor() ([]byte, []int)

+ func (*UpdateList) ProtoMessage()

+ func (x *UpdateList) GetColumns() []*Expr

+ func (x *UpdateList) GetValues() []*Expr

+ func (x *UpdateList) ProtoReflect() protoreflect.Message

+ func (x *UpdateList) Reset()

+ func (x *UpdateList) String() string

+ type VarRef struct

+ Name string

+ func (*VarRef) Descriptor() ([]byte, []int)

+ func (*VarRef) ProtoMessage()

+ func (x *VarRef) GetName() string

+ func (x *VarRef) ProtoReflect() protoreflect.Message

+ func (x *VarRef) Reset()

+ func (x *VarRef) String() string

+ type WindowSpec struct

+ Lag int32

+ Lead int32

+ OderyBy []*OrderBySpec

+ PartitionBy []*Expr

+ func (*WindowSpec) Descriptor() ([]byte, []int)

+ func (*WindowSpec) ProtoMessage()

+ func (x *WindowSpec) GetLag() int32

+ func (x *WindowSpec) GetLead() int32

+ func (x *WindowSpec) GetOderyBy() []*OrderBySpec

+ func (x *WindowSpec) GetPartitionBy() []*Expr

+ func (x *WindowSpec) ProtoReflect() protoreflect.Message

+ func (x *WindowSpec) Reset()

+ func (x *WindowSpec) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL