Documentation
¶
Index ¶
- Variables
- func GetTempTableName(DbName string, TblName string) string
- func IsMemtable(tblRange []byte) bool
- type Attribute
- func (*Attribute) Descriptor() ([]byte, []int)
- func (def *Attribute) Format(buf *bytes.Buffer)
- func (m *Attribute) GetAlg() github_com_matrixorigin_matrixone_pkg_compress.T
- func (m *Attribute) GetAutoIncrement() bool
- func (m *Attribute) GetClusterBy() bool
- func (m *Attribute) GetComment() string
- func (m *Attribute) GetDefault() *plan.Default
- func (m *Attribute) GetID() uint64
- func (m *Attribute) GetIsHidden() bool
- func (m *Attribute) GetIsRowId() bool
- func (m *Attribute) GetName() string
- func (m *Attribute) GetOnUpdate() *plan.OnUpdate
- func (m *Attribute) GetPrimary() bool
- func (m *Attribute) Marshal() (dAtA []byte, err error)
- func (m *Attribute) MarshalTo(dAtA []byte) (int, error)
- func (m *Attribute) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Attribute) ProtoMessage()
- func (m *Attribute) ProtoSize() (n int)
- func (m *Attribute) Reset()
- func (m *Attribute) String() string
- func (m *Attribute) Unmarshal(dAtA []byte) error
- func (m *Attribute) XXX_DiscardUnknown()
- func (m *Attribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Attribute) XXX_Merge(src proto.Message)
- func (m *Attribute) XXX_Size() int
- func (m *Attribute) XXX_Unmarshal(b []byte) error
- type AttributeDef
- func (*AttributeDef) Descriptor() ([]byte, []int)
- func (def *AttributeDef) Format(buf *bytes.Buffer)
- func (m *AttributeDef) GetAttr() Attribute
- func (m *AttributeDef) Marshal() (dAtA []byte, err error)
- func (m *AttributeDef) MarshalTo(dAtA []byte) (int, error)
- func (m *AttributeDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AttributeDef) ProtoMessage()
- func (m *AttributeDef) ProtoSize() (n int)
- func (m *AttributeDef) Reset()
- func (m *AttributeDef) String() string
- func (def *AttributeDef) ToPBVersion() TableDefPB
- func (m *AttributeDef) Unmarshal(dAtA []byte) error
- func (m *AttributeDef) XXX_DiscardUnknown()
- func (m *AttributeDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AttributeDef) XXX_Merge(src proto.Message)
- func (m *AttributeDef) XXX_Size() int
- func (m *AttributeDef) XXX_Unmarshal(b []byte) error
- type ClusterByDef
- func (*ClusterByDef) Descriptor() ([]byte, []int)
- func (m *ClusterByDef) GetName() string
- 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 (*ClusterByDef) ProtoMessage()
- func (m *ClusterByDef) ProtoSize() (n int)
- func (m *ClusterByDef) Reset()
- func (m *ClusterByDef) String() string
- func (def *ClusterByDef) ToPBVersion() TableDefPB
- 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 CommentDef
- func (*CommentDef) Descriptor() ([]byte, []int)
- func (m *CommentDef) GetComment() string
- func (m *CommentDef) Marshal() (dAtA []byte, err error)
- func (m *CommentDef) MarshalTo(dAtA []byte) (int, error)
- func (m *CommentDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommentDef) ProtoMessage()
- func (m *CommentDef) ProtoSize() (n int)
- func (m *CommentDef) Reset()
- func (m *CommentDef) String() string
- func (def *CommentDef) ToPBVersion() TableDefPB
- func (m *CommentDef) Unmarshal(dAtA []byte) error
- func (m *CommentDef) XXX_DiscardUnknown()
- func (m *CommentDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommentDef) XXX_Merge(src proto.Message)
- func (m *CommentDef) XXX_Size() int
- func (m *CommentDef) XXX_Unmarshal(b []byte) error
- type Constraint
- type ConstraintDef
- type ConstraintDefPB
- func (*ConstraintDefPB) Descriptor() ([]byte, []int)
- func (def *ConstraintDefPB) FromPBVersion() *ConstraintDef
- func (m *ConstraintDefPB) GetCts() []ConstraintPB
- func (m *ConstraintDefPB) Marshal() (dAtA []byte, err error)
- func (m *ConstraintDefPB) MarshalTo(dAtA []byte) (int, error)
- func (m *ConstraintDefPB) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConstraintDefPB) ProtoMessage()
- func (m *ConstraintDefPB) ProtoSize() (n int)
- func (m *ConstraintDefPB) Reset()
- func (m *ConstraintDefPB) String() string
- func (m *ConstraintDefPB) Unmarshal(dAtA []byte) error
- func (m *ConstraintDefPB) XXX_DiscardUnknown()
- func (m *ConstraintDefPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConstraintDefPB) XXX_Merge(src proto.Message)
- func (m *ConstraintDefPB) XXX_Size() int
- func (m *ConstraintDefPB) XXX_Unmarshal(b []byte) error
- type ConstraintPB
- func (*ConstraintPB) Descriptor() ([]byte, []int)
- func (def *ConstraintPB) FromPBVersion() Constraint
- func (m *ConstraintPB) GetCt() isConstraintPB_Ct
- func (m *ConstraintPB) GetForeignKeyDef() *ForeignKeyDef
- func (m *ConstraintPB) GetIndexDef() *IndexDef
- func (m *ConstraintPB) GetPrimaryKeyDef() *PrimaryKeyDef
- func (m *ConstraintPB) GetRefChildTableDef() *RefChildTableDef
- func (m *ConstraintPB) GetStreamConfigsDef() *StreamConfigsDef
- func (m *ConstraintPB) Marshal() (dAtA []byte, err error)
- func (m *ConstraintPB) MarshalTo(dAtA []byte) (int, error)
- func (m *ConstraintPB) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConstraintPB) ProtoMessage()
- func (m *ConstraintPB) ProtoSize() (n int)
- func (m *ConstraintPB) Reset()
- func (m *ConstraintPB) String() string
- func (m *ConstraintPB) Unmarshal(dAtA []byte) error
- func (m *ConstraintPB) XXX_DiscardUnknown()
- func (m *ConstraintPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConstraintPB) XXX_Merge(src proto.Message)
- func (*ConstraintPB) XXX_OneofWrappers() []interface{}
- func (m *ConstraintPB) XXX_Size() int
- func (m *ConstraintPB) XXX_Unmarshal(b []byte) error
- type ConstraintPB_ForeignKeyDef
- type ConstraintPB_IndexDef
- type ConstraintPB_PrimaryKeyDef
- type ConstraintPB_RefChildTableDef
- type ConstraintPB_StreamConfigsDef
- type ConstraintType
- type Database
- type Engine
- type EngineType
- type EntireEngine
- func (e *EntireEngine) AllocateIDByKey(ctx context.Context, key string) (uint64, error)
- func (e *EntireEngine) Create(ctx context.Context, databaseName string, op client.TxnOperator) error
- func (e *EntireEngine) Database(ctx context.Context, databaseName string, op client.TxnOperator) (Database, error)
- func (e *EntireEngine) Databases(ctx context.Context, op client.TxnOperator) (databaseNames []string, err error)
- func (e *EntireEngine) Delete(ctx context.Context, databaseName string, op client.TxnOperator) error
- func (e *EntireEngine) GetNameById(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, err error)
- func (e *EntireEngine) GetRelationById(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, rel Relation, err error)
- func (e *EntireEngine) Hints() Hints
- func (e *EntireEngine) New(ctx context.Context, op client.TxnOperator) error
- func (e *EntireEngine) NewBlockReader(ctx context.Context, num int, ts timestamp.Timestamp, expr *plan.Expr, ...) ([]Reader, error)
- func (e *EntireEngine) Nodes(isInternal bool, tenant string, username string, cnLabel map[string]string) (cnNodes Nodes, err error)
- type ForeignKeyDef
- func (*ForeignKeyDef) Descriptor() ([]byte, []int)
- func (m *ForeignKeyDef) GetFkeys() []*plan.ForeignKeyDef
- 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 (*ForeignKeyDef) ProtoMessage()
- func (m *ForeignKeyDef) ProtoSize() (n int)
- func (m *ForeignKeyDef) Reset()
- func (m *ForeignKeyDef) String() string
- func (def *ForeignKeyDef) ToPBVersion() ConstraintPB
- 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 Hints
- type IndexDef
- func (*IndexDef) Descriptor() ([]byte, []int)
- func (m *IndexDef) GetIndexes() []*plan.IndexDef
- 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 (*IndexDef) ProtoMessage()
- func (m *IndexDef) ProtoSize() (n int)
- func (m *IndexDef) Reset()
- func (m *IndexDef) String() string
- func (def *IndexDef) ToPBVersion() ConstraintPB
- 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 IndexT
- type IndexTableDef
- func (*IndexTableDef) Descriptor() ([]byte, []int)
- func (def *IndexTableDef) Format(buf *bytes.Buffer)
- func (m *IndexTableDef) GetColNames() []string
- func (m *IndexTableDef) GetName() string
- func (m *IndexTableDef) GetTyp() IndexT
- func (m *IndexTableDef) Marshal() (dAtA []byte, err error)
- func (m *IndexTableDef) MarshalTo(dAtA []byte) (int, error)
- func (m *IndexTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IndexTableDef) ProtoMessage()
- func (m *IndexTableDef) ProtoSize() (n int)
- func (m *IndexTableDef) Reset()
- func (m *IndexTableDef) String() string
- func (def *IndexTableDef) ToPBVersion() TableDefPB
- func (m *IndexTableDef) Unmarshal(dAtA []byte) error
- func (m *IndexTableDef) XXX_DiscardUnknown()
- func (m *IndexTableDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IndexTableDef) XXX_Merge(src proto.Message)
- func (m *IndexTableDef) XXX_Size() int
- func (m *IndexTableDef) XXX_Unmarshal(b []byte) error
- type Node
- type Nodes
- type PartitionDef
- func (*PartitionDef) Descriptor() ([]byte, []int)
- func (m *PartitionDef) GetPartition() string
- func (m *PartitionDef) Marshal() (dAtA []byte, err error)
- func (m *PartitionDef) MarshalTo(dAtA []byte) (int, error)
- func (m *PartitionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionDef) ProtoMessage()
- func (m *PartitionDef) ProtoSize() (n int)
- func (m *PartitionDef) Reset()
- func (m *PartitionDef) String() string
- func (def *PartitionDef) ToPBVersion() TableDefPB
- func (m *PartitionDef) Unmarshal(dAtA []byte) error
- func (m *PartitionDef) XXX_DiscardUnknown()
- func (m *PartitionDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PartitionDef) XXX_Merge(src proto.Message)
- func (m *PartitionDef) XXX_Size() int
- func (m *PartitionDef) XXX_Unmarshal(b []byte) error
- type PrimaryKeyDef
- func (*PrimaryKeyDef) Descriptor() ([]byte, []int)
- func (m *PrimaryKeyDef) GetPkey() *plan.PrimaryKeyDef
- 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 (*PrimaryKeyDef) ProtoMessage()
- func (m *PrimaryKeyDef) ProtoSize() (n int)
- func (m *PrimaryKeyDef) Reset()
- func (m *PrimaryKeyDef) String() string
- func (def *PrimaryKeyDef) ToPBVersion() ConstraintPB
- 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
- func (*PropertiesDef) Descriptor() ([]byte, []int)
- 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 (*PropertiesDef) ProtoMessage()
- func (m *PropertiesDef) ProtoSize() (n int)
- func (m *PropertiesDef) Reset()
- func (m *PropertiesDef) String() string
- func (def *PropertiesDef) ToPBVersion() TableDefPB
- 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
- func (*Property) Descriptor() ([]byte, []int)
- 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 (*Property) ProtoMessage()
- 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 Reader
- type RefChildTableDef
- func (*RefChildTableDef) Descriptor() ([]byte, []int)
- func (m *RefChildTableDef) GetTables() []uint64
- func (m *RefChildTableDef) Marshal() (dAtA []byte, err error)
- func (m *RefChildTableDef) MarshalTo(dAtA []byte) (int, error)
- func (m *RefChildTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RefChildTableDef) ProtoMessage()
- func (m *RefChildTableDef) ProtoSize() (n int)
- func (m *RefChildTableDef) Reset()
- func (m *RefChildTableDef) String() string
- func (def *RefChildTableDef) ToPBVersion() ConstraintPB
- func (m *RefChildTableDef) Unmarshal(dAtA []byte) error
- func (m *RefChildTableDef) XXX_DiscardUnknown()
- func (m *RefChildTableDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RefChildTableDef) XXX_Merge(src proto.Message)
- func (m *RefChildTableDef) XXX_Size() int
- func (m *RefChildTableDef) XXX_Unmarshal(b []byte) error
- type Relation
- type Statistics
- type StreamConfigsDef
- func (*StreamConfigsDef) Descriptor() ([]byte, []int)
- func (m *StreamConfigsDef) GetConfigs() []*plan.Property
- func (m *StreamConfigsDef) Marshal() (dAtA []byte, err error)
- func (m *StreamConfigsDef) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamConfigsDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamConfigsDef) ProtoMessage()
- func (m *StreamConfigsDef) ProtoSize() (n int)
- func (m *StreamConfigsDef) Reset()
- func (m *StreamConfigsDef) String() string
- func (def *StreamConfigsDef) ToPBVersion() ConstraintPB
- func (m *StreamConfigsDef) Unmarshal(dAtA []byte) error
- func (m *StreamConfigsDef) XXX_DiscardUnknown()
- func (m *StreamConfigsDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamConfigsDef) XXX_Merge(src proto.Message)
- func (m *StreamConfigsDef) XXX_Size() int
- func (m *StreamConfigsDef) XXX_Unmarshal(b []byte) error
- type TableDef
- type TableDefPB
- func (*TableDefPB) Descriptor() ([]byte, []int)
- func (def *TableDefPB) FromPBVersion() TableDef
- func (m *TableDefPB) GetAttributeDef() *AttributeDef
- func (m *TableDefPB) GetClusterByDef() *ClusterByDef
- func (m *TableDefPB) GetCommentDef() *CommentDef
- func (m *TableDefPB) GetConstraintDefPB() *ConstraintDefPB
- func (m *TableDefPB) GetDef() isTableDefPB_Def
- func (m *TableDefPB) GetIndexTableDef() *IndexTableDef
- func (m *TableDefPB) GetPartitionDef() *PartitionDef
- func (m *TableDefPB) GetPropertiesDef() *PropertiesDef
- func (m *TableDefPB) GetVersionDef() *VersionDef
- func (m *TableDefPB) GetViewDef() *ViewDef
- func (m *TableDefPB) Marshal() (dAtA []byte, err error)
- func (m *TableDefPB) MarshalTo(dAtA []byte) (int, error)
- func (m *TableDefPB) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TableDefPB) ProtoMessage()
- func (m *TableDefPB) ProtoSize() (n int)
- func (m *TableDefPB) Reset()
- func (m *TableDefPB) String() string
- func (m *TableDefPB) Unmarshal(dAtA []byte) error
- func (m *TableDefPB) XXX_DiscardUnknown()
- func (m *TableDefPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TableDefPB) XXX_Merge(src proto.Message)
- func (*TableDefPB) XXX_OneofWrappers() []interface{}
- func (m *TableDefPB) XXX_Size() int
- func (m *TableDefPB) XXX_Unmarshal(b []byte) error
- type TableDefPB_AttributeDef
- type TableDefPB_ClusterByDef
- type TableDefPB_CommentDef
- type TableDefPB_ConstraintDefPB
- type TableDefPB_IndexTableDef
- type TableDefPB_PartitionDef
- type TableDefPB_PropertiesDef
- type TableDefPB_VersionDef
- type TableDefPB_ViewDef
- type VectorPool
- type VersionDef
- func (*VersionDef) Descriptor() ([]byte, []int)
- func (m *VersionDef) GetVersion() uint32
- func (m *VersionDef) Marshal() (dAtA []byte, err error)
- func (m *VersionDef) MarshalTo(dAtA []byte) (int, error)
- func (m *VersionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*VersionDef) ProtoMessage()
- func (m *VersionDef) ProtoSize() (n int)
- func (m *VersionDef) Reset()
- func (m *VersionDef) String() string
- func (def *VersionDef) ToPBVersion() TableDefPB
- func (m *VersionDef) Unmarshal(dAtA []byte) error
- func (m *VersionDef) XXX_DiscardUnknown()
- func (m *VersionDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VersionDef) XXX_Merge(src proto.Message)
- func (m *VersionDef) XXX_Size() int
- func (m *VersionDef) XXX_Unmarshal(b []byte) error
- type ViewDef
- func (*ViewDef) Descriptor() ([]byte, []int)
- 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 (*ViewDef) ProtoMessage()
- func (m *ViewDef) ProtoSize() (n int)
- func (m *ViewDef) Reset()
- func (m *ViewDef) String() string
- func (def *ViewDef) ToPBVersion() TableDefPB
- 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
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func GetTempTableName ¶ added in v0.7.0
func IsMemtable ¶ added in v0.8.0
Types ¶
type Attribute ¶
type Attribute struct { // IsHide whether the attribute is hidden or not IsHidden bool // IsRowId whether the attribute is rowid or not IsRowId bool // Column ID ID uint64 // Name name of attribute Name string // Alg compression algorithm Alg compress.T // Type attribute's type Type types.Type // DefaultExpr default value of this attribute Default *plan.Default // to update col when define in create table OnUpdate *plan.OnUpdate // Primary is primary key or not Primary bool // Clusterby means sort by this column ClusterBy bool // Comment of attribute Comment string // AutoIncrement is auto incr or not AutoIncrement bool // Seqnum, do not change during the whole lifetime of the table Seqnum uint16 // EnumValues is for enum type EnumVlaues string }
Attribute is a column
func (*Attribute) Descriptor ¶ added in v0.8.0
func (*Attribute) GetAlg ¶ added in v0.8.0
func (m *Attribute) GetAlg() github_com_matrixorigin_matrixone_pkg_compress.T
func (*Attribute) GetAutoIncrement ¶ added in v0.8.0
func (*Attribute) GetClusterBy ¶ added in v0.8.0
func (*Attribute) GetComment ¶ added in v0.8.0
func (*Attribute) GetDefault ¶ added in v0.8.0
func (*Attribute) GetIsHidden ¶ added in v0.8.0
func (*Attribute) GetIsRowId ¶ added in v0.8.0
func (*Attribute) GetOnUpdate ¶ added in v0.8.0
func (*Attribute) GetPrimary ¶ added in v0.8.0
func (*Attribute) MarshalToSizedBuffer ¶ added in v0.8.0
func (*Attribute) ProtoMessage ¶ added in v0.8.0
func (*Attribute) ProtoMessage()
func (*Attribute) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *Attribute) XXX_DiscardUnknown()
func (*Attribute) XXX_Marshal ¶ added in v0.8.0
func (*Attribute) XXX_Unmarshal ¶ added in v0.8.0
type AttributeDef ¶
type AttributeDef struct {
Attr Attribute
}
func (*AttributeDef) Descriptor ¶ added in v0.8.0
func (*AttributeDef) Descriptor() ([]byte, []int)
func (*AttributeDef) Format ¶
func (def *AttributeDef) Format(buf *bytes.Buffer)
func (*AttributeDef) GetAttr ¶ added in v0.8.0
func (m *AttributeDef) GetAttr() Attribute
func (*AttributeDef) Marshal ¶ added in v0.8.0
func (m *AttributeDef) Marshal() (dAtA []byte, err error)
func (*AttributeDef) MarshalTo ¶ added in v0.8.0
func (m *AttributeDef) MarshalTo(dAtA []byte) (int, error)
func (*AttributeDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *AttributeDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AttributeDef) ProtoMessage ¶ added in v0.8.0
func (*AttributeDef) ProtoMessage()
func (*AttributeDef) ProtoSize ¶ added in v0.8.0
func (m *AttributeDef) ProtoSize() (n int)
func (*AttributeDef) Reset ¶ added in v0.8.0
func (m *AttributeDef) Reset()
func (*AttributeDef) String ¶ added in v0.8.0
func (m *AttributeDef) String() string
func (*AttributeDef) ToPBVersion ¶ added in v0.8.0
func (def *AttributeDef) ToPBVersion() TableDefPB
func (*AttributeDef) Unmarshal ¶ added in v0.8.0
func (m *AttributeDef) Unmarshal(dAtA []byte) error
func (*AttributeDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *AttributeDef) XXX_DiscardUnknown()
func (*AttributeDef) XXX_Marshal ¶ added in v0.8.0
func (m *AttributeDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AttributeDef) XXX_Merge ¶ added in v0.8.0
func (m *AttributeDef) XXX_Merge(src proto.Message)
func (*AttributeDef) XXX_Size ¶ added in v0.8.0
func (m *AttributeDef) XXX_Size() int
func (*AttributeDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *AttributeDef) XXX_Unmarshal(b []byte) error
type ClusterByDef ¶ added in v0.7.0
type ClusterByDef struct {
Name string
}
func (*ClusterByDef) Descriptor ¶ added in v0.8.0
func (*ClusterByDef) Descriptor() ([]byte, []int)
func (*ClusterByDef) GetName ¶ added in v0.8.0
func (m *ClusterByDef) GetName() string
func (*ClusterByDef) Marshal ¶ added in v0.8.0
func (m *ClusterByDef) Marshal() (dAtA []byte, err error)
func (*ClusterByDef) MarshalTo ¶ added in v0.8.0
func (m *ClusterByDef) MarshalTo(dAtA []byte) (int, error)
func (*ClusterByDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *ClusterByDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterByDef) ProtoMessage ¶ added in v0.8.0
func (*ClusterByDef) ProtoMessage()
func (*ClusterByDef) ProtoSize ¶ added in v0.8.0
func (m *ClusterByDef) ProtoSize() (n int)
func (*ClusterByDef) Reset ¶ added in v0.8.0
func (m *ClusterByDef) Reset()
func (*ClusterByDef) String ¶ added in v0.8.0
func (m *ClusterByDef) String() string
func (*ClusterByDef) ToPBVersion ¶ added in v0.8.0
func (def *ClusterByDef) ToPBVersion() TableDefPB
func (*ClusterByDef) Unmarshal ¶ added in v0.8.0
func (m *ClusterByDef) Unmarshal(dAtA []byte) error
func (*ClusterByDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *ClusterByDef) XXX_DiscardUnknown()
func (*ClusterByDef) XXX_Marshal ¶ added in v0.8.0
func (m *ClusterByDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterByDef) XXX_Merge ¶ added in v0.8.0
func (m *ClusterByDef) XXX_Merge(src proto.Message)
func (*ClusterByDef) XXX_Size ¶ added in v0.8.0
func (m *ClusterByDef) XXX_Size() int
func (*ClusterByDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *ClusterByDef) XXX_Unmarshal(b []byte) error
type CommentDef ¶
type CommentDef struct {
Comment string
}
func (*CommentDef) Descriptor ¶ added in v0.8.0
func (*CommentDef) Descriptor() ([]byte, []int)
func (*CommentDef) GetComment ¶ added in v0.8.0
func (m *CommentDef) GetComment() string
func (*CommentDef) Marshal ¶ added in v0.8.0
func (m *CommentDef) Marshal() (dAtA []byte, err error)
func (*CommentDef) MarshalTo ¶ added in v0.8.0
func (m *CommentDef) MarshalTo(dAtA []byte) (int, error)
func (*CommentDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *CommentDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommentDef) ProtoMessage ¶ added in v0.8.0
func (*CommentDef) ProtoMessage()
func (*CommentDef) ProtoSize ¶ added in v0.8.0
func (m *CommentDef) ProtoSize() (n int)
func (*CommentDef) Reset ¶ added in v0.8.0
func (m *CommentDef) Reset()
func (*CommentDef) String ¶ added in v0.8.0
func (m *CommentDef) String() string
func (*CommentDef) ToPBVersion ¶ added in v0.8.0
func (def *CommentDef) ToPBVersion() TableDefPB
func (*CommentDef) Unmarshal ¶ added in v0.8.0
func (m *CommentDef) Unmarshal(dAtA []byte) error
func (*CommentDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *CommentDef) XXX_DiscardUnknown()
func (*CommentDef) XXX_Marshal ¶ added in v0.8.0
func (m *CommentDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommentDef) XXX_Merge ¶ added in v0.8.0
func (m *CommentDef) XXX_Merge(src proto.Message)
func (*CommentDef) XXX_Size ¶ added in v0.8.0
func (m *CommentDef) XXX_Size() int
func (*CommentDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *CommentDef) XXX_Unmarshal(b []byte) error
type Constraint ¶ added in v0.7.0
type Constraint interface { // ToPBVersion returns corresponding PB struct. ToPBVersion() ConstraintPB // contains filtered or unexported methods }
type ConstraintDef ¶ added in v0.7.0
type ConstraintDef struct {
Cts []Constraint
}
func (*ConstraintDef) GetPrimaryKeyDef ¶ added in v0.7.0
func (def *ConstraintDef) GetPrimaryKeyDef() *PrimaryKeyDef
get the primary key definition in the constraint, and return null if there is no primary key
func (*ConstraintDef) MarshalBinary ¶ added in v0.7.0
func (def *ConstraintDef) MarshalBinary() (data []byte, err error)
func (*ConstraintDef) ToPBVersion ¶ added in v0.8.0
func (def *ConstraintDef) ToPBVersion() TableDefPB
func (*ConstraintDef) UnmarshalBinary ¶ added in v0.7.0
func (def *ConstraintDef) UnmarshalBinary(data []byte) error
type ConstraintDefPB ¶ added in v0.8.0
type ConstraintDefPB struct {
Cts []ConstraintPB `protobuf:"bytes,1,rep,name=Cts,proto3" json:"Cts"`
}
PB version of ConstraintDef
func (*ConstraintDefPB) Descriptor ¶ added in v0.8.0
func (*ConstraintDefPB) Descriptor() ([]byte, []int)
func (*ConstraintDefPB) FromPBVersion ¶ added in v0.8.0
func (def *ConstraintDefPB) FromPBVersion() *ConstraintDef
func (*ConstraintDefPB) GetCts ¶ added in v0.8.0
func (m *ConstraintDefPB) GetCts() []ConstraintPB
func (*ConstraintDefPB) Marshal ¶ added in v0.8.0
func (m *ConstraintDefPB) Marshal() (dAtA []byte, err error)
func (*ConstraintDefPB) MarshalTo ¶ added in v0.8.0
func (m *ConstraintDefPB) MarshalTo(dAtA []byte) (int, error)
func (*ConstraintDefPB) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *ConstraintDefPB) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConstraintDefPB) ProtoMessage ¶ added in v0.8.0
func (*ConstraintDefPB) ProtoMessage()
func (*ConstraintDefPB) ProtoSize ¶ added in v0.8.0
func (m *ConstraintDefPB) ProtoSize() (n int)
func (*ConstraintDefPB) Reset ¶ added in v0.8.0
func (m *ConstraintDefPB) Reset()
func (*ConstraintDefPB) String ¶ added in v0.8.0
func (m *ConstraintDefPB) String() string
func (*ConstraintDefPB) Unmarshal ¶ added in v0.8.0
func (m *ConstraintDefPB) Unmarshal(dAtA []byte) error
func (*ConstraintDefPB) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *ConstraintDefPB) XXX_DiscardUnknown()
func (*ConstraintDefPB) XXX_Marshal ¶ added in v0.8.0
func (m *ConstraintDefPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConstraintDefPB) XXX_Merge ¶ added in v0.8.0
func (m *ConstraintDefPB) XXX_Merge(src proto.Message)
func (*ConstraintDefPB) XXX_Size ¶ added in v0.8.0
func (m *ConstraintDefPB) XXX_Size() int
func (*ConstraintDefPB) XXX_Unmarshal ¶ added in v0.8.0
func (m *ConstraintDefPB) XXX_Unmarshal(b []byte) error
type ConstraintPB ¶ added in v0.8.0
type ConstraintPB struct { // Types that are valid to be assigned to Ct: // *ConstraintPB_ForeignKeyDef // *ConstraintPB_PrimaryKeyDef // *ConstraintPB_RefChildTableDef // *ConstraintPB_IndexDef // *ConstraintPB_StreamConfigsDef Ct isConstraintPB_Ct `protobuf_oneof:"ct"` }
PB version of Constraint
func (*ConstraintPB) Descriptor ¶ added in v0.8.0
func (*ConstraintPB) Descriptor() ([]byte, []int)
func (*ConstraintPB) FromPBVersion ¶ added in v0.8.0
func (def *ConstraintPB) FromPBVersion() Constraint
func (*ConstraintPB) GetCt ¶ added in v0.8.0
func (m *ConstraintPB) GetCt() isConstraintPB_Ct
func (*ConstraintPB) GetForeignKeyDef ¶ added in v0.8.0
func (m *ConstraintPB) GetForeignKeyDef() *ForeignKeyDef
func (*ConstraintPB) GetIndexDef ¶ added in v0.8.0
func (m *ConstraintPB) GetIndexDef() *IndexDef
func (*ConstraintPB) GetPrimaryKeyDef ¶ added in v0.8.0
func (m *ConstraintPB) GetPrimaryKeyDef() *PrimaryKeyDef
func (*ConstraintPB) GetRefChildTableDef ¶ added in v0.8.0
func (m *ConstraintPB) GetRefChildTableDef() *RefChildTableDef
func (*ConstraintPB) GetStreamConfigsDef ¶ added in v1.0.0
func (m *ConstraintPB) GetStreamConfigsDef() *StreamConfigsDef
func (*ConstraintPB) Marshal ¶ added in v0.8.0
func (m *ConstraintPB) Marshal() (dAtA []byte, err error)
func (*ConstraintPB) MarshalTo ¶ added in v0.8.0
func (m *ConstraintPB) MarshalTo(dAtA []byte) (int, error)
func (*ConstraintPB) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *ConstraintPB) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConstraintPB) ProtoMessage ¶ added in v0.8.0
func (*ConstraintPB) ProtoMessage()
func (*ConstraintPB) ProtoSize ¶ added in v0.8.0
func (m *ConstraintPB) ProtoSize() (n int)
func (*ConstraintPB) Reset ¶ added in v0.8.0
func (m *ConstraintPB) Reset()
func (*ConstraintPB) String ¶ added in v0.8.0
func (m *ConstraintPB) String() string
func (*ConstraintPB) Unmarshal ¶ added in v0.8.0
func (m *ConstraintPB) Unmarshal(dAtA []byte) error
func (*ConstraintPB) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *ConstraintPB) XXX_DiscardUnknown()
func (*ConstraintPB) XXX_Marshal ¶ added in v0.8.0
func (m *ConstraintPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConstraintPB) XXX_Merge ¶ added in v0.8.0
func (m *ConstraintPB) XXX_Merge(src proto.Message)
func (*ConstraintPB) XXX_OneofWrappers ¶ added in v0.8.0
func (*ConstraintPB) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ConstraintPB) XXX_Size ¶ added in v0.8.0
func (m *ConstraintPB) XXX_Size() int
func (*ConstraintPB) XXX_Unmarshal ¶ added in v0.8.0
func (m *ConstraintPB) XXX_Unmarshal(b []byte) error
type ConstraintPB_ForeignKeyDef ¶ added in v0.8.0
type ConstraintPB_ForeignKeyDef struct {
ForeignKeyDef *ForeignKeyDef `protobuf:"bytes,1,opt,name=ForeignKeyDef,proto3,oneof" json:"ForeignKeyDef,omitempty"`
}
func (*ConstraintPB_ForeignKeyDef) MarshalTo ¶ added in v0.8.0
func (m *ConstraintPB_ForeignKeyDef) MarshalTo(dAtA []byte) (int, error)
func (*ConstraintPB_ForeignKeyDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *ConstraintPB_ForeignKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConstraintPB_ForeignKeyDef) ProtoSize ¶ added in v0.8.0
func (m *ConstraintPB_ForeignKeyDef) ProtoSize() (n int)
type ConstraintPB_IndexDef ¶ added in v0.8.0
type ConstraintPB_IndexDef struct {
IndexDef *IndexDef `protobuf:"bytes,4,opt,name=IndexDef,proto3,oneof" json:"IndexDef,omitempty"`
}
func (*ConstraintPB_IndexDef) MarshalTo ¶ added in v0.8.0
func (m *ConstraintPB_IndexDef) MarshalTo(dAtA []byte) (int, error)
func (*ConstraintPB_IndexDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *ConstraintPB_IndexDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConstraintPB_IndexDef) ProtoSize ¶ added in v0.8.0
func (m *ConstraintPB_IndexDef) ProtoSize() (n int)
type ConstraintPB_PrimaryKeyDef ¶ added in v0.8.0
type ConstraintPB_PrimaryKeyDef struct {
PrimaryKeyDef *PrimaryKeyDef `protobuf:"bytes,2,opt,name=PrimaryKeyDef,proto3,oneof" json:"PrimaryKeyDef,omitempty"`
}
func (*ConstraintPB_PrimaryKeyDef) MarshalTo ¶ added in v0.8.0
func (m *ConstraintPB_PrimaryKeyDef) MarshalTo(dAtA []byte) (int, error)
func (*ConstraintPB_PrimaryKeyDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *ConstraintPB_PrimaryKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConstraintPB_PrimaryKeyDef) ProtoSize ¶ added in v0.8.0
func (m *ConstraintPB_PrimaryKeyDef) ProtoSize() (n int)
type ConstraintPB_RefChildTableDef ¶ added in v0.8.0
type ConstraintPB_RefChildTableDef struct {
RefChildTableDef *RefChildTableDef `protobuf:"bytes,3,opt,name=RefChildTableDef,proto3,oneof" json:"RefChildTableDef,omitempty"`
}
func (*ConstraintPB_RefChildTableDef) MarshalTo ¶ added in v0.8.0
func (m *ConstraintPB_RefChildTableDef) MarshalTo(dAtA []byte) (int, error)
func (*ConstraintPB_RefChildTableDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *ConstraintPB_RefChildTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConstraintPB_RefChildTableDef) ProtoSize ¶ added in v0.8.0
func (m *ConstraintPB_RefChildTableDef) ProtoSize() (n int)
type ConstraintPB_StreamConfigsDef ¶ added in v1.0.0
type ConstraintPB_StreamConfigsDef struct {
StreamConfigsDef *StreamConfigsDef `protobuf:"bytes,5,opt,name=StreamConfigsDef,proto3,oneof" json:"StreamConfigsDef,omitempty"`
}
func (*ConstraintPB_StreamConfigsDef) MarshalTo ¶ added in v1.0.0
func (m *ConstraintPB_StreamConfigsDef) MarshalTo(dAtA []byte) (int, error)
func (*ConstraintPB_StreamConfigsDef) MarshalToSizedBuffer ¶ added in v1.0.0
func (m *ConstraintPB_StreamConfigsDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConstraintPB_StreamConfigsDef) ProtoSize ¶ added in v1.0.0
func (m *ConstraintPB_StreamConfigsDef) ProtoSize() (n int)
type ConstraintType ¶ added in v0.7.0
type ConstraintType int8
const ( Index ConstraintType = iota RefChildTable ForeignKey PrimaryKey StreamConfig )
type Database ¶
type Database interface { Relations(context.Context) ([]string, error) Relation(context.Context, string, any) (Relation, error) Delete(context.Context, string) error Create(context.Context, string, []TableDef) error // Create Table - (name, table define) Truncate(context.Context, string) (uint64, error) GetDatabaseId(context.Context) string IsSubscription(context.Context) bool GetCreateSql(context.Context) string }
type Engine ¶
type Engine interface { // transaction interface New(ctx context.Context, op client.TxnOperator) error // Delete deletes a database Delete(ctx context.Context, databaseName string, op client.TxnOperator) error // Create creates a database Create(ctx context.Context, databaseName string, op client.TxnOperator) error // Databases returns all database names Databases(ctx context.Context, op client.TxnOperator) (databaseNames []string, err error) // Database creates a handle for a database Database(ctx context.Context, databaseName string, op client.TxnOperator) (Database, error) // Nodes returns all nodes for worker jobs. isInternal, tenant, cnLabel are // used to filter CN servers. Nodes(isInternal bool, tenant string, username string, cnLabel map[string]string) (cnNodes Nodes, err error) // Hints returns hints of engine features // return value should not be cached // since implementations may update hints after engine had initialized Hints() Hints NewBlockReader(ctx context.Context, num int, ts timestamp.Timestamp, expr *plan.Expr, ranges [][]byte, tblDef *plan.TableDef, proc any) ([]Reader, error) // Get database name & table name by table id GetNameById(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, err error) // Get relation by table id GetRelationById(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, rel Relation, err error) // AllocateIDByKey allocate a globally unique ID by key. AllocateIDByKey(ctx context.Context, key string) (uint64, error) }
type EngineType ¶ added in v0.8.0
type EngineType int8
const ( Disttae EngineType = iota Memory UNKNOWN )
type EntireEngine ¶ added in v0.7.0
type EntireEngine struct { Engine Engine // original engine TempEngine Engine // new engine for temporarily table }
EntireEngine is a wrapper for Engine to support temporary table
func (*EntireEngine) AllocateIDByKey ¶ added in v0.8.0
func (*EntireEngine) Create ¶ added in v0.7.0
func (e *EntireEngine) Create(ctx context.Context, databaseName string, op client.TxnOperator) error
func (*EntireEngine) Database ¶ added in v0.7.0
func (e *EntireEngine) Database(ctx context.Context, databaseName string, op client.TxnOperator) (Database, error)
func (*EntireEngine) Databases ¶ added in v0.7.0
func (e *EntireEngine) Databases(ctx context.Context, op client.TxnOperator) (databaseNames []string, err error)
func (*EntireEngine) Delete ¶ added in v0.7.0
func (e *EntireEngine) Delete(ctx context.Context, databaseName string, op client.TxnOperator) error
func (*EntireEngine) GetNameById ¶ added in v0.7.0
func (e *EntireEngine) GetNameById(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, err error)
func (*EntireEngine) GetRelationById ¶ added in v0.7.0
func (e *EntireEngine) GetRelationById(ctx context.Context, op client.TxnOperator, tableId uint64) (dbName string, tblName string, rel Relation, err error)
func (*EntireEngine) Hints ¶ added in v0.7.0
func (e *EntireEngine) Hints() Hints
func (*EntireEngine) New ¶ added in v0.7.0
func (e *EntireEngine) New(ctx context.Context, op client.TxnOperator) error
func (*EntireEngine) NewBlockReader ¶ added in v0.7.0
type ForeignKeyDef ¶ added in v0.7.0
type ForeignKeyDef struct {
Fkeys []*plan.ForeignKeyDef
}
func (*ForeignKeyDef) Descriptor ¶ added in v0.8.0
func (*ForeignKeyDef) Descriptor() ([]byte, []int)
func (*ForeignKeyDef) GetFkeys ¶ added in v0.8.0
func (m *ForeignKeyDef) GetFkeys() []*plan.ForeignKeyDef
func (*ForeignKeyDef) Marshal ¶ added in v0.8.0
func (m *ForeignKeyDef) Marshal() (dAtA []byte, err error)
func (*ForeignKeyDef) MarshalTo ¶ added in v0.8.0
func (m *ForeignKeyDef) MarshalTo(dAtA []byte) (int, error)
func (*ForeignKeyDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *ForeignKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ForeignKeyDef) ProtoMessage ¶ added in v0.8.0
func (*ForeignKeyDef) ProtoMessage()
func (*ForeignKeyDef) ProtoSize ¶ added in v0.8.0
func (m *ForeignKeyDef) ProtoSize() (n int)
func (*ForeignKeyDef) Reset ¶ added in v0.8.0
func (m *ForeignKeyDef) Reset()
func (*ForeignKeyDef) String ¶ added in v0.8.0
func (m *ForeignKeyDef) String() string
func (*ForeignKeyDef) ToPBVersion ¶ added in v0.8.0
func (def *ForeignKeyDef) ToPBVersion() ConstraintPB
func (*ForeignKeyDef) Unmarshal ¶ added in v0.8.0
func (m *ForeignKeyDef) Unmarshal(dAtA []byte) error
func (*ForeignKeyDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *ForeignKeyDef) XXX_DiscardUnknown()
func (*ForeignKeyDef) XXX_Marshal ¶ added in v0.8.0
func (m *ForeignKeyDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ForeignKeyDef) XXX_Merge ¶ added in v0.8.0
func (m *ForeignKeyDef) XXX_Merge(src proto.Message)
func (*ForeignKeyDef) XXX_Size ¶ added in v0.8.0
func (m *ForeignKeyDef) XXX_Size() int
func (*ForeignKeyDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *ForeignKeyDef) XXX_Unmarshal(b []byte) error
type IndexDef ¶ added in v0.7.0
func (*IndexDef) Descriptor ¶ added in v0.8.0
func (*IndexDef) GetIndexes ¶ added in v0.8.0
func (*IndexDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (*IndexDef) ProtoMessage ¶ added in v0.8.0
func (*IndexDef) ProtoMessage()
func (*IndexDef) ToPBVersion ¶ added in v0.8.0
func (def *IndexDef) ToPBVersion() ConstraintPB
func (*IndexDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *IndexDef) XXX_DiscardUnknown()
func (*IndexDef) XXX_Marshal ¶ added in v0.8.0
func (*IndexDef) XXX_Unmarshal ¶ added in v0.8.0
type IndexTableDef ¶
func (*IndexTableDef) Descriptor ¶ added in v0.8.0
func (*IndexTableDef) Descriptor() ([]byte, []int)
func (*IndexTableDef) Format ¶
func (def *IndexTableDef) Format(buf *bytes.Buffer)
func (*IndexTableDef) GetColNames ¶ added in v0.8.0
func (m *IndexTableDef) GetColNames() []string
func (*IndexTableDef) GetName ¶ added in v0.8.0
func (m *IndexTableDef) GetName() string
func (*IndexTableDef) GetTyp ¶ added in v0.8.0
func (m *IndexTableDef) GetTyp() IndexT
func (*IndexTableDef) Marshal ¶ added in v0.8.0
func (m *IndexTableDef) Marshal() (dAtA []byte, err error)
func (*IndexTableDef) MarshalTo ¶ added in v0.8.0
func (m *IndexTableDef) MarshalTo(dAtA []byte) (int, error)
func (*IndexTableDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *IndexTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IndexTableDef) ProtoMessage ¶ added in v0.8.0
func (*IndexTableDef) ProtoMessage()
func (*IndexTableDef) ProtoSize ¶ added in v0.8.0
func (m *IndexTableDef) ProtoSize() (n int)
func (*IndexTableDef) Reset ¶ added in v0.8.0
func (m *IndexTableDef) Reset()
func (*IndexTableDef) String ¶ added in v0.8.0
func (m *IndexTableDef) String() string
func (*IndexTableDef) ToPBVersion ¶ added in v0.8.0
func (def *IndexTableDef) ToPBVersion() TableDefPB
func (*IndexTableDef) Unmarshal ¶ added in v0.8.0
func (m *IndexTableDef) Unmarshal(dAtA []byte) error
func (*IndexTableDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *IndexTableDef) XXX_DiscardUnknown()
func (*IndexTableDef) XXX_Marshal ¶ added in v0.8.0
func (m *IndexTableDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IndexTableDef) XXX_Merge ¶ added in v0.8.0
func (m *IndexTableDef) XXX_Merge(src proto.Message)
func (*IndexTableDef) XXX_Size ¶ added in v0.8.0
func (m *IndexTableDef) XXX_Size() int
func (*IndexTableDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *IndexTableDef) XXX_Unmarshal(b []byte) error
type PartitionDef ¶ added in v0.6.0
func (*PartitionDef) Descriptor ¶ added in v0.8.0
func (*PartitionDef) Descriptor() ([]byte, []int)
func (*PartitionDef) GetPartition ¶ added in v0.8.0
func (m *PartitionDef) GetPartition() string
func (*PartitionDef) Marshal ¶ added in v0.8.0
func (m *PartitionDef) Marshal() (dAtA []byte, err error)
func (*PartitionDef) MarshalTo ¶ added in v0.8.0
func (m *PartitionDef) MarshalTo(dAtA []byte) (int, error)
func (*PartitionDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *PartitionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionDef) ProtoMessage ¶ added in v0.8.0
func (*PartitionDef) ProtoMessage()
func (*PartitionDef) ProtoSize ¶ added in v0.8.0
func (m *PartitionDef) ProtoSize() (n int)
func (*PartitionDef) Reset ¶ added in v0.8.0
func (m *PartitionDef) Reset()
func (*PartitionDef) String ¶ added in v0.8.0
func (m *PartitionDef) String() string
func (*PartitionDef) ToPBVersion ¶ added in v0.8.0
func (def *PartitionDef) ToPBVersion() TableDefPB
func (*PartitionDef) Unmarshal ¶ added in v0.8.0
func (m *PartitionDef) Unmarshal(dAtA []byte) error
func (*PartitionDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *PartitionDef) XXX_DiscardUnknown()
func (*PartitionDef) XXX_Marshal ¶ added in v0.8.0
func (m *PartitionDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionDef) XXX_Merge ¶ added in v0.8.0
func (m *PartitionDef) XXX_Merge(src proto.Message)
func (*PartitionDef) XXX_Size ¶ added in v0.8.0
func (m *PartitionDef) XXX_Size() int
func (*PartitionDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *PartitionDef) XXX_Unmarshal(b []byte) error
type PrimaryKeyDef ¶ added in v0.7.0
type PrimaryKeyDef struct {
Pkey *plan.PrimaryKeyDef
}
func (*PrimaryKeyDef) Descriptor ¶ added in v0.8.0
func (*PrimaryKeyDef) Descriptor() ([]byte, []int)
func (*PrimaryKeyDef) GetPkey ¶ added in v0.8.0
func (m *PrimaryKeyDef) GetPkey() *plan.PrimaryKeyDef
func (*PrimaryKeyDef) Marshal ¶ added in v0.8.0
func (m *PrimaryKeyDef) Marshal() (dAtA []byte, err error)
func (*PrimaryKeyDef) MarshalTo ¶ added in v0.8.0
func (m *PrimaryKeyDef) MarshalTo(dAtA []byte) (int, error)
func (*PrimaryKeyDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *PrimaryKeyDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PrimaryKeyDef) ProtoMessage ¶ added in v0.8.0
func (*PrimaryKeyDef) ProtoMessage()
func (*PrimaryKeyDef) ProtoSize ¶ added in v0.8.0
func (m *PrimaryKeyDef) ProtoSize() (n int)
func (*PrimaryKeyDef) Reset ¶ added in v0.8.0
func (m *PrimaryKeyDef) Reset()
func (*PrimaryKeyDef) String ¶ added in v0.8.0
func (m *PrimaryKeyDef) String() string
func (*PrimaryKeyDef) ToPBVersion ¶ added in v0.8.0
func (def *PrimaryKeyDef) ToPBVersion() ConstraintPB
func (*PrimaryKeyDef) Unmarshal ¶ added in v0.8.0
func (m *PrimaryKeyDef) Unmarshal(dAtA []byte) error
func (*PrimaryKeyDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *PrimaryKeyDef) XXX_DiscardUnknown()
func (*PrimaryKeyDef) XXX_Marshal ¶ added in v0.8.0
func (m *PrimaryKeyDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrimaryKeyDef) XXX_Merge ¶ added in v0.8.0
func (m *PrimaryKeyDef) XXX_Merge(src proto.Message)
func (*PrimaryKeyDef) XXX_Size ¶ added in v0.8.0
func (m *PrimaryKeyDef) XXX_Size() int
func (*PrimaryKeyDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *PrimaryKeyDef) XXX_Unmarshal(b []byte) error
type PropertiesDef ¶
type PropertiesDef struct {
Properties []Property
}
func (*PropertiesDef) Descriptor ¶ added in v0.8.0
func (*PropertiesDef) Descriptor() ([]byte, []int)
func (*PropertiesDef) GetProperties ¶ added in v0.8.0
func (m *PropertiesDef) GetProperties() []Property
func (*PropertiesDef) Marshal ¶ added in v0.8.0
func (m *PropertiesDef) Marshal() (dAtA []byte, err error)
func (*PropertiesDef) MarshalTo ¶ added in v0.8.0
func (m *PropertiesDef) MarshalTo(dAtA []byte) (int, error)
func (*PropertiesDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *PropertiesDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PropertiesDef) ProtoMessage ¶ added in v0.8.0
func (*PropertiesDef) ProtoMessage()
func (*PropertiesDef) ProtoSize ¶ added in v0.8.0
func (m *PropertiesDef) ProtoSize() (n int)
func (*PropertiesDef) Reset ¶ added in v0.8.0
func (m *PropertiesDef) Reset()
func (*PropertiesDef) String ¶ added in v0.8.0
func (m *PropertiesDef) String() string
func (*PropertiesDef) ToPBVersion ¶ added in v0.8.0
func (def *PropertiesDef) ToPBVersion() TableDefPB
func (*PropertiesDef) Unmarshal ¶ added in v0.8.0
func (m *PropertiesDef) Unmarshal(dAtA []byte) error
func (*PropertiesDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *PropertiesDef) XXX_DiscardUnknown()
func (*PropertiesDef) XXX_Marshal ¶ added in v0.8.0
func (m *PropertiesDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PropertiesDef) XXX_Merge ¶ added in v0.8.0
func (m *PropertiesDef) XXX_Merge(src proto.Message)
func (*PropertiesDef) XXX_Size ¶ added in v0.8.0
func (m *PropertiesDef) XXX_Size() int
func (*PropertiesDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *PropertiesDef) XXX_Unmarshal(b []byte) error
type Property ¶
func (*Property) Descriptor ¶ added in v0.8.0
func (*Property) MarshalToSizedBuffer ¶ added in v0.8.0
func (*Property) ProtoMessage ¶ added in v0.8.0
func (*Property) ProtoMessage()
func (*Property) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *Property) XXX_DiscardUnknown()
func (*Property) XXX_Marshal ¶ added in v0.8.0
func (*Property) XXX_Unmarshal ¶ added in v0.8.0
type RefChildTableDef ¶ added in v0.7.0
type RefChildTableDef struct {
Tables []uint64
}
func (*RefChildTableDef) Descriptor ¶ added in v0.8.0
func (*RefChildTableDef) Descriptor() ([]byte, []int)
func (*RefChildTableDef) GetTables ¶ added in v0.8.0
func (m *RefChildTableDef) GetTables() []uint64
func (*RefChildTableDef) Marshal ¶ added in v0.8.0
func (m *RefChildTableDef) Marshal() (dAtA []byte, err error)
func (*RefChildTableDef) MarshalTo ¶ added in v0.8.0
func (m *RefChildTableDef) MarshalTo(dAtA []byte) (int, error)
func (*RefChildTableDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *RefChildTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RefChildTableDef) ProtoMessage ¶ added in v0.8.0
func (*RefChildTableDef) ProtoMessage()
func (*RefChildTableDef) ProtoSize ¶ added in v0.8.0
func (m *RefChildTableDef) ProtoSize() (n int)
func (*RefChildTableDef) Reset ¶ added in v0.8.0
func (m *RefChildTableDef) Reset()
func (*RefChildTableDef) String ¶ added in v0.8.0
func (m *RefChildTableDef) String() string
func (*RefChildTableDef) ToPBVersion ¶ added in v0.8.0
func (def *RefChildTableDef) ToPBVersion() ConstraintPB
func (*RefChildTableDef) Unmarshal ¶ added in v0.8.0
func (m *RefChildTableDef) Unmarshal(dAtA []byte) error
func (*RefChildTableDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *RefChildTableDef) XXX_DiscardUnknown()
func (*RefChildTableDef) XXX_Marshal ¶ added in v0.8.0
func (m *RefChildTableDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RefChildTableDef) XXX_Merge ¶ added in v0.8.0
func (m *RefChildTableDef) XXX_Merge(src proto.Message)
func (*RefChildTableDef) XXX_Size ¶ added in v0.8.0
func (m *RefChildTableDef) XXX_Size() int
func (*RefChildTableDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *RefChildTableDef) XXX_Unmarshal(b []byte) error
type Relation ¶
type Relation interface { Statistics UpdateObjectInfos(context.Context) error Ranges(context.Context, []*plan.Expr) ([][]byte, error) TableDefs(context.Context) ([]TableDef, error) // Get complete tableDef information, including columns, constraints, partitions, version, comments, etc GetTableDef(context.Context) *plan.TableDef GetPrimaryKeys(context.Context) ([]*Attribute, error) GetHideKeys(context.Context) ([]*Attribute, error) Write(context.Context, *batch.Batch) error Update(context.Context, *batch.Batch) error // Delete(context.Context, *vector.Vector, string) error Delete(context.Context, *batch.Batch, string) error AddTableDef(context.Context, TableDef) error DelTableDef(context.Context, TableDef) error // only ConstraintDef can be modified UpdateConstraint(context.Context, *ConstraintDef) error AlterTable(ctx context.Context, c *ConstraintDef, constraint [][]byte) error // Support renaming tables within explicit transactions (CN worspace) TableRenameInTxn(ctx context.Context, constraint [][]byte) error GetTableID(context.Context) uint64 // GetTableName returns the name of the table. GetTableName() string GetDBID(context.Context) uint64 // second argument is the number of reader, third argument is the filter extend, foruth parameter is the payload required by the engine NewReader(context.Context, int, *plan.Expr, [][]byte) ([]Reader, error) TableColumns(ctx context.Context) ([]*Attribute, error) //max and min values MaxAndMinValues(ctx context.Context) ([][2]any, []uint8, error) GetEngineType() EngineType GetColumMetadataScanInfo(ctx context.Context, name string) ([]*plan.MetadataScanInfo, error) // PrimaryKeysMayBeModified reports whether any rows with any primary keys in keyVector was modified during `from` to `to` // If not sure, returns true // Initially added for implementing locking rows by primary keys PrimaryKeysMayBeModified(ctx context.Context, from types.TS, to types.TS, keyVector *vector.Vector) (bool, error) }
type Statistics ¶
type StreamConfigsDef ¶ added in v1.0.0
func (*StreamConfigsDef) Descriptor ¶ added in v1.0.0
func (*StreamConfigsDef) Descriptor() ([]byte, []int)
func (*StreamConfigsDef) GetConfigs ¶ added in v1.0.0
func (m *StreamConfigsDef) GetConfigs() []*plan.Property
func (*StreamConfigsDef) Marshal ¶ added in v1.0.0
func (m *StreamConfigsDef) Marshal() (dAtA []byte, err error)
func (*StreamConfigsDef) MarshalTo ¶ added in v1.0.0
func (m *StreamConfigsDef) MarshalTo(dAtA []byte) (int, error)
func (*StreamConfigsDef) MarshalToSizedBuffer ¶ added in v1.0.0
func (m *StreamConfigsDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamConfigsDef) ProtoMessage ¶ added in v1.0.0
func (*StreamConfigsDef) ProtoMessage()
func (*StreamConfigsDef) ProtoSize ¶ added in v1.0.0
func (m *StreamConfigsDef) ProtoSize() (n int)
func (*StreamConfigsDef) Reset ¶ added in v1.0.0
func (m *StreamConfigsDef) Reset()
func (*StreamConfigsDef) String ¶ added in v1.0.0
func (m *StreamConfigsDef) String() string
func (*StreamConfigsDef) ToPBVersion ¶ added in v1.0.0
func (def *StreamConfigsDef) ToPBVersion() ConstraintPB
func (*StreamConfigsDef) Unmarshal ¶ added in v1.0.0
func (m *StreamConfigsDef) Unmarshal(dAtA []byte) error
func (*StreamConfigsDef) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *StreamConfigsDef) XXX_DiscardUnknown()
func (*StreamConfigsDef) XXX_Marshal ¶ added in v1.0.0
func (m *StreamConfigsDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamConfigsDef) XXX_Merge ¶ added in v1.0.0
func (m *StreamConfigsDef) XXX_Merge(src proto.Message)
func (*StreamConfigsDef) XXX_Size ¶ added in v1.0.0
func (m *StreamConfigsDef) XXX_Size() int
func (*StreamConfigsDef) XXX_Unmarshal ¶ added in v1.0.0
func (m *StreamConfigsDef) XXX_Unmarshal(b []byte) error
type TableDef ¶
type TableDef interface { // ToPBVersion returns corresponding PB struct. ToPBVersion() TableDefPB // contains filtered or unexported methods }
type TableDefPB ¶ added in v0.8.0
type TableDefPB struct { // Types that are valid to be assigned to Def: // *TableDefPB_CommentDef // *TableDefPB_PartitionDef // *TableDefPB_ViewDef // *TableDefPB_AttributeDef // *TableDefPB_IndexTableDef // *TableDefPB_PropertiesDef // *TableDefPB_ClusterByDef // *TableDefPB_ConstraintDefPB // *TableDefPB_VersionDef Def isTableDefPB_Def `protobuf_oneof:"def"` }
PB version of TableDef
func (*TableDefPB) Descriptor ¶ added in v0.8.0
func (*TableDefPB) Descriptor() ([]byte, []int)
func (*TableDefPB) FromPBVersion ¶ added in v0.8.0
func (def *TableDefPB) FromPBVersion() TableDef
func (*TableDefPB) GetAttributeDef ¶ added in v0.8.0
func (m *TableDefPB) GetAttributeDef() *AttributeDef
func (*TableDefPB) GetClusterByDef ¶ added in v0.8.0
func (m *TableDefPB) GetClusterByDef() *ClusterByDef
func (*TableDefPB) GetCommentDef ¶ added in v0.8.0
func (m *TableDefPB) GetCommentDef() *CommentDef
func (*TableDefPB) GetConstraintDefPB ¶ added in v0.8.0
func (m *TableDefPB) GetConstraintDefPB() *ConstraintDefPB
func (*TableDefPB) GetDef ¶ added in v0.8.0
func (m *TableDefPB) GetDef() isTableDefPB_Def
func (*TableDefPB) GetIndexTableDef ¶ added in v0.8.0
func (m *TableDefPB) GetIndexTableDef() *IndexTableDef
func (*TableDefPB) GetPartitionDef ¶ added in v0.8.0
func (m *TableDefPB) GetPartitionDef() *PartitionDef
func (*TableDefPB) GetPropertiesDef ¶ added in v0.8.0
func (m *TableDefPB) GetPropertiesDef() *PropertiesDef
func (*TableDefPB) GetVersionDef ¶ added in v0.8.0
func (m *TableDefPB) GetVersionDef() *VersionDef
func (*TableDefPB) GetViewDef ¶ added in v0.8.0
func (m *TableDefPB) GetViewDef() *ViewDef
func (*TableDefPB) Marshal ¶ added in v0.8.0
func (m *TableDefPB) Marshal() (dAtA []byte, err error)
func (*TableDefPB) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB) ProtoMessage ¶ added in v0.8.0
func (*TableDefPB) ProtoMessage()
func (*TableDefPB) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB) ProtoSize() (n int)
func (*TableDefPB) Reset ¶ added in v0.8.0
func (m *TableDefPB) Reset()
func (*TableDefPB) String ¶ added in v0.8.0
func (m *TableDefPB) String() string
func (*TableDefPB) Unmarshal ¶ added in v0.8.0
func (m *TableDefPB) Unmarshal(dAtA []byte) error
func (*TableDefPB) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *TableDefPB) XXX_DiscardUnknown()
func (*TableDefPB) XXX_Marshal ¶ added in v0.8.0
func (m *TableDefPB) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TableDefPB) XXX_Merge ¶ added in v0.8.0
func (m *TableDefPB) XXX_Merge(src proto.Message)
func (*TableDefPB) XXX_OneofWrappers ¶ added in v0.8.0
func (*TableDefPB) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*TableDefPB) XXX_Size ¶ added in v0.8.0
func (m *TableDefPB) XXX_Size() int
func (*TableDefPB) XXX_Unmarshal ¶ added in v0.8.0
func (m *TableDefPB) XXX_Unmarshal(b []byte) error
type TableDefPB_AttributeDef ¶ added in v0.8.0
type TableDefPB_AttributeDef struct {
AttributeDef *AttributeDef `protobuf:"bytes,4,opt,name=AttributeDef,proto3,oneof" json:"AttributeDef,omitempty"`
}
func (*TableDefPB_AttributeDef) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_AttributeDef) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_AttributeDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_AttributeDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_AttributeDef) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_AttributeDef) ProtoSize() (n int)
type TableDefPB_ClusterByDef ¶ added in v0.8.0
type TableDefPB_ClusterByDef struct {
ClusterByDef *ClusterByDef `protobuf:"bytes,7,opt,name=ClusterByDef,proto3,oneof" json:"ClusterByDef,omitempty"`
}
func (*TableDefPB_ClusterByDef) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_ClusterByDef) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_ClusterByDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_ClusterByDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_ClusterByDef) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_ClusterByDef) ProtoSize() (n int)
type TableDefPB_CommentDef ¶ added in v0.8.0
type TableDefPB_CommentDef struct {
CommentDef *CommentDef `protobuf:"bytes,1,opt,name=CommentDef,proto3,oneof" json:"CommentDef,omitempty"`
}
func (*TableDefPB_CommentDef) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_CommentDef) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_CommentDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_CommentDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_CommentDef) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_CommentDef) ProtoSize() (n int)
type TableDefPB_ConstraintDefPB ¶ added in v0.8.0
type TableDefPB_ConstraintDefPB struct {
ConstraintDefPB *ConstraintDefPB `protobuf:"bytes,8,opt,name=ConstraintDefPB,proto3,oneof" json:"ConstraintDefPB,omitempty"`
}
func (*TableDefPB_ConstraintDefPB) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_ConstraintDefPB) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_ConstraintDefPB) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_ConstraintDefPB) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_ConstraintDefPB) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_ConstraintDefPB) ProtoSize() (n int)
type TableDefPB_IndexTableDef ¶ added in v0.8.0
type TableDefPB_IndexTableDef struct {
IndexTableDef *IndexTableDef `protobuf:"bytes,5,opt,name=IndexTableDef,proto3,oneof" json:"IndexTableDef,omitempty"`
}
func (*TableDefPB_IndexTableDef) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_IndexTableDef) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_IndexTableDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_IndexTableDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_IndexTableDef) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_IndexTableDef) ProtoSize() (n int)
type TableDefPB_PartitionDef ¶ added in v0.8.0
type TableDefPB_PartitionDef struct {
PartitionDef *PartitionDef `protobuf:"bytes,2,opt,name=PartitionDef,proto3,oneof" json:"PartitionDef,omitempty"`
}
func (*TableDefPB_PartitionDef) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_PartitionDef) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_PartitionDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_PartitionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_PartitionDef) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_PartitionDef) ProtoSize() (n int)
type TableDefPB_PropertiesDef ¶ added in v0.8.0
type TableDefPB_PropertiesDef struct {
PropertiesDef *PropertiesDef `protobuf:"bytes,6,opt,name=PropertiesDef,proto3,oneof" json:"PropertiesDef,omitempty"`
}
func (*TableDefPB_PropertiesDef) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_PropertiesDef) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_PropertiesDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_PropertiesDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_PropertiesDef) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_PropertiesDef) ProtoSize() (n int)
type TableDefPB_VersionDef ¶ added in v0.8.0
type TableDefPB_VersionDef struct {
VersionDef *VersionDef `protobuf:"bytes,9,opt,name=VersionDef,proto3,oneof" json:"VersionDef,omitempty"`
}
func (*TableDefPB_VersionDef) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_VersionDef) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_VersionDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_VersionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_VersionDef) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_VersionDef) ProtoSize() (n int)
type TableDefPB_ViewDef ¶ added in v0.8.0
type TableDefPB_ViewDef struct {
ViewDef *ViewDef `protobuf:"bytes,3,opt,name=ViewDef,proto3,oneof" json:"ViewDef,omitempty"`
}
func (*TableDefPB_ViewDef) MarshalTo ¶ added in v0.8.0
func (m *TableDefPB_ViewDef) MarshalTo(dAtA []byte) (int, error)
func (*TableDefPB_ViewDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *TableDefPB_ViewDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TableDefPB_ViewDef) ProtoSize ¶ added in v0.8.0
func (m *TableDefPB_ViewDef) ProtoSize() (n int)
type VectorPool ¶ added in v0.8.0
type VersionDef ¶ added in v0.8.0
type VersionDef struct {
Version uint32
}
func (*VersionDef) Descriptor ¶ added in v0.8.0
func (*VersionDef) Descriptor() ([]byte, []int)
func (*VersionDef) GetVersion ¶ added in v0.8.0
func (m *VersionDef) GetVersion() uint32
func (*VersionDef) Marshal ¶ added in v0.8.0
func (m *VersionDef) Marshal() (dAtA []byte, err error)
func (*VersionDef) MarshalTo ¶ added in v0.8.0
func (m *VersionDef) MarshalTo(dAtA []byte) (int, error)
func (*VersionDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (m *VersionDef) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*VersionDef) ProtoMessage ¶ added in v0.8.0
func (*VersionDef) ProtoMessage()
func (*VersionDef) ProtoSize ¶ added in v0.8.0
func (m *VersionDef) ProtoSize() (n int)
func (*VersionDef) Reset ¶ added in v0.8.0
func (m *VersionDef) Reset()
func (*VersionDef) String ¶ added in v0.8.0
func (m *VersionDef) String() string
func (*VersionDef) ToPBVersion ¶ added in v0.8.0
func (def *VersionDef) ToPBVersion() TableDefPB
func (*VersionDef) Unmarshal ¶ added in v0.8.0
func (m *VersionDef) Unmarshal(dAtA []byte) error
func (*VersionDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *VersionDef) XXX_DiscardUnknown()
func (*VersionDef) XXX_Marshal ¶ added in v0.8.0
func (m *VersionDef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VersionDef) XXX_Merge ¶ added in v0.8.0
func (m *VersionDef) XXX_Merge(src proto.Message)
func (*VersionDef) XXX_Size ¶ added in v0.8.0
func (m *VersionDef) XXX_Size() int
func (*VersionDef) XXX_Unmarshal ¶ added in v0.8.0
func (m *VersionDef) XXX_Unmarshal(b []byte) error
type ViewDef ¶ added in v0.6.0
type ViewDef struct {
View string
}
func (*ViewDef) Descriptor ¶ added in v0.8.0
func (*ViewDef) MarshalToSizedBuffer ¶ added in v0.8.0
func (*ViewDef) ProtoMessage ¶ added in v0.8.0
func (*ViewDef) ProtoMessage()
func (*ViewDef) ToPBVersion ¶ added in v0.8.0
func (def *ViewDef) ToPBVersion() TableDefPB
func (*ViewDef) XXX_DiscardUnknown ¶ added in v0.8.0
func (m *ViewDef) XXX_DiscardUnknown()
func (*ViewDef) XXX_Marshal ¶ added in v0.8.0
func (*ViewDef) XXX_Unmarshal ¶ added in v0.8.0
Directories
¶
Path | Synopsis |
---|---|
tae
|
|
common
A few allocators for TAE
|
A few allocators for TAE |
logtail/service
This package implements client and server for logtail push model.
|
This package implements client and server for logtail push model. |
mergesort
Package heap provides heap operations for any type that implements heap.Interface.
|
Package heap provides heap operations for any type that implements heap.Interface. |
Click to show internal directories.
Click to hide internal directories.